|
1 | 1 | import check |
2 | | -import sqltables |
3 | 2 |
|
4 | 3 | import pickle |
5 | 4 | import mysql.connector |
6 | 5 |
|
| 6 | +from mysql.connector import errorcode |
7 | 7 |
|
| 8 | +TABLES = {} |
| 9 | +TABLES['employees'] = ( |
| 10 | + "CREATE TABLE `employees` (" |
| 11 | + " `emp_no` int(5) NOT NULL AUTO_INCREMENT," |
| 12 | + " `birth_date` date NOT NULL," |
| 13 | + " `first_name` varchar(15) NOT NULL," |
| 14 | + " `last_name` varchar(15) NOT NULL," |
| 15 | + " `gender` enum('M','F') NOT NULL," |
| 16 | + " `hire_date` date NOT NULL," |
| 17 | + " `age` int(2) NOT NULL," |
| 18 | + " PRIMARY KEY (`emp_no`)" |
| 19 | + ") ") |
| 20 | + |
| 21 | +TABLES['clients'] = ( |
| 22 | + "CREATE TABLE `clients` (" |
| 23 | + " `acc_no` int(5) NOT NULL AUTO_INCREMENT PRIMARY KEY," |
| 24 | + " `acc_type` enum('S','C') NOT NULL," |
| 25 | + " `first_name` varchar(15) NOT NULL," |
| 26 | + " `last_name` varchar(15) NOT NULL," |
| 27 | + " `gender` enum('M','F') NOT NULL," |
| 28 | + " `birth_date` date NOT NULL," |
| 29 | + " `acc_creation_date` date NOT NULL," |
| 30 | + " `mobile_no` int(10) NOT NULL," |
| 31 | + " `email_id` varchar(25) NOT NULL" |
| 32 | + ") " |
| 33 | +) |
| 34 | + |
| 35 | +TABLES['savings'] = ( |
| 36 | + "CREATE TABLE `savings` (" |
| 37 | + " `acc_no` int(5) NOT NULL," |
| 38 | + " `balance` int NOT NULL," |
| 39 | + " `loan` enum('YES','NO') NOT NULL," |
| 40 | + " PRIMARY KEY (`acc_no`)," |
| 41 | + " FOREIGN KEY(`acc_no`) REFERENCES clients(acc_no)" |
| 42 | + ") " |
| 43 | +) |
| 44 | + |
| 45 | +TABLES['current'] = ( |
| 46 | + "CREATE TABLE `current` (" |
| 47 | + " `acc_no` int(5) NOT NULL," |
| 48 | + " `balance` int NOT NULL," |
| 49 | + " `overdraft` int NOT NULL," |
| 50 | + " PRIMARY KEY (`acc_no`)," |
| 51 | + " FOREIGN KEY(`acc_no`) REFERENCES clients(acc_no)" |
| 52 | + ") " |
| 53 | +) |
| 54 | + |
| 55 | +TABLES['loan'] = ( |
| 56 | + "CREATE TABLE `loan` (" |
| 57 | + " `acc_no` int(5) NOT NULL," |
| 58 | + " `loan_type` enum('PL','HL','EL','TL','BL') NOT NULL," |
| 59 | + " `loan_amt` int NOT NULL," |
| 60 | + " `time_period_months` int NOT NULL," |
| 61 | + " `iterest_perc_per_annum` int(1) NOT NULL," |
| 62 | + " `amt-per-month` int NOT NULL," |
| 63 | + " `remaining_amt` int NOT NULL," |
| 64 | + " PRIMARY KEY (`acc_no`)," |
| 65 | + " FOREIGN KEY(`acc_no`) REFERENCES clients(acc_no)" |
| 66 | + ") " |
| 67 | +) |
| 68 | + |
| 69 | +TABLES['overdraft']=( |
| 70 | + "CREATE TABLE `overdraft` (" |
| 71 | + " `acc_no` int(5) NOT NULL," |
| 72 | + " `overdraft_amt` int NOT NULL," |
| 73 | + " `od_with_interest_remaining` int NOT NULL," |
| 74 | + " PRIMARY KEY (`acc_no`)," |
| 75 | + " FOREIGN KEY(`acc_no`) REFERENCES clients(acc_no)" |
| 76 | + ") " |
| 77 | +) |
| 78 | + |
| 79 | + |
| 80 | +############################################################################################ |
8 | 81 | query="" |
9 | 82 | Password="" |
10 | 83 | Database="" |
@@ -41,10 +114,24 @@ def querycheck(): |
41 | 114 | if conn!="": |
42 | 115 | if conn.is_connected: |
43 | 116 | print("Connection established successfully.") |
44 | | - with open("firsttime.txt","w") as f: |
45 | | - f.write("False") |
46 | | - sqltables.tables() |
47 | | - ans=True |
| 117 | + if check.check()==True: |
| 118 | + cursor=conn.cursor() |
| 119 | + #Table creation |
| 120 | + for table_name in TABLES: |
| 121 | + table_description = TABLES[table_name] |
| 122 | + try: |
| 123 | + print("Creating table {}: ".format(table_name), end='') |
| 124 | + cursor.execute(table_description) |
| 125 | + except mysql.connector.Error as err: |
| 126 | + if err.errno == errorcode.ER_TABLE_EXISTS_ERROR: |
| 127 | + print("already exists.") |
| 128 | + else: |
| 129 | + print(err.msg) |
| 130 | + else: |
| 131 | + print("OK") |
| 132 | + with open("firsttime.txt","w") as f: |
| 133 | + f.write("False") |
| 134 | + ans=True |
48 | 135 |
|
49 | 136 | if not ans: |
50 | 137 | print("There was a problem in connection") |
@@ -83,4 +170,25 @@ def setup(): |
83 | 170 | else: |
84 | 171 | if querycheck(): |
85 | 172 | connectionquery() |
86 | | -setup() |
| 173 | + |
| 174 | +"""def tables(): |
| 175 | + conn=setup() |
| 176 | + cursor=conn.cursor() |
| 177 | + for table_name in TABLES: |
| 178 | + table_description = TABLES[table_name] |
| 179 | + try: |
| 180 | + print("Creating table {}: ".format(table_name), end='') |
| 181 | + cursor.execute(table_description) |
| 182 | + except mysql.connector.Error as err: |
| 183 | + if err.errno == errorcode.ER_TABLE_EXISTS_ERROR: |
| 184 | + print("already exists.") |
| 185 | + else: |
| 186 | + print(err.msg) |
| 187 | + else: |
| 188 | + print("OK")""" |
| 189 | + |
| 190 | + |
| 191 | +################################################################################################## |
| 192 | +#Links |
| 193 | +#https://education.github.com/git-cheat-sheet-education.pdf |
| 194 | +#https://dev.mysql.com/doc/connector-python/en/connector-python-example-ddl.html |
0 commit comments