• 60090

    文章

  • 611

    评论

  • 59

    友链

  • 最近新加了换肤功能,大家多来逛逛吧~~~~
  • 喜欢这个网站的朋友可以加一下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()

 


 转载至链接:https://my.oschina.net/ydsakyclguozi/blog/3007718。

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

欢迎来到梁钟霖个人博客网站。本个人博客网站提供最新的站长新闻,各种互联网资讯。 还提供个人博客模板,最新最全的java教程,java面试题。在此我将尽我最大所能将此个人博客网站做的最好! 谢谢大家,愿大家一起进步!

转载原创文章请注明出处,转载至: 梁钟霖个人博客www.liangzl.com

0条评论

Loading...


发表评论

电子邮件地址不会被公开。 必填项已用*标注

自定义皮肤
注册梁钟霖个人博客