zoukankan      html  css  js  c++  java
  • python操作mysql

    import pymysql

    def insertOne(result):
    # 连接数据库
    db = pymysql.Connect(
    host='121.196.103.249',
    port=33306,
    user='root',
    passwd='123456',
    db='spider',
    charset='utf8'
    )

    # 获取游标
    cursor = db.cursor()
    
    try:
        # 插入数据
        sql = """insert into test(name,age) values (%s,%s) """
        cursor.execute(sql, (result["name"], result["age"]))
    except:
        print("异常")
    
    # 关闭连接
    db.commit()
    cursor.close()
    db.close()
    

    def insertMany(result):
    # 连接数据库
    db = pymysql.Connect(
    host='121.196.103.249',
    port=33306,
    user='root',
    passwd='123456',
    db='spider',
    charset='utf8'
    )

    # 获取游标
    cursor = db.cursor()
    
    try:
        # 插入多条数据   方式一
        # sql = """insert into test(age,name) values (%s,%s) """
        # data=((x["name"],x["age"]) for x in result)
        # cursor.executemany(sql,data)
    
        # 插入多条数据   方式二
        sql = """insert into test(age,name) values (%s,%s) """
        for x in result:
            cursor.execute(sql, (x["name"], x["age"]))
    
    except:
        print("数据库异常")
    
    # 关闭连接
    db.commit()
    cursor.close()
    db.close()
    

    def select():
    # 连接数据库
    db = pymysql.Connect(
    host='121.196.103.249',
    port=33306,
    user='root',
    passwd='123456',
    db='spider',
    charset='utf8'
    )

    # 获取游标
    cursor = db.cursor()
    
    try:
        sql = "select * from test"
        cursor.execute(sql)
        # 获取所有记录列表
        results = cursor.fetchall()
    except:
        print("异常")
    db.close()
    return results
    

    def update(result):
    # 连接数据库
    db = pymysql.Connect(
    host='121.196.103.249',
    port=33306,
    user='root',
    passwd='123456',
    db='spider',
    charset='utf8'
    )

    # 获取游标
    cursor = db.cursor()
    
    try:
        sql = """UPDATE test set age=%s where name=%s"""
        data=(result["age"],result["name"])
        cursor.execute(sql,data)
    except:
        print("异常")
    # 关闭连接
    db.commit()
    cursor.close()
    db.close()
    

    if name == 'main':
    # result={"name":"haha","age":"18"}
    # insertOne(result)
    # print("插入成功")

    # result=[{"name":"haha","age":"18"},{"name":"haha2","age":"19"}]
    # insertMany(result)
    # print("插入成功")
    
    result={"name":"haha","age":"100"}
    update(result)
    
    # result=select()
    # print(1)
  • 相关阅读:
    Java中如何更换jar包中的.class文件并重新打包
    IIS环境配置和项目部署
    C#中Invoke与BeginInvoke区别
    Windows编程 网络编程基础
    Windows编程 网络编程常见结构体
    什么是OpenGL中的深度、深度缓存、深度测试
    三维场景的渲染优化
    矢量数据转换成栅格数据
    vs2010 c# 配置项问题
    宝宝小时候竟然是近视?
  • 原文地址:https://www.cnblogs.com/jimlau/p/14761587.html
Copyright © 2011-2022 走看看