import pymysql
import datainfo
import time

#獲取參數

host = datainfo.host
username = datainfo.username
password = datainfo.password
database = datainfo.db

print()

#測試數據庫連接
def testconnect():

    #打開數據庫鏈接

    db = pymysql.connect(host,username,password,database)

    #使用cursor() 方法創建一個遊標對象 cursor
 


    cursor = db.cursor()

    #使用execute()方法執行SQL查詢

    cursor.execute("select version()")

    #使用fetchone ()獲取單條數據

    data = cursor.fetchone()

    print(data)

    db.close()

#插入數據庫
def InsertDate():
    #打開數據庫鏈接

    db = pymysql.connect(host,username,password,database,charset=‘utf8‘)

    
 
#使用cursor() 方法創建一個遊標對象 cursor

    cursor = db.cursor()

    create_time = time.strftime(‘%Y-%m-%d %H:%M:%S‘)
    update_time = time.strftime(‘%Y-%m-%d %H:%M:%S‘)
    start_time = time.strftime(‘%Y-%m-%d %H:%M:%S‘)
    end_time = time.strftime(‘%Y-%m-%d %H:%M:%S‘)
    remark = "測試插入信息"
    print("開始
 
")
    #Sql 插入語句
    sql = "insert into demo(start_time,end_time,creat_time,update_time,remark) "           "VALUES (‘%s‘,‘%s‘,‘%s‘,‘%s‘,‘%s‘)"          %(start_time,end_time,create_time,update_time,remark)
    try:
        #執行sql
        print("執行插入")
        tt = cursor.execute(sql)
        print(tt)
        db.commit()
    except UnicodeEncodeError as e :
        #發生錯誤時回滾
        print(e)
        db.rollback()
    db.close()


#查詢操作
def selectData():
    db = pymysql.connect(host, username, password, database, charset=‘utf8‘)

    # 使用cursor() 方法創建一個遊標對象 cursor

    cursor = db.cursor()

    sql = "select * from demo where id >=‘%d‘" %(1)
    try:
        #執行sql
        print("執行查詢")
        cursor.execute(sql)
        results = cursor.fetchall()
        for row in results:
            id = row[0]
            start_time = row[1]
            end_time = row[2]
            create_time = row[3]
            update_time = row[4]
            remark = row[5]
            #打印結果
            print("id = %d,start_time=%s,end_time=%s,create_time=%s,update_time=%s,remark=%s" %(id,start_time,end_time,create_time,update_time,remark))

        db.commit()
    except UnicodeEncodeError as e :
        #發生錯誤時回滾
        print(e)

    db.close()

#更新操作
def update_data():
    db = pymysql.connect(host, username, password, database, charset=‘utf8‘)

    # 使用cursor() 方法創建一個遊標對象 cursor

    cursor = db.cursor()
    update_time = time.strftime(‘%Y-%m-%d %H:%M:%S‘)
    sql = "update demo set update_time =‘%s‘ where id >=‘%d‘ " %(update_time,1)
    try:
        #執行sql
        print("執行更新")
        cursor.execute(sql)

        db.commit()
    except UnicodeEncodeError as e :
        #發生錯誤時回滾
        print(e)
        db.rollback()
    db.close()

#刪除操作
def delete_Date():
    db = pymysql.connect(host, username, password, database, charset=‘utf8‘)

    # 使用cursor() 方法創建一個遊標對象 cursor

    cursor = db.cursor()

    sql = "delete from demo where id <‘%d‘ " %(1)
    try:
        #執行sql
        print("執行刪除")
        cursor.execute(sql)

        db.commit()
    except UnicodeEncodeError as e :
        #發生錯誤時回滾
        print(e)
        db.rollback()
    db.close()



if __name__ == ‘__main__‘:
    testconnect()
    InsertDate()
    selectData()
    update_data()
    delete_Date()

Python 3 Mysql 增刪改查