python for gbase8a 驱动

import time from . import GBaseLogger global GBASELOGGER from GBaseConnector.GBaseCursor import GBaseCursor from GBaseConnector.GBaseSocket import GBaseSocket from GBaseConnector.GBaseProtocol import GBaseProtocol from GBaseConnector.GBaseConstants import (ClientFlag, ServerCmd, flag_is_set, ServerFlag, CharacterSet) from GBaseConnector import GBaseError class GBaseConnection(object): ''' ************************************************************ Module : GBaseConnection Function : Create connection to GBase server Corporation : General Data Technology CO,. Ltd. Team : DMD, Interface Team Author : wq Date : 2013-7 Version : v1.0 Description : Create connection to GBase server. And execute SQL and fetch rows. ************************************************************ ''' def __init__(self, **kwargs): ''' ************************************************************ Function : __init__ Arguments : 1) **kwargs (dict) : connection arguments { 'user': gbase, 'port': 5258 } Return : Description : GBaseConnection construct function ************************************************************ ''' self._host = '127.0.0.1' self._user = '' self._password = '' self._database = '' self._port = 5258 self.charset = None self._use_unicode = True self._collation = None self._connection_timeout = 30 self._autocommit = True self._time_zone = None self._sql_mode = None self._get_warnings = False self._raise_on_warnings = False self._client_flags = ClientFlag.get_default() self._charset_id = 33 # utf8 self._socket = None self._protocol = None self._hello_res = None self._server_version = None self._have_next_result = False self._unread_result = False # Initial log system GBaseLogger.InitLog(**kwargs) if len(kwargs) > 0: self.connect(**kwargs) def parsecfg(self, **kwargs): ''' ************************************************************ Function : parsecfg Arguments : 1) **kwargs (dict) : connection arguments { 'user': gbase, 'port': 5258 } Return : Description : Parse config arguments and get values. ************************************************************ ''' GBASELOGGER.debug('Enter: parsecfg') config = kwargs.copy() # dsn if 'dsn' in config: GBASELOGGER.error('Not support dsn key word.') raise GBaseError.NotSupportedError('Not support dsn key word.') # host if 'host' in config: if config['host'] != None and len(config['host']) > 0: # Bug #2857 self._host = config['host'] del config['host'] # user if 'user' in config: self._user = config['user'] del config['user'] # Compatible other key compatible_keys = [ ('db', 'database'), ('passwd', 'password'), ('connect_timeout', 'connection_timeout'), ] for comp_key, full_key in compatible_keys: try: if full_key not in config: config[full_key] = config[comp_key] del config[comp_key] except KeyError: pass # Missing compat argument is OK # password if 'password' in config: self._password = config['password'] del config['password'] # port if 'port' in config: try: self._port = int(config['port']) del config['port'] except KeyError: pass # Missing port argument is OK except ValueError: raise ValueError( "TCP/IP port number should be an integer") if 'connection_timeout' in config: self.connection_timeout = config['connection_timeout'] del config['connection_timeout'] if 'autocommit' in config: self._autocommit = config['autocommit'] del config['autocommit'] if 'sql_mode' in config: self.sql_mode = config['sql_mode'] del config['sql_mode'] if 'get_warnings' in config: self.get_warnings = config['get_warnings'] del config['get_warnings'] # Configure client flags try: default = ClientFlag.get_default() self.set_client_flags(config['client_flags'] or default) del config['client_flags'] except KeyError: pass # Missing client_flags-argument is OK # Configure character set and collation if ('charset' in config or 'collation' in config): try: self.charset = config['charset'] del config['charset'] except KeyError: self.charset = None try: collation = config['collation'] del config['collation'] except KeyError: collation = None self._charset_id = CharacterSet.get_charset_info(self.charset, collation)[0] if 'raise_on_warnings' in config: self.raise_on_warnings = config['raise_on_warnings'] del config['raise_on_warnings'] if 'use_unicode' in config: self.use_unicode = config["use_unicode"] del config['use_unicode'] # Other configuration for k, v in list(config.items()): # TRACE Configuration if k.startswith('trace'): continue try: self.DEFAULT_CONFIG[k] except KeyError: raise AttributeError("The argument is not support. '%s'" % k) attribute = '_' + k try: setattr(self, attribute, v.strip()) except AttributeError: setattr(self, attribute, v) GBASELOGGER.debug('Exit: parsecfg') @property def port(self): ''' ************************************************************ Function : port Arguments : Return : int Description : Return current port. ************************************************************ ''' return self._port @property def user(self): ''' ************************************************************ Function : user Arguments : Return : string Description : Return current user. ************************************************************ ''' return self._user @property def host(self): ''' ************************************************************ Function : host Arguments : Return : string Description : Return current