1
0

* adding support for MySQL

This commit is contained in:
Ovidiu Constantin
2011-11-23 18:19:01 +02:00
parent 265fe2d9b8
commit 4c0f06f39d
2 changed files with 15 additions and 2 deletions

View File

@@ -509,7 +509,12 @@ if __name__ == '__main__':
conf = DataStore.CONFIG_DEFAULTS
args, argv = readconf.parse_argv( [], conf)
args.dbtype= config.get('database','type')
args.connect_args = {'database' : config.get('database','database') }
if args.dbtype == 'sqlite3':
args.connect_args = { 'database' : config.get('database','database') }
elif args.dbtype == 'MySQLdb':
args.connect_args = { 'db' : config.get('database','database'), 'user' : config.get('database','user'), 'passwd' : config.get('database','pass') }
elif args.dbtype == 'psycopg2':
args.connect_args = { 'database' : config.get('database','database') }
store = MyStore(args)
thread.start_new_thread(listen_thread, (store,))