| 7 | |
| 8 | class SqlManager(object): |
| 9 | def __init__(self): |
| 10 | db_type = config.DB_config.get('db_type', 'mysql') |
| 11 | db_config = config.DB_config.get(db_type) |
| 12 | |
| 13 | if db_type == 'mysql': |
| 14 | from sql.mysql import MySql |
| 15 | self.sql = MySql(**db_config) |
| 16 | elif db_type == 'redis': |
| 17 | pass |
| 18 | elif db_type == 'sqlite': |
| 19 | pass |
| 20 | elif db_type == 'mongodb': |
| 21 | from sql.mongodb import Mongodb |
| 22 | self.sql = Mongodb(**db_config) |
| 23 | else: # default mysql |
| 24 | from sql.mysql import MySql |
| 25 | self.sql = MySql(**config.DB_config.get('db_type')) |
| 26 | |
| 27 | def init_database(self, database_name): |
| 28 | pass |