python连接数据库代码

2019-08-27  本文已影响0人  互联网中的一个咸鱼
import pymysql              #导包
conn = pymysql.connect('localhost', 'root', 'QFedu123!',
                       'mysqldb', charset='utf8mb4')  # 连接数据库
#对应的是数据库地址,用户名,密码,数据库名 , 字符串 
if conn:
    print('数据库连接成功')
cursor = conn.cursor()   # 获取游标对象
# 游标是系统为用户开设的一个数据缓冲区,存放SQL语句的执行结果


def create_table():  # 创建表的函数
    # sql语句
    sql = 'create table table1(id int primary key auto_increment , name varchar(20) not null)'
    cursor.execute(sql)  # 执行sql语句

def insert_data():   # 往表中插入数据
    sql = "insert into table1 values(%s,'%s');" %(6,'alice')   # 插入一条数据
    cursor.execute(sql)

    # sql = 'insert into table1(name) values(%s)'  # 插入多条数据 
    # cursor.executemany(sql,['alice','shark','jpx'])
    conn.commit()                             #提交数据库

def select_data():   # 在表中查找数据
    sql='select * from table1;'
    cursor.execute(sql)           #执行sql语句
    # cursor=conn.cursor(cursor=pymysql.cursors.DictCursor)        #指定获取到的数据的类型
    select_data=cursor.fetchall()    #获取到全部结果         数据默认会以元组的方式保存并输出
    # select_data=cursor.fetchone()     # 获取到一行结果       
    print(select_data)

def del_data():    # 在表中删除数据
    sql="delete from table1 where id=%s" %(2)
    cursor.execute(sql)
    conn.commit()   #向数据库提交

def alter_data():   # 修改数据
    sql="update table1 set name='%s' where name='%s' " %('alice','shark')    
    #前面加上单引号,后面也要加上单引号     前面没有加上引号,就是数字
    #  全部用%s可以避免不必要的麻烦
    #    
    if sql:
        print('修改成功')
    cursor.execute(sql)
    conn.commit()   #提交更新

def main():
    # create_table()    # 创建表格
    # insert_data()      #插入数据
    # select_data()     # 查询数据
    # del_data()         #删除数据
    # alter_data()       #修改数据
    pass

if __name__ == "__main__":
    main()
上一篇 下一篇

猜你喜欢

热点阅读