Skip to content

Commit afddd4b

Browse files
Update connection_manager.py
support kingbase database
1 parent ea0b3d4 commit afddd4b

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

src/DatabaseLibrary/connection_manager.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -139,6 +139,12 @@ def connect_to_database(self, dbapiModuleName=None, dbName=None, dbUsername=None
139139
host=dbHost,
140140
port=dbPort
141141
)
142+
elif dbapiModuleName in ["ksycopg2"]:
143+
dbPort = dbPort or 54321
144+
logger.info('Connecting using : %s.connect(database=%s, user=%s, password=%s, host=%s, port=%s) ' % (
145+
dbapiModuleName, dbName, dbUsername, dbPassword, dbHost, dbPort))
146+
self._dbconnection = db_api_2.connect(database=dbName, user=dbUsername, password=dbPassword, host=dbHost,
147+
port=dbPort)
142148
else:
143149
logger.info('Connecting using : %s.connect(database=%s, user=%s, password=%s, host=%s, port=%s) ' % (dbapiModuleName, dbName, dbUsername, dbPassword, dbHost, dbPort))
144150
self._dbconnection = db_api_2.connect(database=dbName, user=dbUsername, password=dbPassword, host=dbHost, port=dbPort)

0 commit comments

Comments
 (0)