Package gluon :: Module dal :: Class MongoDBAdapter
[hide private]
[frames] | no frames]

Class MongoDBAdapter

source code

    object --+            
             |            
ConnectionPool --+        
                 |        
       BaseAdapter --+    
                     |    
          NoSQLAdapter --+
                         |
                        MongoDBAdapter

Nested Classes [hide private]

Inherited from BaseAdapter: __metaclass__

Instance Methods [hide private]
 
__init__(self, db, uri='mongodb://127.0.0.1:5984/db', pool_size=0, folder=None, db_codec='UTF-8', credential_decoder=<function IDENTITY at 0x334cd70>, driver_args={}, adapter_args={}, do_connect=True, after_connection=None)
x.__init__(...) initializes x; see help(type(x)) for signature
source code
 
object_id(self, arg=None)
Convert input to a valid Mongodb ObjectId instance
source code
 
parse_reference(self, value, field_type) source code
 
parse_id(self, value, field_type) source code
 
represent(self, obj, fieldtype) source code
 
create_table(self, table, migrate=True, fake_migrate=False, polymodel=None, isCapped=False) source code
 
count(self, query, distinct=None, snapshot=True) source code
 
expand(self, expression, field_type=None) source code
 
drop(self, table, mode='') source code
 
truncate(self, table, mode, safe=None) source code
 
select(self, query, fields, attributes, count=False, snapshot=False)
Always returns a Rows object, possibly empty.
source code
 
insert(self, table, fields, safe=None)
Safe determines whether a asynchronious request is done or a synchronious action is done For safety, we use by default synchronous requests
source code
 
update(self, tablename, query, fields, safe=None) source code
 
delete(self, tablename, query, safe=None) source code
 
bulk_insert(self, table, items) source code
 
INVERT(self, first) source code
 
NOT(self, first) source code
 
AND(self, first, second) source code
 
OR(self, first, second) source code
 
BELONGS(self, first, second) source code
 
EQ(self, first, second=None) source code
 
NE(self, first, second=None) source code
 
LT(self, first, second=None) source code
 
LE(self, first, second=None) source code
 
GT(self, first, second) source code
 
GE(self, first, second=None) source code
 
ADD(self, first, second) source code
 
SUB(self, first, second) source code
 
MUL(self, first, second) source code
 
DIV(self, first, second) source code
 
MOD(self, first, second) source code
 
AS(self, first, second) source code
 
ON(self, first, second) source code
 
COMMA(self, first, second) source code
 
ILIKE(self, first, second)
case in-sensitive like operator
source code
 
LIKE(self, first, second)
case sensitive like operator
source code
 
STARTSWITH(self, first, second) source code
 
ENDSWITH(self, first, second) source code
 
CONTAINS(self, first, second, case_sensitive=False) source code

Inherited from NoSQLAdapter: AGGREGATE, EXTRACT, LEFT_JOIN, LENGTH, LOWER, PRIMARY_KEY, RANDOM, SUBSTRING, UPPER, alias, close_connection, commit, commit_prepared, concat_add, constraint_name, create_sequence_and_triggers, distributed_transaction_begin, execute, id_query, lastrowid, log_execute, migrate_table, prepare, represent_exceptions, rollback, rollback_prepared, rowslice

Inherited from NoSQLAdapter (private): _count, _delete, _insert, _select, _update

Inherited from BaseAdapter: ALLOW_NULL, CASE, CAST, COALESCE, COALESCE_ZERO, CONCAT, COUNT, EPOCH, JOIN, NOT_NULL, RAW, REGEXP, REPLACE, adapt, build_parsemap, common_filter, connector, expand_all, file_close, file_delete, file_exists, file_open, find_driver, get_table, isOperationalError, isProgrammingError, is_numerical_type, log, parse, parse_blob, parse_boolean, parse_date, parse_datetime, parse_decimal, parse_double, parse_integer, parse_json, parse_list_integers, parse_list_references, parse_list_strings, parse_time, parse_value, save_dbt, select_limitby, sequence_name, smart_adapt, sqlsafe_field, sqlsafe_table, table_alias, tables, trigger_name, varquote

Inherited from ConnectionPool: after_connection, after_connection_hook, close, find_or_make_work_folder, reconnect

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Static Methods [hide private]

Inherited from NoSQLAdapter: to_unicode

Inherited from ConnectionPool: close_all_instances, set_folder

Class Variables [hide private]
  native_json = True
  drivers = ('pymongo')
  uploads_in_blob = False
  types = {'bigint': <type 'long'>, 'blob': <type 'str'>, 'boole...
  error_messages = {'javascript_needed': 'This must yet be repla...

Inherited from NoSQLAdapter: QUOTE_TEMPLATE, can_select_for_update

Inherited from BaseAdapter: FALSE, TRUE, T_SEP, commit_on_alter_table, connection, dbpath, driver, driver_name, folder, support_distributed_transaction

Inherited from ConnectionPool: POOLS, check_active_connection

Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

__init__(self, db, uri='mongodb://127.0.0.1:5984/db', pool_size=0, folder=None, db_codec='UTF-8', credential_decoder=<function IDENTITY at 0x334cd70>, driver_args={}, adapter_args={}, do_connect=True, after_connection=None)
(Constructor)

source code 

x.__init__(...) initializes x; see help(type(x)) for signature

Overrides: object.__init__
(inherited documentation)

object_id(self, arg=None)

source code 

Convert input to a valid Mongodb ObjectId instance

self.object_id("<random>") -> ObjectId (not unique) instance

parse_reference(self, value, field_type)

source code 
Overrides: BaseAdapter.parse_reference

parse_id(self, value, field_type)

source code 
Overrides: BaseAdapter.parse_id

represent(self, obj, fieldtype)

source code 
Overrides: BaseAdapter.represent

create_table(self, table, migrate=True, fake_migrate=False, polymodel=None, isCapped=False)

source code 
Overrides: BaseAdapter.create_table

count(self, query, distinct=None, snapshot=True)

source code 
Overrides: BaseAdapter.count

expand(self, expression, field_type=None)

source code 
Overrides: BaseAdapter.expand

drop(self, table, mode='')

source code 
Overrides: BaseAdapter.drop

truncate(self, table, mode, safe=None)

source code 
Overrides: BaseAdapter.truncate

select(self, query, fields, attributes, count=False, snapshot=False)

source code 

Always returns a Rows object, possibly empty.

Overrides: BaseAdapter.select
(inherited documentation)

insert(self, table, fields, safe=None)

source code 

Safe determines whether a asynchronious request is done or a synchronious action is done For safety, we use by default synchronous requests

Overrides: BaseAdapter.insert

update(self, tablename, query, fields, safe=None)

source code 
Overrides: BaseAdapter.update

delete(self, tablename, query, safe=None)

source code 
Overrides: BaseAdapter.delete

bulk_insert(self, table, items)

source code 
Overrides: BaseAdapter.bulk_insert

INVERT(self, first)

source code 
Overrides: BaseAdapter.INVERT

NOT(self, first)

source code 
Overrides: BaseAdapter.NOT

AND(self, first, second)

source code 
Overrides: BaseAdapter.AND

OR(self, first, second)

source code 
Overrides: BaseAdapter.OR

BELONGS(self, first, second)

source code 
Overrides: BaseAdapter.BELONGS

EQ(self, first, second=None)

source code 
Overrides: BaseAdapter.EQ

NE(self, first, second=None)

source code 
Overrides: BaseAdapter.NE

LT(self, first, second=None)

source code 
Overrides: BaseAdapter.LT

LE(self, first, second=None)

source code 
Overrides: BaseAdapter.LE

GT(self, first, second)

source code 
Overrides: BaseAdapter.GT

GE(self, first, second=None)

source code 
Overrides: BaseAdapter.GE

ADD(self, first, second)

source code 
Overrides: BaseAdapter.ADD

SUB(self, first, second)

source code 
Overrides: BaseAdapter.SUB

MUL(self, first, second)

source code 
Overrides: BaseAdapter.MUL

DIV(self, first, second)

source code 
Overrides: BaseAdapter.DIV

MOD(self, first, second)

source code 
Overrides: BaseAdapter.MOD

AS(self, first, second)

source code 
Overrides: BaseAdapter.AS

ON(self, first, second)

source code 
Overrides: BaseAdapter.ON

COMMA(self, first, second)

source code 
Overrides: BaseAdapter.COMMA

ILIKE(self, first, second)

source code 

case in-sensitive like operator

Overrides: BaseAdapter.ILIKE
(inherited documentation)

LIKE(self, first, second)

source code 

case sensitive like operator

Overrides: BaseAdapter.LIKE
(inherited documentation)

STARTSWITH(self, first, second)

source code 
Overrides: BaseAdapter.STARTSWITH

ENDSWITH(self, first, second)

source code 
Overrides: BaseAdapter.ENDSWITH

CONTAINS(self, first, second, case_sensitive=False)

source code 
Overrides: BaseAdapter.CONTAINS

Class Variable Details [hide private]

types

Value:
{'bigint': <type 'long'>,
 'blob': <type 'str'>,
 'boolean': <type 'bool'>,
 'date': <type 'datetime.date'>,
 'datetime': <type 'datetime.datetime'>,
 'double': <type 'float'>,
 'float': <type 'float'>,
 'id': <type 'long'>,
...

error_messages

Value:
{'javascript_needed': 'This must yet be replaced with javascript in or\
der to work.'}