Python_MySQL數據庫的寫入與讀取

【需求】1. 在數據庫中創建表，且能按時間自動創建新表 2. 數據寫入數據庫 3. 從數據庫讀取數據

1. 創建表，並自動更新

def Creat_Table(InitMySQL,tabel_name):
    # 創建游標
    cursor = InitMySQL.cursor()
    sql = "create table if not exists " +  tabel_name  + "(dTime   datetime not null comment '時間'," \
                                                "dElectric_uA  int not null comment '電流'," \
                                                "dDistance   int not null comment '距離'," \
                                                "dWarning    int not null comment '報警')"
    # 打印sql
    print(sql)
    cursor.execute(sql)
    # 關閉游標
    cursor.close()

需要輸入數據庫的連接對象和表名稱，sql根據表名稱判斷數據庫中是否存在該表，如果存在則不會創建，不存在則創建新表

tabel_name 可以根據時間創建

2. 向數據庫中寫入數據

根據創建的數據庫中表的類型進行數據填充

def Write_to_MySQL(InitMySQL,tabel_name, CurrentTime, Electric_uA, Distance, WaringStatus):
    # 創建游標
    cursor = InitMySQL.cursor()
    # #創建sql
    # w_table_name = 'warning' + day_time
    sql = 'insert into '+ tabel_name+ ' values (%s, %s, %s, %s)'
    print(sql)
    result = cursor.execute(sql,(CurrentTime, Electric_uA, Distance, WaringStatus))
    if result == 1:
        pass
        # print('添加成功!')
    else:
        print('添加數據失敗！')
    # 4. 操作成功提交事務
    InitMySQL.commit()
    # 關閉游標
    cursor.close()

整體表的創建與數據輸入

import time
import datetime
import json
import pymysql

# JSON 文件初始化
def InitJSON():
    global filejson
    try:
        with open('TIE_LDY_20190923_1502.json', 'r') as f:
            filejson = json.load(f)
    except FileNotFoundError:
        print('無法打開指定的文件!')
    except LookupError:
        print('指定了未知的編碼!')
    except UnicodeDecodeError:
        print('讀取文件時解碼錯誤!')

#  數據庫參數初始化
def MysqlInit():
    # global LiuCaoSQL
    # 1. 創建數據庫連接對象
    InitMySQL = pymysql.connect(host=filejson['MysqlInit']['host'], port=filejson['MysqlInit']['port'],
                          database=filejson['MysqlInit']['database'], charset=filejson['MysqlInit']['charset'],
                          user=filejson['MysqlInit']['user'], password=filejson['MysqlInit']['password'])
    return InitMySQL

def Creat_Table(InitMySQL,tabel_name):
    # 創建游標
    cursor = InitMySQL.cursor()
    # # 獲取當前時間 年-月-日
    # day_time = datetime.datetime.now().strftime("%Y_%m_%d_%H_%M")
    # # 拼接table名稱
    # tabel_name = 'warning' + day_time
    # 創建sql語句  創建列表的表頭 注意表的類型create table if not exists tablename
    sql = "create table if not exists " +  tabel_name  + "(dTime   datetime not null comment '時間'," \
                                                "dElectric_uA  int not null comment '電流'," \
                                                "dDistance   int not null comment '距離'," \
                                                "dWarning    int not null comment '報警')"
    # 打印sql
    print(sql)
    cursor.execute(sql)
    # 關閉游標
    cursor.close()


# 向數據庫寫入內容
def Write_to_MySQL(InitMySQL,tabel_name, CurrentTime, Electric_uA, Distance, WaringStatus):
    # 創建游標
    cursor = InitMySQL.cursor()
    # 獲取當前時間 年-月-日
    # day_time = datetime.datetime.now().strftime("%Y_%m_%d_%H_%M")
    # #創建sql
    # w_table_name = 'warning' + day_time
    sql = 'insert into '+ tabel_name+ ' values (%s, %s, %s, %s)'
    print(sql)
    result = cursor.execute(sql,(CurrentTime, Electric_uA, Distance, WaringStatus))
    if result == 1:
        pass
        # print('添加成功!')
    else:
        print('添加數據失敗！')
    # 4. 操作成功提交事務
    InitMySQL.commit()
    # 關閉游標
    cursor.close()
def main():
    # 初始化JSON 和數據庫
    InitJSON()
    InitMySQL = MysqlInit()
    # 測試數據庫創建 表
    # Creat_Table(InitMySQL)
    # 測試寫入數據
    Electric_uA = 1000
    Distance = 1000
    WaringStatus = 0
    i= 0
    while(i < 10000):
        # 獲取當前時間 年-月-日
        day_time = datetime.datetime.now().strftime("%Y_%m_%d_%H_%M")
        # 拼接table名稱
        tabel_name = 'warning' + day_time
        # 測試數據庫創建 表
        Creat_Table(InitMySQL,tabel_name)
        i += 1
        CurrentTime = datetime.datetime.now().strftime("%Y_%m_%d %H:%M:%S")
        Electric_uA -= 1
        Distance += 1
        Write_to_MySQL(InitMySQL, tabel_name, CurrentTime, Electric_uA, Distance, WaringStatus)
        time.sleep(0.01)

測試的數據庫結果：

 

 3. 從數據庫讀取數據

"""
   【函數功能】 讀取數據庫中最新的幾分鍾數據
   【輸入】     需要查詢的table名稱（也可以從JSON中讀取）
   【輸出】     查找的數據列表
"""
def Read_from_Mysql(InitMySQL, sql_tabel_name):
    # 從JSON中讀取sql需要的參數
    set_time = filejson['MysqlInit']['set_delaytime_min']
    now_time = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
    last_time = (datetime.datetime.now() - datetime.timedelta(minutes = set_time)).strftime("%Y-%m-%d %H:%M:%S")
    # sql_tabel_name = filejson['MysqlInit']['sql_tabel_name']
    sql_distance_header = filejson['MysqlInit']['distance_header']
    sql_time_header = filejson['MysqlInit']['time_header']
    # 創建游標
    cursor = InitMySQL.cursor()
    sql = "SELECT " + sql_distance_header + " FROM " + sql_tabel_name + " WHERE " + sql_time_header \
          + "<'" + now_time + "'" + " and " +  sql_time_header + ">'" +last_time + "'"
    # print(sql)
    cursor.execute(sql)
    # 獲取該字段下的數據
    result = cursor.fetchall()
    # 關閉游標
    cursor.close()
    # 將數據轉換成列表
    new_distance= []
    for dis in result:
        new_distance.append(dis[0])
    return new_distance

【重點】sql的字符串拼接中可以加入變量 時間需要用單引號引起來

 

 園中有博主寫的關於數據庫，非常詳細 可以參考 https://www.cnblogs.com/hackerer/p/11588717.html