zoukankan      html  css  js  c++  java
  • Python3-pymysql模块-数据库操作之MySQL

    博客转载

      http://www.cnblogs.com/alex3714/articles/5950372.html

    代码示例

    import pymysql
    
    conn = None
    cursor = None
    try:
        # 连接数据库
        conn = pymysql.connect(host='13.13.13.123', port=3306, user='root', passwd='******', db='db_name')
        # 获取游标对象
        cursor = conn.cursor()
        # 执行insert语句
        sql = "insert into tab_student(name,age,sex) values(%s,%s,%s)"
        sql_args = ("Joey1", 47, 1)
        row_count = cursor.execute(sql, sql_args)
        print(row_count)    # 受影响的行数
        # 执行多个insert语句
        sql = "insert into tab_student(name,age,sex) values(%s,%s,%s)"
        sql_args = [("Joey2", 47, 1),
                    ("Joey3", 47, 1),
                    ("Joey4", 47, 1),
                    ("Joey5", 47, 1),
                    ]
        row_count = cursor.executemany(sql, sql_args)
        print(row_count)    # 受影响的行数
        # 提交事务
        conn.commit()
    except Exception as ex:
        conn.rollback()
    finally:
        # 关闭游标与数据库连接
        cursor.close()
        conn.close()
    增-INSERT

    import pymysql
    
    conn = None
    cursor = None
    try:
        # 连接数据库
        conn = pymysql.connect(host='13.13.13.123', port=3306, user='username', passwd='password', db='db_name')
        # 获取游标对象
        cursor = conn.cursor()
        # 执行delete语句
        sql = "delete from tab_student where name = %s and age = %s "
        sql_args = ("Joey", 47,)
        row_count = cursor.execute(sql, sql_args)
        print(row_count)    # 受影响的行数
        # 提交事务
        conn.commit()
    except Exception as ex:
        conn.rollback()
    finally:
        # 关闭游标与数据库连接
        cursor.close()
        conn.close()
    删-DELETE

    import pymysql
    conn = None
    cursor = None
    try:
        # 连接数据库
        conn = pymysql.connect(host='13.13.13.123', port=3306, user='username', passwd='password', db='db_name')
        # 获取游标对象
        cursor = conn.cursor()
        # 执行update语句
        sql = "update tab_student set name = %s where name like %s "
        sql_args = ("Jet", "J%",)
        row_count = cursor.execute(sql, sql_args)
        print(row_count)    # 受影响的行数
        # 提交事务
        conn.commit()
    except Exception as ex:
        conn.rollback()
    finally:
        # 关闭游标与数据库连接
        cursor.close()
        conn.close()
    改-UPDATE

    import pymysql
    
    conn = None
    cursor = None
    try:
        # 连接数据库
        conn = pymysql.connect(host='13.13.13.123', port=3306, user='username', passwd='password', db='db_name')
        # 获取游标对象
        cursor = conn.cursor()
        # 执行update语句
        sql = "select * from tab_student where name = %s "
        sql_args = ("Jet", )
        row_count = cursor.execute(sql, sql_args)
        print(row_count)    # 查询结果的行数
        # 获取查询结果
        result = cursor.fetchone()    # 提取一行查询结果
        # result = cursor.fetchall()    # 提取全部查询结果
        # result = cursor.fetchmany(3)    # 提取指定行的查询结果
        print(result)
    except Exception as ex:
        conn.rollback()
    finally:
        # 关闭游标与数据库连接
        cursor.close()
        conn.close()
    查-SELECT

  • 相关阅读:
    MSMQ简例
    C#观察者模式简例
    C#常见算法题目(面试准备)
    HttpWebRequest
    自定义Attribute简例
    .Net下的 ORM框架介紹
    for xml path的应用
    .net中日至框架log4net.dll如何使用
    动态载入.ascx用户控件
    wap 2.0 编写规范
  • 原文地址:https://www.cnblogs.com/qq1207501666/p/6762627.html
Copyright © 2011-2022 走看看