Changeset Navigation

Changeset 198

Timestamp:

10/25/07 04:59:52

Author:

fumanchu

Message:

New ConnectionManager?.initial_sql attribute, for running e.g. "SET search_path" on each conn.

Files:

r197	r198
232	232	"REPEATABLE READ", "SERIALIZABLE"]
233	233
	234	# Any SQL to execute per connection (inside _get_conn)
	235	# before returning the connection to the caller.
	236	initial_sql = None
	237
234	238	def __init__(self, db):
235	239	self.transactions = {}

r197	r198
334	334	conn.CommandTimeout = self.CommandTimeout
335	335	conn.Open(connectstr)
	336	if self.initial_sql:
	337	conn._oleobj_.InvokeTypes(
	338	*(Connection_Execute +
	339	(self.initial_sql, pythoncom.Missing, -1)))
336	340	return conn
337	341

r197	r198
411	411	try:
412	412	conn = _mysql.connect(**args)
	413	if self.initial_sql:
	414	conn.query(self.initial_sql)
413	415	except _mysql.OperationalError, x:
414	416	if x.args[0] == 1040: # Too many connections

r197	r198
38	38	# Allow statements like CREATE DATABASE to run outside a transaction.
39	39	c.set_isolation_level(0)
	40	if self.initial_sql:
	41	cursor.execute(self.initial_sql)
40	42	return c
41	43	except _psycopg.DatabaseError, x:

r195	r198
26	26
27	27	try:
28		return libpq.PQconnectdb(connstr)
	28	conn = libpq.PQconnectdb(connstr)
	29	if self.initial_sql:
	30	conn.query(self.initial_sql)
	31	return conn
29	32	except libpq.DatabaseError, x:
30	33	msg = x.args[0]

r197	r198
607	607	## conn.isolation_level = None
608	608	conn.text_factory = str
609		return conn.cursor()
	609	c = conn.cursor()
	610	if self.initial_sql:
	611	c.execute(self.initial_sql)
	612	return c
610	613	else:
611	614	def _get_conn(self):
612		return _sqlite.connect(self.db.name, self.db.mode)
	615	conn = _sqlite.connect(self.db.name, self.db.mode)
	616	if self.initial_sql:
	617	conn.execute(self.initial_sql)
	618	return conn
613	619
614	620	def isolate(self, conn, isolation=None):