• 105186

    文章

  • 803

    评论

  • 12

    友链

  • 最近新加了换肤功能,大家多来逛逛吧~~~~
  • 喜欢这个网站的朋友可以加一下QQ群,我们一起交流技术。

python3操作mysql数据库(CURD)

撸了今年阿里、腾讯和美团的面试,我有一个重要发现.......>>
import pymysql

#插入数据实例
try:
    # 打开数据库连接
    conn = pymysql.connect(host='127.0.0.1', #数据库地址
                           db='z_python',#数据库名
                           port=3306,#端口
                           user='root',#数据库账号
                           password='123456'#数据库密码
                           )
    # 使用 cursor() 方法创建一个游标对象 cursor
    with conn.cursor() as cursor:
        # 查询
        sql = "insert into users(email,password) values (%s, %s)"
        result = cursor.execute(sql, ('d@163.com', 'china#$%'))
        if(result==1):
            print("插入成功")
        else:
            print("插入失败")

    #数据库提交
    conn.commit()
except Exception as e:
   #打印出异常
   print("插入失败:"+str(e))
   # 异常回滚
   conn.rollback()
finally:
    # 关闭数据库连接
    conn.close()

#读取实例,通过主键读取一条记录
try:
    # 打开数据库连接
    conn = pymysql.connect(host='127.0.0.1', #数据库地址
                           db='z_python',#数据库名
                           port=3306,#端口
                           user='root',#数据库账号
                           password='123456'#数据库密码
                           )
    # 使用 cursor() 方法创建一个游标对象 cursor
    with conn.cursor() as cursor:
        # 查询
        sql = "select * from users where id = %s"
        cursor.execute(sql, (1))
        result = cursor.fetchall()
        #遍历一条数据方式1
        for row in result:
            id = row[0]
            email = row[1]
            password = row[2]
            print("通过主键查询方式1:",id, email, password)
        #遍历一条数据方式2
        sql = "select * from users where id = %s"
        cursor.execute(sql, (1))
        result = cursor.fetchone()
        print("通过主键查询方式2:",result[0],result[1],result[2])

    #数据库提交
    conn.commit()
except Exception as e:
    # 打印出异常
    print("通过主键读取一条记录:" + str(e))
   # 异常回滚
    conn.rollback()
finally:
    # 关闭数据库连接
    conn.close()

#读取实例,like查询多条记录
try:
    # 打开数据库连接
    conn = pymysql.connect(host='127.0.0.1', #数据库地址
                           db='z_python',#数据库名
                           port=3306,#端口
                           user='root',#数据库账号
                           password='123456'#数据库密码
                           )
    # 使用 cursor() 方法创建一个游标对象 cursor
    with conn.cursor() as cursor:
        # like查询
        sql = "select * from users where email  like '%%%s%%'"%('163')
        cursor.execute(sql)
        result = cursor.fetchall()
        # 遍历数据
        for row in result:
            id = row[0]
            email = row[1]
            password = row[2]
            print("like条件查询:", id, email, password)

    #数据库提交
    conn.commit()
except Exception as e:
    # 打印出异常
    print("like查询多条记录失败:" + str(e))
    # 异常回滚
    conn.rollback()
finally:
    # 关闭数据库连接
    conn.close()


#更新数据实例
try:
    # 打开数据库连接
    conn = pymysql.connect(host='127.0.0.1', #数据库地址
                           db='z_python',#数据库名
                           port=3306,#端口
                           user='root',#数据库账号
                           password='123456'#数据库密码
                           )
    # 使用 cursor() 方法创建一个游标对象 cursor
    with conn.cursor() as cursor:
        # like查询
        sql = "update users set email =%s where id= %s"
        result = cursor.execute(sql,('aa@qq.com',1))
        if(result==1):
            print("更新成功")
        else:
            print("更新失败")

    #数据库提交
    conn.commit()
except Exception as e:
    # 打印出异常
    print("更新数据失败:" + str(e))
    # 异常回滚
    conn.rollback()
finally:
    # 关闭数据库连接
    conn.close()

#删除数据实例
try:
    # 打开数据库连接
    conn = pymysql.connect(host='127.0.0.1', #数据库地址
                           db='z_python',#数据库名
                           port=3306,#端口
                           user='root',#数据库账号
                           password='123456'#数据库密码
                           )
    # 使用 cursor() 方法创建一个游标对象 cursor
    with conn.cursor() as cursor:
        # like查询
        sql = "delete from  users where id= %s"
        result = cursor.execute(sql,(16))
        if(result==1):
            print("删除成功")
        else:
            print("删除失败")

    #数据库提交
    conn.commit()
except Exception as e:
    # 打印出异常
    print("更新数据失败:" + str(e))
    # 异常回滚
    conn.rollback()
finally:
    # 关闭数据库连接
    conn.close()

 


695856371Web网页设计师②群 | 喜欢本站的朋友可以收藏本站,或者加入我们大家一起来交流技术!

0条评论

Loading...


自定义皮肤 主体内容背景
打开支付宝扫码付款购买视频教程
遇到问题联系客服QQ:419400980
注册梁钟霖个人博客