zoukankan      html  css  js  c++  java
  • Python连接mysql基本操作

    创建数据库表

    import  pymysql
    
    # 打开数据库连接
    db= pymysql.connect(host='localhost',user="root",password="root",db="ceshi",port=3306,charset='utf8')
    # 使用cursor()方法获取操作游标
    cur = db.cursor()
    # 使用execute方法执行SQL语句
    cur.execute("drop table if exists student")
    sql = "create table student(id  int primary key auto_increment ,name char(20),sex char(1),age int)"
    try:
        # 执行sql语句
        cur.execute(sql)
        # 提交到数据库执行
        db.commit()
    except:
        db.rollback()
    # 关闭数据库连接
    db.close()

    数据库查询操作

    import  pymysql
    
    db= pymysql.connect(host='localhost',user="root",password="root",db="ceshi",port=3306,charset='utf8')
    cur = db.cursor()
    sql = "select * from student "
    
    try:
        cur.execute(sql)
        result = cur.fetchall()
        for row in result:
            id = row[0]
            name = row[1]
            sex = row[2]
            age = row[3]
            print(id ,name ,sex,age)
    finally:
        db.close()

    数据库插入操作

    import  pymysql
    
    # 打开数据库连接
    db= pymysql.connect(host='localhost',user="root",password="root",db="ceshi",port=3306,charset='utf8')
    # 使用cursor()方法获取操作游标
    cur = db.cursor()
    # 使用execute方法执行SQL语句
    sql ="INSERT INTO student(name,sex,age) values('mac',1,222)"
    
    try:
        # 执行sql语句
        cur.execute(sql)
        # 提交到数据库执行
        db.commit()
    except:
        db.rollback()
    # 关闭数据库连接
    db.close()

    数据库更新操作

    import  pymysql
    
    # 打开数据库连接
    db= pymysql.connect(host='localhost',user="root",password="root",db="ceshi",port=3306,charset='utf8')
    # 使用cursor()方法获取操作游标
    cur = db.cursor()
    # 使用execute方法执行SQL语句
    sql ="update student set age = 123 where age = 222"
    
    try:
        # 执行sql语句
        cur.execute(sql)
        # 提交到数据库执行
        db.commit()
    except:
        db.rollback()
    # 关闭数据库连接
    db.close()

    删除操作

    import  pymysql
    
    # 打开数据库连接
    db= pymysql.connect(host='localhost',user="root",password="root",db="ceshi",port=3306,charset='utf8')
    # 使用cursor()方法获取操作游标
    cur = db.cursor()
    # 使用execute方法执行SQL语句
    sql ="delete from student where age > 50"
    
    try:
        # 执行sql语句
        cur.execute(sql)
        # 提交到数据库执行
        db.commit()
    except:
        db.rollback()
    # 关闭数据库连接
    db.close()
  • 相关阅读:
    Java面向对象编程 -5
    Java面向对象编程 -4.3
    Java面向对象编程 -4.2
    Java面向对象编程 -4
    Java面向对象编程 -3.3
    Java面向对象编程 -3.2
    Java面向对象编程 -3
    自解压格式的命令
    windows批处理命令学习
    使用自解压格式
  • 原文地址:https://www.cnblogs.com/zhan1995/p/8926419.html
Copyright © 2011-2022 走看看