博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Python 3 Mysql 增删改查
阅读量:5235 次
发布时间:2019-06-14

本文共 3086 字,大约阅读时间需要 10 分钟。

 

 

import pymysqlimport datainfoimport time#获取参数host = datainfo.hostusername = datainfo.usernamepassword = datainfo.passworddatabase = datainfo.dbprint()#测试数据库连接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()

 

转载于:https://www.cnblogs.com/Skyyj/p/6821046.html

你可能感兴趣的文章
苹果开发者账号那些事儿(二)
查看>>
使用C#交互快速生成代码!
查看>>
UVA11374 Airport Express
查看>>
P1373 小a和uim之大逃离 四维dp,维护差值
查看>>
NOIP2015 运输计划 树上差分+树剖
查看>>
P3950 部落冲突 树链剖分
查看>>
读书_2019年
查看>>
读书汇总贴
查看>>
微信小程序 movable-view组件应用:可拖动悬浮框_返回首页
查看>>
MPT树详解
查看>>
空间分析开源库GEOS
查看>>
RQNOJ八月赛
查看>>
前端各种mate积累
查看>>
jQuery 1.7 发布了
查看>>
Python(软件目录结构规范)
查看>>
Windows多线程入门のCreateThread与_beginthreadex本质区别(转)
查看>>
Nginx配置文件(nginx.conf)配置详解1
查看>>
linux php编译安装
查看>>
name phone email正则表达式
查看>>
721. Accounts Merge
查看>>