31 |
|
|
32 |
import string |
import string |
33 |
import sys |
import sys |
34 |
from gnue.common.datasources import GDataObjects, GConditions |
from gnue.common.datasources.drivers.DBSIG2.Driver import DBSIG2 |
35 |
from gnue.common.apps import GDebug |
from gnue.common.datasources import GDataObjects.ConnectionError |
|
from gnue.common.datasources.drivers.DBSIG2.Driver \ |
|
|
import DBSIG2.RecordSet, DBSIG2.ResultSet, DBSIG2.DataObject, \ |
|
|
DBSIG2.DataObject_SQL, DBSIG2.DataObject_Object |
|
|
|
|
|
try: |
|
|
import MySQLdb |
|
|
except ImportError, mesg: |
|
|
GDebug.printMesg(1,mesg) |
|
|
print "-"*79 |
|
|
print _("\nCould not load MySQLdb. For MySQL support, please install \n") \ |
|
|
+ _("mysql-python 0.9.0 or later from") \ |
|
|
+ "http://sourceforge.net/projects/mysql-python\n" |
|
|
print _("Error: %s") % mesg |
|
|
print "-"*79 |
|
|
sys.exit() |
|
|
|
|
|
|
|
|
|
|
|
class MySQL_RecordSet(DBSIG2.RecordSet): |
|
|
pass |
|
|
|
|
36 |
|
|
37 |
class MySQL_ResultSet(DBSIG2.ResultSet): |
class MySQL_ResultSet(DBSIG2.ResultSet): |
38 |
def __init__(self, dataObject, cursor=None, defaultValues={}, masterRecordSet=None): |
def __init__(self, dataObject, cursor=None, defaultValues={}, masterRecordSet=None): |
85 |
return 0 |
return 0 |
86 |
else: |
else: |
87 |
return 0 |
return 0 |
|
|
|
|
class MySQL_DataObject(DBSIG2.DataObject): |
|
|
def __init__(self): |
|
|
DBSIG2.DataObject.__init__(self) |
|
|
self._DatabaseError = MySQLdb.DatabaseError |
|
|
self._resultSetClass = MySQL_ResultSet |
|
|
def connect(self, connectData={}): |
|
|
GDebug.printMesg(1,"Mysql database driver initializing") |
|
|
|
|
|
try: |
|
|
self._dataConnection = MySQLdb.connect(user=connectData['_username'], |
|
|
passwd=connectData['_password'], |
|
|
host=connectData['host'], |
|
|
db=connectData['dbname']) |
|
|
except self._DatabaseError, value: |
|
|
raise GDataObjects.LoginError, value |
|
|
|
|
|
self._beginTransaction() |
|
|
self._postConnect() |
|
|
|
|
|
|
|
|
def _postConnect(self): |
|
|
self.triggerExtensions = TriggerExtensions(self._dataConnection) |
|
|
|
|
|
|
|
|
def _beginTransaction(self): |
|
|
try: |
|
|
self._dataConnection.begin() |
|
|
except: |
|
|
pass |
|
|
|
|
|
|
|
|
# |
|
|
# Schema (metadata) functions |
|
|
# |
|
|
|
|
|
# Return a list of the types of Schema objects this driver provides |
|
|
def getSchemaTypes(self): |
|
|
return [('table',_('Tables'),1)] |
|
|
|
|
|
# Return a list of Schema objects |
|
|
def getSchemaList(self, type=None): |
|
|
|
|
|
# TODO: This excludes any system tables and views. Should it? |
|
|
statement = "SHOW TABLES" |
|
|
|
|
|
cursor = self._dataConnection.cursor() |
|
|
cursor.execute(statement) |
|
|
|
|
|
list = [] |
|
|
for rs in cursor.fetchall(): |
|
|
list.append(GDataObjects.Schema(attrs={'id':rs[0], 'name':rs[0], |
|
|
'type':'table', |
|
|
'primarykey': self.__getPrimaryKey(rs[0])}, |
|
|
getChildSchema=self.__getFieldSchema)) |
|
|
|
|
|
cursor.close() |
|
|
return list |
|
|
|
|
|
|
|
|
# Find a schema object with specified name |
|
|
def getSchemaByName(self, name, type=None): |
|
|
statement = "DESCRIBE %s" % (name) |
|
|
|
|
|
cursor = self._dataConnection.cursor() |
|
|
cursor.execute(statement) |
|
|
|
|
|
rs = cursor.fetchone() |
|
|
if rs: |
|
|
schema = GDataObjects.Schema(attrs={'id':name, 'name':name, |
|
|
'type':'table', |
|
|
'primarykey': self.__getPrimaryKey(name,cursor)}, |
|
|
getChildSchema=self.__getFieldSchema) |
|
|
else: |
|
|
schema = None |
|
|
|
|
|
cursor.close() |
|
|
return schema |
|
|
|
|
|
|
|
|
def __getPrimaryKey(self, id, cursor=None): |
|
|
statement = "DESCRIBE %s" % id |
|
|
if not cursor: |
|
|
cursor = self._dataConnection.cursor() |
|
|
close_cursor = 1 |
|
|
else: |
|
|
close_cursor = 0 |
|
|
cursor.execute(statement) |
|
|
|
|
|
lst = [] |
|
|
for rs in cursor.fetchall(): |
|
|
if rs[3] == 'PRI': |
|
|
lst.append(rs[0]) |
|
|
|
|
|
if close_cursor: |
|
|
cursor.close() |
|
|
|
|
|
return tuple(lst) |
|
|
|
|
|
# Get fields for a table |
|
|
def __getFieldSchema(self, parent): |
|
|
|
|
|
statement = "DESCRIBE %s" % parent.id |
|
|
|
|
|
cursor = self._dataConnection.cursor() |
|
|
cursor.execute(statement) |
|
|
|
|
|
list = [] |
|
|
for rs in cursor.fetchall(): |
|
|
|
|
|
nativetype = string.split(string.replace(rs[1],')',''),'(') |
|
|
|
|
|
|
|
|
attrs={'id': "%s.%s" % (parent.id, rs[0]), 'name': rs[0], |
|
|
'type':'field', 'nativetype': nativetype[0], |
|
|
'required': rs[2] != 'YES'} |
|
|
|
|
|
if nativetype[0] in ('int','integer','bigint','mediumint', |
|
|
'smallint','tinyint','float','real', |
|
|
'double','decimal'): |
|
|
attrs['datatype']='number' |
|
|
elif nativetype[0] in ('date','time','timestamp','datetime'): |
|
|
attrs['datatype']='date' |
|
|
else: |
|
|
attrs['datatype']='text' |
|
|
|
|
|
try: |
|
|
if len(nativetype) == 2: |
|
|
try: |
|
|
ln, prec = nativetype[1].split(',') |
|
|
except: |
|
|
ln = nativetype[1] |
|
|
prec = None |
|
|
attrs['length'] = int(ln.split()[0]) |
|
|
if prec != None: |
|
|
attrs['precision'] = int(prec) |
|
|
except ValueError: |
|
|
GDebug.printMesg(1,'WARNING: mysql native type error: %s' % nativetype) |
|
|
|
|
|
if rs[4] not in ('NULL', '0000-00-00 00:00:00','', None): |
|
|
attrs['defaulttype'] = 'constant' |
|
|
attrs['defaultval'] = rs[4] |
|
|
|
|
|
if rs[5] == 'auto_increment': |
|
|
attrs['defaulttype'] = 'serial' |
|
|
|
|
|
|
|
|
list.append(GDataObjects.Schema(attrs=attrs)) |
|
|
|
|
|
cursor.close() |
|
|
return list |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
class MySQL_DataObject_Object(MySQL_DataObject, \ |
|
|
DBSIG2.DataObject_Object): |
|
|
|
|
|
def __init__(self): |
|
|
MySQL_DataObject.__init__(self) |
|
|
|
|
|
def _buildQuery(self, conditions={},forDetail=None,additionalSQL=""): |
|
|
return DBSIG2.DataObject_Object._buildQuery(self, conditions,forDetail,additionalSQL) |
|
|
|
|
|
|
|
|
class MySQL_DataObject_SQL(MySQL_DataObject, \ |
|
|
DBSIG2.DataObject_SQL): |
|
|
def __init__(self): |
|
|
# Call DBSIG init first because MySQL_DataObject needs to overwrite |
|
|
# some of its values |
|
|
DBSIG2.DataObject_SQL.__init__(self) |
|
|
MySQL_DataObject.__init__(self) |
|
|
|
|
|
def _buildQuery(self, conditions={}): |
|
|
return DBSIG2.DataObject_SQL._buildQuery(self, conditions) |
|
|
|
|
|
|
|
|
# |
|
|
# Extensions to Trigger Namespaces |
|
|
# |
|
|
class TriggerExtensions: |
|
|
|
|
|
def __init__(self, connection): |
|
|
self.__connection = connection |
|
|
|
|
|
# Return the current date, according to database |
|
|
# def getDate(self): |
|
|
# pass |
|
|
|
|
|
# Return a sequence number from sequence 'name' |
|
|
# def getSequence(self, name): |
|
|
# pass |
|
|
|
|
|
# Run the SQL statement 'statement' |
|
|
# def sql(self, statement): |
|
|
# pass |
|
|
|
|
|
|
|
|
|
|
|
###################################### |
|
|
# |
|
|
# The following hashes describe |
|
|
# this driver's characteristings. |
|
|
# |
|
|
###################################### |
|
|
|
|
|
# |
|
|
# All datasouce "types" and corresponding DataObject class |
|
|
# |
|
|
supportedDataObjects = { |
|
|
'object': MySQL_DataObject_Object, |
|
|
'sql': MySQL_DataObject_SQL |
|
|
} |
|
|
|
|
|
|
|