cubicweb: comparison server/sources/native.py

equal deleted inserted replaced

-:00b1b6b906cf
+:97c55baefa0c
 from logilab.common.decorators import cached, clear_cache
 from logilab.common.configuration import Method
 from logilab.common.shellutils import getlogin
 from logilab.database import get_db_helper
+from yams import schema2sql as y2sql
 from cubicweb import UnknownEid, AuthenticationError, ValidationError, Binary
 from cubicweb import transaction as tx, server, neg_role
 from cubicweb.schema import VIRTUAL_RTYPES
 from cubicweb.cwconfig import CubicWebNoAppConfiguration
 from cubicweb.server import hook
 ' OR '.join(clauses))
 else:
 restr = '(%s)' % ' OR '.join(clauses)
 return '%s WHERE %s' % (select, restr)
+def rdef_table_column(rdef):
+"""return table and column used to store the given relation definition in
+the database
+"""
+return (SQL_PREFIX + str(rdef.subject),
+SQL_PREFIX + str(rdef.rtype))
+def rdef_physical_info(dbhelper, rdef):
+"""return backend type and a boolean flag if NULL values should be allowed
+for a given relation definition
+"""
+coltype = y2sql.type_from_constraints(dbhelper, rdef.object,
+rdef.constraints, creating=False)
+allownull = rdef.cardinality[0] != '1'
+return coltype, allownull
 class UndoException(Exception):
 """something went wrong during undoing"""
 pass
 raise
 # short cut to method requiring advanced db helper usage ##################
+def update_rdef_column(self, session, rdef):
+"""update physical column for a relation definition (final or inlined)
+"""
+table, column = rdef_table_column(rdef)
+coltype, allownull = rdef_physical_info(self.dbhelper, rdef)
+if not self.dbhelper.alter_column_support:
+self.error("backend can't alter %s.%s to %s%s", table, column, coltype,
+not allownull and 'NOT NULL' or '')
+return
+self.dbhelper.change_col_type(LogCursor(session.pool[self.uri]),
+table, column, coltype, allownull)
+self.info('altered %s.%s: now %s%s', table, column, coltype,
+not allownull and 'NOT NULL' or '')
+def update_rdef_null_allowed(self, session, rdef):
+"""update NULL / NOT NULL of physical column for a relation definition
+(final or inlined)
+"""
+if not self.dbhelper.alter_column_support:
+# not supported (and NOT NULL not set by yams in that case, so no
+# worry)
+return
+table, column = rdef_table_column(rdef)
+coltype, allownull = rdef_physical_info(self.dbhelper, rdef)
+self.dbhelper.set_null_allowed(LogCursor(session.pool[self.uri]),
+table, column, coltype, allownull)
+def update_rdef_indexed(self, session, rdef):
+table, column = rdef_table_column(rdef)
+if rdef.indexed:
+self.create_index(session, table, column)
+else:
+self.drop_index(session, table, column)
+def update_rdef_unique(self, session, rdef):
+table, column = rdef_table_column(rdef)
+if rdef.constraint_by_type('UniqueConstraint'):
+self.create_index(session, table, column, unique=True)
+else:
+self.drop_index(session, table, column, unique=True)
 def create_index(self, session, table, column, unique=False):
 cursor = LogCursor(session.pool[self.uri])
 self.dbhelper.create_index(cursor, table, column, unique)
 def drop_index(self, session, table, column, unique=False):
 cursor = LogCursor(session.pool[self.uri])
 self.dbhelper.drop_index(cursor, table, column, unique)
-def change_col_type(self, session, table, column, coltype, null_allowed):
-cursor = LogCursor(session.pool[self.uri])
-self.dbhelper.change_col_type(cursor, table, column, coltype, null_allowed)
-def set_null_allowed(self, session, table, column, coltype, null_allowed):
-cursor = LogCursor(session.pool[self.uri])
-self.dbhelper.set_null_allowed(cursor, table, column, coltype, null_allowed)
 # system source interface #################################################
 def eid_type_source(self, session, eid):
 """return a tuple (type, source, extid) for the entity with id <eid>"""
 entity[rtype] = Binary(value)
 elif isinstance(value, str):
 entity[rtype] = unicode(value, session.encoding, 'replace')
 else:
 entity[rtype] = value
-entity.set_eid(eid)
+entity.eid = eid
 session.repo.init_entity_caches(session, entity, self)
 entity.edited_attributes = set(entity)
-entity.check()
+entity._cw_check()
 self.repo.hm.call_hooks('before_add_entity', session, entity=entity)
 # restore the entity
 action.changes['cw_eid'] = eid
 sql = self.sqlgen.insert(SQL_PREFIX + etype, action.changes)
 self.doexec(session, sql, action.changes)
 entity = self.repo.vreg['etypes'].etype_class(etype)(session)
 except Exception:
 return [session._(
 "Can't undo creation of entity %(eid)s of type %(etype)s, type "
 "no more supported" % {'eid': eid, 'etype': etype})]
-entity.set_eid(eid)
+entity.eid = eid
 # for proper eid/type cache update
 hook.set_operation(session, 'pendingeids', eid,
 CleanupDeletedEidsCacheOp)
 self.repo.hm.call_hooks('before_delete_entity', session, entity=entity)
 # remove is / is_instance_of which are added using sql by hooks, hence
 """
 self.debug('reindexing %r', entity.eid)
 try:
 # use cursor_index_object, not cursor_reindex_object since
 # unindexing done in the FTIndexEntityOp
-self.dbhelper.cursor_index_object(entity.eid, entity,
+self.dbhelper.cursor_index_object(entity.eid,
+entity.cw_adapt_to('IFTIndexable'),
 session.pool['system'])
 except Exception: # let KeyboardInterrupt / SystemExit propagate
 self.exception('error while reindexing %s', entity)
 if eid in pendingeids or eid in done:
 # entity added and deleted in the same transaction or already
 # processed
 return
 done.add(eid)
-for container in session.entity_from_eid(eid).fti_containers():
+iftindexable = session.entity_from_eid(eid).cw_adapt_to('IFTIndexable')
+for container in iftindexable.fti_containers():
 source.fti_unindex_entity(session, container.eid)
 source.fti_index_entity(session, container)
 def sql_schema(driver):

branch	stable
changeset 5994	97c55baefa0c
parent 5982	30985571dbc9
child 6019	373a313ee9ec