Modified DAL and DB2 adapter to allow use of the official ibm_db_dbi driver or ODBC.
This commit is contained in:
@@ -144,6 +144,12 @@ if not 'google' in DRIVERS:
|
|||||||
pyodbc = None
|
pyodbc = None
|
||||||
LOGGER.debug('no MSSQL/DB2/Teradata/Ingres driver pyodbc')
|
LOGGER.debug('no MSSQL/DB2/Teradata/Ingres driver pyodbc')
|
||||||
|
|
||||||
|
try:
|
||||||
|
import ibm_db_dbi
|
||||||
|
DRIVERS.append('ibm_db_dbi')
|
||||||
|
except ImportError:
|
||||||
|
LOGGER.debug('no DB2 driver ibm_db_dbi')
|
||||||
|
|
||||||
try:
|
try:
|
||||||
import Sybase
|
import Sybase
|
||||||
DRIVERS.append('Sybase')
|
DRIVERS.append('Sybase')
|
||||||
|
|||||||
@@ -36,7 +36,8 @@ ADAPTERS = {
|
|||||||
'mssql4' : MSSQL4Adapter,
|
'mssql4' : MSSQL4Adapter,
|
||||||
'vertica': VerticaAdapter,
|
'vertica': VerticaAdapter,
|
||||||
'sybase': SybaseAdapter,
|
'sybase': SybaseAdapter,
|
||||||
'db2': DB2Adapter,
|
'db2:ibm_db_dbi': DB2Adapter,
|
||||||
|
'db2:pyodbc': DB2Adapter,
|
||||||
'teradata': TeradataAdapter,
|
'teradata': TeradataAdapter,
|
||||||
'informix': InformixAdapter,
|
'informix': InformixAdapter,
|
||||||
'informix-se': InformixSEAdapter,
|
'informix-se': InformixSEAdapter,
|
||||||
|
|||||||
@@ -7,7 +7,7 @@ from .base import BaseAdapter
|
|||||||
|
|
||||||
|
|
||||||
class DB2Adapter(BaseAdapter):
|
class DB2Adapter(BaseAdapter):
|
||||||
drivers = ('pyodbc',)
|
drivers = ('ibm_db_dbi', 'pyodbc')
|
||||||
|
|
||||||
types = {
|
types = {
|
||||||
'boolean': 'CHAR(1)',
|
'boolean': 'CHAR(1)',
|
||||||
@@ -73,8 +73,18 @@ class DB2Adapter(BaseAdapter):
|
|||||||
self._after_connection = after_connection
|
self._after_connection = after_connection
|
||||||
self.find_or_make_work_folder()
|
self.find_or_make_work_folder()
|
||||||
ruri = uri.split('://', 1)[1]
|
ruri = uri.split('://', 1)[1]
|
||||||
|
|
||||||
def connector(cnxn=ruri,driver_args=driver_args):
|
def connector(cnxn=ruri,driver_args=driver_args):
|
||||||
return self.driver.connect(cnxn,**driver_args)
|
if self.driver_name == 'ibm_db_dbi':
|
||||||
|
vars = cnxn.split(";")
|
||||||
|
cnxn = {}
|
||||||
|
for var in vars:
|
||||||
|
v = var.split('=')
|
||||||
|
cnxn[v[0]] = v[1]
|
||||||
|
return self.driver.connect(cnxn['DSN'], cnxn['UID'], cnxn['PWD'], **driver_args)
|
||||||
|
else:
|
||||||
|
return self.driver.connect(cnxn, **driver_args)
|
||||||
|
|
||||||
self.connector = connector
|
self.connector = connector
|
||||||
if do_connect: self.reconnect()
|
if do_connect: self.reconnect()
|
||||||
|
|
||||||
|
|||||||
+2
-1
@@ -114,7 +114,8 @@ Supported DAL URI strings::
|
|||||||
'mssql4://web2py:none@A64X2/web2py_test' # best pagination (requires >= 2012)
|
'mssql4://web2py:none@A64X2/web2py_test' # best pagination (requires >= 2012)
|
||||||
'oracle://username:password@database'
|
'oracle://username:password@database'
|
||||||
'firebird://user:password@server:3050/database'
|
'firebird://user:password@server:3050/database'
|
||||||
'db2://DSN=dsn;UID=user;PWD=pass'
|
'db2:ibm_db_dbi://DSN=dsn;UID=user;PWD=pass'
|
||||||
|
'db2:pyodbc://driver=DB2;hostname=host;database=database;uid=user;pwd=password;port=port'
|
||||||
'firebird://username:password@hostname/database'
|
'firebird://username:password@hostname/database'
|
||||||
'firebird_embedded://username:password@c://path'
|
'firebird_embedded://username:password@c://path'
|
||||||
'informix://user:password@server:3050/database'
|
'informix://user:password@server:3050/database'
|
||||||
|
|||||||
Reference in New Issue
Block a user