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
40
43 try :
44
45 return cursor.insert_id()
46 except AttributeError:
47
48
49
50 return cursor.lastrowid
51
52 _dbutils["MySQLdb"] = Mysql_dbutils
53
56 table = self.tname(table)
57 sql = r"select nextval('%s_pk_seq')" % table
58 cursor.execute(sql)
59 rv = cursor.fetchone()
60 return rv[0]
61
63 table = self.tname(table)
64 sql = r"select currval('%s_pk_seq')" % table
65 cursor.execute(sql)
66 rv = cursor.fetchone()
67 return rv[0]
68
71
72 _dbutils["psycopg"] = Psycopg_dbutils
73
76 if y:
77 conn.set_isolation_level(0)
78 else:
79 conn.set_isolation_level(1)
80
81 _dbutils["psycopg2"] = Psycopg2_dbutils
82
84 """Add support for pgdb in the PyGreSQL database connectivity package.
85 """
87 table = self.tname(table)
88 sql = r"select nextval('%s_pk_seq')" % table
89 cursor.execute(sql)
90 rv = cursor.fetchone()
91 return rv[0]
92
94 table = self.tname(table)
95 sql = r"select currval('%s_pk_seq')" % table
96 cursor.execute(sql)
97 rv = cursor.fetchone()
98 return rv[0]
99
101 raise NotImplementedError("pgdb does not support this!")
102
103 _dbutils["pgdb"] = Pgdb_dbutils
104
110