| 116 | self.sql_class = SQL_class() |
| 117 | |
| 118 | def initJDBC(self): |
| 119 | if os.path.exists(self.config_file): |
| 120 | with open(self.config_file, 'r') as config_file: |
| 121 | config = json.load(config_file) |
| 122 | jdbc_s = config['jdbc'] |
| 123 | for jdbc in jdbc_s: |
| 124 | host = jdbc['host'] |
| 125 | db = jdbc['db'] |
| 126 | name = jdbc['name'] |
| 127 | password = jdbc['password'] |
| 128 | self.jdbcList.append(host + '/' + db) |
| 129 | self.userNames.append(name) |
| 130 | self.passwords.append(password) |
| 131 | self.userNameMap[host + '/' + db] = name |
| 132 | self.passwordMap[host + '/' + db] = password |
| 133 | self.connMap[host + '/' + db] = create_engine('mysql+pymysql://' + name + ':' + password + '@' + host + '/' + db) |
| 134 | |
| 135 | def get_table_columns(self): |
| 136 | for jdbc in self.jdbcList: |