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()