+
−typemap = repo.system_source.dbhelper.TYPE_MAPPING
+
−sqls = """
+
−CREATE TABLE transactions (
+
−  tx_uuid CHAR(32) PRIMARY KEY NOT NULL,
+
−  tx_user INTEGER NOT NULL,
+
−  tx_time %s NOT NULL
+
−);;
+
−CREATE INDEX transactions_tx_user_idx ON transactions(tx_user);;
+
−
+
−CREATE TABLE tx_entity_actions (
+
−  tx_uuid CHAR(32) REFERENCES transactions(tx_uuid) ON DELETE CASCADE,
+
−  txa_action CHAR(1) NOT NULL,
+
−  txa_public %s NOT NULL,
+
−  txa_order INTEGER,
+
−  eid INTEGER NOT NULL,
+
−  etype VARCHAR(64) NOT NULL,
+
−  changes %s
+
−);;
+
−CREATE INDEX tx_entity_actions_txa_action_idx ON tx_entity_actions(txa_action);;
+
−CREATE INDEX tx_entity_actions_txa_public_idx ON tx_entity_actions(txa_public);;
+
−CREATE INDEX tx_entity_actions_eid_idx ON tx_entity_actions(eid);;
+
−CREATE INDEX tx_entity_actions_etype_idx ON tx_entity_actions(etype);;
+
−
+
−CREATE TABLE tx_relation_actions (
+
−  tx_uuid CHAR(32) REFERENCES transactions(tx_uuid) ON DELETE CASCADE,
+
−  txa_action CHAR(1) NOT NULL,
+
−  txa_public %s NOT NULL,
+
−  txa_order INTEGER,
+
−  eid_from INTEGER NOT NULL,
+
−  eid_to INTEGER NOT NULL,
+
−  rtype VARCHAR(256) NOT NULL
+
−);;
+
−CREATE INDEX tx_relation_actions_txa_action_idx ON tx_relation_actions(txa_action);;
+
−CREATE INDEX tx_relation_actions_txa_public_idx ON tx_relation_actions(txa_public);;
+
−CREATE INDEX tx_relation_actions_eid_from_idx ON tx_relation_actions(eid_from);;
+
−CREATE INDEX tx_relation_actions_eid_to_idx ON tx_relation_actions(eid_to)
+
−""" % (typemap['Datetime'],
+
−       typemap['Boolean'], typemap['Bytes'], typemap['Boolean'])
+
−for statement in sqls.split(';;'):
+
−    sql(statement)