Overhauled SQLite.py, SQLite_import.py, & SQLite_schema_from_file.py.

Author: david lambert

DBClient.py

@@ -135,7 +135,7 @@ def run_sql(self) -> (list, list, int):
 
                 # Handle SQL results.
                 if sql_type in {'INSERT', 'UPDATE', 'DELETE'}:
-                    self.cursor.commit()
+                    self.cursor.connection.commit()
                 elif sql_type != 'SELECT':
                     print('Not a CRUD statement!')
                 elif sql_type == 'SELECT':

DBInstance.py

@@ -90,7 +90,7 @@ def __init__(self,
 
         # Get the library's primary parameter style.
         print('Parameter style "{}".'.format(self.db_lib_obj.paramstyle))
-        # paramstyle = 'named': cx_Oracle.  Option for sqlite3 & psycopg2.
+        # paramstyle = 'named': oracledb.  Option for sqlite3 & psycopg2.
         # paramstyle = 'qmark': sqlite3 and pyodbc.
         # paramstyle = 'pyformat': pymysql and psycopg2.
 
@@ -116,7 +116,9 @@ def __init__(self,
             else:
                 args = (self.hostname, self.username, self.password,
                         self.instance, self.port_num)
-                self.connection = self.db_lib_obj.connect(*args)
+                # self.connection = self.db_lib_obj.connect(*args)
+                self.connection = self.db_lib_obj.connect(host=self.hostname, user=self.username, password=self.password, db=self.instance,
+                                                          port=self.port_num)
             print('Successfully connected to database.')
         except self.db_lib_obj.Error:
             print_stacktrace()
@@ -300,7 +302,7 @@ def get_db_connection_string(self) -> str:
             db_software_version (str): database software version.
         """
         z = ''
-        if self.db_lib_name == c.CX_ORACLE:
+        if self.db_lib_name == c.ORACLEDB:
             z = '{}/{}@{}:{}/{}'
         elif self.db_lib_name == c.PSYCOPG2:
             z = "user='{}' password='{}' host='{}' port='{}' dbname='{}'"
@@ -323,6 +325,7 @@ def get_db_connection_string(self) -> str:
         if self.db_type in {ORACLE, POSTGRESQL, SQLSERVER}:
             z = z.format(self.username, self.password, self.hostname,
                          self.port_num, self.instance)
+            print(z)
         elif self.db_type in c.FILE_DATABASES:
             z = z.format(self.db_path)
         elif self.db_type == MYSQL:

UniversalClient.py

@@ -12,6 +12,11 @@
 DATE: Jul 9, 2020
 
 For more information, see README.rst.
+ACCESS OK
+SQLITE3 OK
+MYSQL NOT OK
+POSTGRES OK
+ORACLE OK
 """
 # -------- IMPORTS
 
@@ -30,11 +35,17 @@
     ACCESS: '',
     MYSQL: 'root',
     ORACLE: 'ds2',
-    POSTGRESQL: 'root',
+    POSTGRESQL: 'ds2',
     SQLITE: '',
     SQLSERVER: 'sa'}
 
-sample_password = 'password'
+sample_password = {
+    ACCESS: '',
+    MYSQL: 'ds2',
+    ORACLE: 'ds2',
+    POSTGRESQL: 'ds2',
+    SQLITE: '',
+    SQLSERVER: 'Pa$$w0rd'}
 
 # VirtualBox Guests use NAT.
 sample_hostname = '127.0.0.1'
@@ -50,10 +61,10 @@
 sample_instance = {
     ACCESS: '',
     MYSQL: 'DS2',
-    ORACLE: 'ORCL',
+    ORACLE: 'XE',
     POSTGRESQL: 'ds2',
     SQLITE: '',
-    SQLSERVER: 'DS2'}
+    SQLSERVER: 'DS3'}
 
 home = 'C:\\Coding\\PyCharm\\projects\\Python-Universal-DB-Client\\'
 sample_db_path = {
@@ -80,14 +91,29 @@ def main() -> None:
     os, py_version_major, py_version_minor = os_python_version_info()
 
     # GET DATABASE CONNECTION INFO TO USE.
-    db_type1 = SQLITE
-
+    prompt = "Enter the number for the database type you want:"
+    for choice_num, choice in enumerate(c.DB_TYPES):
+        prompt += f"\n{choice_num}: {choice}"
+    prompt += ": "
+    while True:
+        db_type1 = input(prompt)
+        if db_type1.isdigit():
+            db_type1 = int(db_type1)
+            if 0 <= db_type1 <= len(c.DB_TYPES)-1:
+                db_type1 = c.DB_TYPES[db_type1]
+                break
+            else:
+                print(f"Invalid integer choice: {db_type1}")
+        else:
+            print("Only integers allowed.")
     if db_type1 not in c.DB_TYPES:
         print('UNKNOWN DATABASE TYPE.')
         exit(1)
+    print(f"You chose '{db_type1}'.")
+
     db_path1 = sample_db_path[db_type1]
     username1 = sample_username[db_type1]
-    password1 = sample_password
+    password1 = sample_password[db_type1]
     hostname1 = sample_hostname
     port_num1 = sample_port_num[db_type1]
     instance1 = sample_instance[db_type1]
@@ -224,7 +250,7 @@ def main() -> None:
         # MS Access does not support bind variables/parameterization.
         query2 = query.format("'CHEVY FOSTER'", "35.0", terminator='')
     elif paramstyle2 == c.NAMED:
-        # oracle/cx_Oracle and sqlite/sqlite3.
+        # oracle/oracledb and sqlite/sqlite3.
         query2 = query.format(':actor', ':price', terminator='')
         bind_vars2 = {'actor': 'CHEVY FOSTER', 'price': 35.0}
     elif paramstyle2 == c.PYFORMAT:

constants.py

@@ -34,15 +34,15 @@
 
 # DATABASE LIBRARIES.
 
-CX_ORACLE = 'cx_Oracle'
+ORACLEDB = 'oracledb'
 PSYCOPG2 = 'psycopg2'
 PYMYSQL = 'pymysql'
 PYODBC = 'pyodbc'
 SQLITE3 = 'sqlite3'
 LIB_NAME_FOR_DB = {
     ACCESS: PYODBC,
     MYSQL: PYMYSQL,
-    ORACLE: CX_ORACLE,
+    ORACLE: ORACLEDB,
     POSTGRESQL: PSYCOPG2,
     SQLITE: SQLITE3,
     SQLSERVER: PYODBC}
@@ -63,7 +63,7 @@
 QMARK = 'qmark'
 NOBINDVARS = 'nobindvars'
 PARAMSTYLE_FOR_LIB = {
-    CX_ORACLE: NAMED,
+    ORACLEDB: NAMED,
     PSYCOPG2: PYFORMAT,
     PYMYSQL: PYFORMAT,
     PYODBC: QMARK,

databases/ds2.sqlite3

@@ -0,0 +1,38 @@
+import pymysql
+
+# query2 = query.format("%(actor)s", "%(price)s", terminator='')
+# bind_vars2 = {'actor': 'CHEVY FOSTER', 'price': 35.0}
+
+# MySQL database login and location information.
+username = "root"
+password = "password"
+hostname = "127.0.0.1"
+port_num = 3306
+instance = "jingw"
+
+# Print properties of the mysql.connector library.
+print(f"\nmysql.connector library version: {pymysql.__version__}")
+print(f"mysql.connector parameter style ('named', 'qmark', or 'pyformat'): {mysql.connector.paramstyle}")
+
+# Make connection to database.
+connection = pymysql.connect(user=username, password=password, host=hostname, port=port_num, database=instance)
+
+# Create cursor.
+cursor = connection.cursor()
+
+sql = "delete from item where iid = 2"
+cursor.execute(sql)
+
+rows = cursor.fetchall()
+print("Rows in result set:")
+for row in rows:
+    print(row)
+
+# Commit any remaining inserts.
+connection.commit()
+
+# Finish up.
+cursor.close()
+connection.close()
+
+print("All Done.")