1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
import psycopg2 as dbapi2
ISOLATION_LEVELS = None, 0, 1, 2
placeholder = '%s'
# AUTOCOMMIT = None, 0
# READ_COMMITTED = READ_UNCOMMITTED = 1
# REPEATABLE_READ = SERIALIZABLE = 2
CODEMAP = {
1082: 'DATE',
23: 'INTEGER',
701: 'FLOAT',
1043: 'VARCHAR'
}
def connect(params, isolation_level=None, **kw):
user, pwd, host, port, db = params
port = port or 5432
conn = dbapi2.connect(
database=db, host=host, port=port, user=user, password=pwd, **kw)
if isolation_level is None:
conn.set_isolation_level(0)
return conn
|
