diff --git a/bin/SQLDataCreating.py b/bin/SQLDataCreating.py index 843bebe..9272048 100644 --- a/bin/SQLDataCreating.py +++ b/bin/SQLDataCreating.py @@ -13,31 +13,49 @@ from datetime import datetime # 定义公共的部分 path = Path(__file__) -configfile = path.parent.parent / "etc/test_config.yml" -db_config = yaml.load(codecs.open(configfile ,'r',encoding='utf-8'),Loader=yaml.FullLoader) -driver_name = db_config["driver_name"] -driver_jar_path = db_config["driver_jar_path"] -db_user = db_config["db_user"] -db_password = db_config["db_password"] -jdbc_url = db_config["jdbc_url"] +etc_dir = path.parent.parent / "etc" +configfile = etc_dir / "test_config.yml" +db_config = yaml.load(codecs.open( + configfile, 'r', encoding='utf-8'), Loader=yaml.FullLoader) +driver_jar_path = etc_dir / "driver" / db_config["driver_jar"] -OAuth = [str(db_user),str(db_password)] -if not db_user and not db_password: +OAuth = [str(db_config["db_user"]), str(db_config["db_password"])] +if not db_config["db_user"] and not db_config["db_password"]: OAuth = None -#conn to db by jaydebeapi -conn = jaydebeapi.connect(driver_name, - jdbc_url, - OAuth, - driver_jar_path) +# conn to db by jaydebeapi +conn = jaydebeapi.connect(db_config["driver_name"], + db_config["jdbc_url"], + OAuth, + str(driver_jar_path)) +# conn.close() +def execute_sql(sql): + with conn.cursor() as curs: + curs.execute(sql) +# selecet_sql = "select * from t22 t WHERE name like '李%'" +# execute_sql(selecet_sql) - - -@repeat(every(2).seconds) +#@repeat(every(1).hours) def create_table(): print("create_table ....") + sql_string = "CREATE TABLE `" + sql_string += "test" + sql_string += "` (" + sql_string += "`uuid` varchar(50) DEFAULT NULL," + sql_string += "`id` bigint DEFAULT NULL," + sql_string += "`name` varchar(50) DEFAULT NULL," + sql_string += "`mobile` varchar(50) DEFAULT NULL," + sql_string += "`ssn` varchar(50) DEFAULT NULL," + sql_string += "`sex` int DEFAULT NULL," + sql_string += "`email` varchar(50) DEFAULT NULL," + sql_string += "`job` varchar(50) DEFAULT NULL," + sql_string += "`address` varchar(50) DEFAULT NULL," + sql_string += "`actime_time` timestamp NULL DEFAULT NULL" + sql_string += ") ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;" + + execute_sql(sql_string) @repeat(every(20).seconds) @@ -55,7 +73,6 @@ def updata_data(): print("updata_data ....") - if __name__ == '__main__': while True: run_pending() diff --git a/etc/test_config.yml b/etc/test_config.yml index be06d4f..b7065c1 100644 --- a/etc/test_config.yml +++ b/etc/test_config.yml @@ -1,7 +1,7 @@ #数据库配置文件 -driver_name: "com.mysql.cj.jdbc.Driver" +driver_name: "com.mysql.jdbc.Driver" driver_jar: "mysql-connector-java-8.0.29.jar" -jdbc_url: "jdbc:mysql://10.10.29.9:3306/" +jdbc_url: "jdbc:mysql://10.10.29.9:3306/test2" db_user: "root" db_password: "Unary@2023" diff --git a/requirements.txt b/requirements.txt index 6e3f8bd..e8e4ff3 100644 --- a/requirements.txt +++ b/requirements.txt @@ -1,4 +1,5 @@ faker==19.12.0 schedule==1.2.1 PyYAML==6.0.1 +JayDeBeApi==1.2.3