diff --git a/jobs/basic_job.py b/jobs/basic_job.py index 86bb3015..09e7c77e 100644 --- a/jobs/basic_job.py +++ b/jobs/basic_job.py @@ -103,7 +103,7 @@ def stat_all(tmp_datetime): # 创建新数据库。 def create_new_database(): - with MySQLdb.connect(common.MYSQL_HOST, common.MYSQL_USER, common.MYSQL_PWD, "mysql", charset="utf8") as db: + with MySQLdb.connect(common.MYSQL_HOST, common.MYSQL_USER, common.MYSQL_PWD, common.MYSQL_DB, charset="utf8") as db: try: create_sql = " CREATE DATABASE IF NOT EXISTS %s CHARACTER SET utf8 COLLATE utf8_general_ci " % common.MYSQL_DB print(create_sql)