1
2
3
4
5
6
7
8
9
10 _dbutils = {}
11
15
17 if table != 'biosequence': return table
18 else: return 'bioentry'
19
20
21
22
23
24
25
26
27
28
30
31 table = self.tname(table)
32 sql = r"select max(%s_id) from %s" % (table, table)
33 cursor.execute(sql)
34 rv = cursor.fetchone()
35 return rv[0]
36
37 - def execute(self, cursor, sql, args=None):
38 """Just execute an sql command.
39 """
40 cursor.execute(sql, args or ())
41
45
47 """Custom database utilities for SQLite.
48 """
49 - def execute(self, cursor, sql, args=None):
50 """Replace %s with ? for variable substitution in sqlite3.
51 """
52 sql = sql.replace("%s", "?")
53 cursor.execute(sql, args or ())
54
55 _dbutils["sqlite3"] = Sqlite_dbutils
56
59 try:
60
61 return cursor.insert_id()
62 except AttributeError:
63
64
65
66 return cursor.lastrowid
67
68 _dbutils["MySQLdb"] = Mysql_dbutils
69
72 table = self.tname(table)
73 sql = r"select nextval('%s_pk_seq')" % table
74 cursor.execute(sql)
75 rv = cursor.fetchone()
76 return rv[0]
77
79 table = self.tname(table)
80 sql = r"select currval('%s_pk_seq')" % table
81 cursor.execute(sql)
82 rv = cursor.fetchone()
83 return rv[0]
84
87
88 _dbutils["psycopg"] = Psycopg_dbutils
89
92 if y:
93 conn.set_isolation_level(0)
94 else:
95 conn.set_isolation_level(1)
96
97 _dbutils["psycopg2"] = Psycopg2_dbutils
98
100 """Add support for pgdb in the PyGreSQL database connectivity package.
101 """
103 table = self.tname(table)
104 sql = r"select nextval('%s_pk_seq')" % table
105 cursor.execute(sql)
106 rv = cursor.fetchone()
107 return rv[0]
108
110 table = self.tname(table)
111 sql = r"select currval('%s_pk_seq')" % table
112 cursor.execute(sql)
113 rv = cursor.fetchone()
114 return rv[0]
115
117 raise NotImplementedError("pgdb does not support this!")
118
119 _dbutils["pgdb"] = Pgdb_dbutils
120
126