Python |
您所在的位置：网站首页 › 创建xml文件并写入数据库中的数据 › Python |
Python
|
【需求】1. 在数据库中创建表，且能按时间自动创建新表 2. 数据写入数据库 3. 从数据库读取数据
1. 创建表，并自动更新
1 def Creat_Table(InitMySQL,tabel_name):
2 # 创建游标
3 cursor = InitMySQL.cursor()
4 sql = "create table if not exists " + tabel_name + "(dTime datetime not null comment '时间'," \
5 "dElectric_uA int not null comment '电流'," \
6 "dDistance int not null comment '距离'," \
7 "dWarning int not null comment '报警')"
8 # 打印sql
9 print(sql)
10 cursor.execute(sql)
11 # 关闭游标
12 cursor.close()
需要输入数据库的连接对象和表名称，sql根据表名称判断数据库中是否存在该表，如果存在则不会创建，不存在则创建新表 tabel_name 可以根据时间创建 2. 向数据库中写入数据根据创建的数据库中表的类型进行数据填充 1 def Write_to_MySQL(InitMySQL,tabel_name, CurrentTime, Electric_uA, Distance, WaringStatus): 2 # 创建游标 3 cursor = InitMySQL.cursor() 4 # #创建sql 5 # w_table_name = 'warning' + day_time 6 sql = 'insert into '+ tabel_name+ ' values (%s, %s, %s, %s)' 7 print(sql) 8 result = cursor.execute(sql,(CurrentTime, Electric_uA, Distance, WaringStatus)) 9 if result == 1: 10 pass 11 # print('添加成功!') 12 else: 13 print('添加数据失败！') 14 # 4. 操作成功提交事务 15 InitMySQL.commit() 16 # 关闭游标 17 cursor.close() 整体表的创建与数据输入 
1 import time
2 import datetime
3 import json
4 import pymysql
5
6 # JSON 文件初始化
7 def InitJSON():
8 global filejson
9 try:
10 with open('TIE_LDY_20190923_1502.json', 'r') as f:
11 filejson = json.load(f)
12 except FileNotFoundError:
13 print('无法打开指定的文件!')
14 except LookupError:
15 print('指定了未知的编码!')
16 except UnicodeDecodeError:
17 print('读取文件时解码错误!')
18
19 # 数据库参数初始化
20 def MysqlInit():
21 # global LiuCaoSQL
22 # 1. 创建数据库连接对象
23 InitMySQL = pymysql.connect(host=filejson['MysqlInit']['host'], port=filejson['MysqlInit']['port'],
24 database=filejson['MysqlInit']['database'], ['MysqlInit']['charset'],
25 user=filejson['MysqlInit']['user'], password=filejson['MysqlInit']['password'])
26 return InitMySQL
27
28 def Creat_Table(InitMySQL,tabel_name):
29 # 创建游标
30 cursor = InitMySQL.cursor()
31 # # 获取当前时间 年-月-日
32 # day_time = datetime.datetime.now().strftime("%Y_%m_%d_%H_%M")
33 # # 拼接table名称
34 # tabel_name = 'warning' + day_time
35 # 创建sql语句 创建列表的表头 注意表的类型create table if not exists tablename
36 sql = "create table if not exists " + tabel_name + "(dTime datetime not null comment '时间'," \
37 "dElectric_uA int not null comment '电流'," \
38 "dDistance int not null comment '距离'," \
39 "dWarning int not null comment '报警')"
40 # 打印sql
41 print(sql)
42 cursor.execute(sql)
43 # 关闭游标
44 cursor.close()
45
46
47 # 向数据库写入内容
48 def Write_to_MySQL(InitMySQL,tabel_name, CurrentTime, Electric_uA, Distance, WaringStatus):
49 # 创建游标
50 cursor = InitMySQL.cursor()
51 # 获取当前时间 年-月-日
52 # day_time = datetime.datetime.now().strftime("%Y_%m_%d_%H_%M")
53 # #创建sql
54 # w_table_name = 'warning' + day_time
55 sql = 'insert into '+ tabel_name+ ' values (%s, %s, %s, %s)'
56 print(sql)
57 result = cursor.execute(sql,(CurrentTime, Electric_uA, Distance, WaringStatus))
58 if result == 1:
59 pass
60 # print('添加成功!')
61 else:
62 print('添加数据失败！')
63 # 4. 操作成功提交事务
64 InitMySQL.commit()
65 # 关闭游标
66 cursor.close()
67 def main():
68 # 初始化JSON 和数据库
69 InitJSON()
70 InitMySQL = MysqlInit()
71 # 测试数据库创建 表
72 # Creat_Table(InitMySQL)
73 # 测试写入数据
74 Electric_uA = 1000
75 Distance = 1000
76 WaringStatus = 0
77 i= 0
78 while(i < 10000):
79 # 获取当前时间 年-月-日
80 day_time = datetime.datetime.now().strftime("%Y_%m_%d_%H_%M")
81 # 拼接table名称
82 tabel_name = 'warning' + day_time
83 # 测试数据库创建 表
84 Creat_Table(InitMySQL,tabel_name)
85 i += 1
86 CurrentTime = datetime.datetime.now().strftime("%Y_%m_%d %H:%M:%S")
87 Electric_uA -= 1
88 Distance += 1
89 Write_to_MySQL(InitMySQL, tabel_name, CurrentTime, Electric_uA, Distance, WaringStatus)
90 time.sleep(0.01)
View Code
测试的数据库结果：
3. 从数据库读取数据 1 """ 2 【函数功能】 读取数据库中最新的几分钟数据 3 【输入】 需要查询的table名称（也可以从JSON中读取） 4 【输出】 查找的数据列表 5 """ 6 def Read_from_Mysql(InitMySQL, sql_tabel_name): 7 # 从JSON中读取sql需要的参数 8 set_time = filejson['MysqlInit']['set_delaytime_min'] 9 now_time = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S") 10 last_time = (datetime.datetime.now() - datetime.timedelta(minutes = set_time)).strftime("%Y-%m-%d %H:%M:%S") 11 # sql_tabel_name = filejson['MysqlInit']['sql_tabel_name'] 12 sql_distance_header = filejson['MysqlInit']['distance_header'] 13 sql_time_header = filejson['MysqlInit']['time_header'] 14 # 创建游标 15 cursor = InitMySQL.cursor() 16 sql = "SELECT " + sql_distance_header + " FROM " + sql_tabel_name + " WHERE " + sql_time_header \ 17 + "'" +last_time + "'" 18 # print(sql) 19 cursor.execute(sql) 20 # 获取该字段下的数据 21 result = cursor.fetchall() 22 # 关闭游标 23 cursor.close() 24 # 将数据转换成列表 25 new_distance= [] 26 for dis in result: 27 new_distance.append(dis[0]) 28 return new_distance 【重点】sql的字符串拼接中可以加入变量 时间需要用单引号引起来 园中有博主写的关于数据库，非常详细 可以参考 https://www.cnblogs.com/hackerer/p/11588717.html |
【本文地址】
今日新闻 |
推荐新闻 |