国外 网站网站,珠海做网站设计,互联网创业项目推荐,做视频图片博客网站1.引入模块
在py文件中引入pymysql模块
from pymysql import *2.Connection 对象 用于建立与数据库的连接 创建对象#xff1a;调用connect()方法
connconnect(参数列表)参数host#xff1a;连接的mysql主机#xff0c;如果本机是localhost参数port#xff1a;连接的m…
1.引入模块
在py文件中引入pymysql模块
from pymysql import *2.Connection 对象 用于建立与数据库的连接 创建对象调用connect()方法
connconnect(参数列表)参数host连接的mysql主机如果本机是localhost参数port连接的mysql主机的端口默认是3306参数database数据库的名称参数user连接的用户名参数password连接的密码参数charset通信采用的编码方式推荐使用utf8
对象的方法
close()关闭连接commit()提交rollback()回滚cursor()返回Cursor对象用于执行sql语句并获得结果
3.Cursor对象
用于执行sql语句使用频度最高的语句为select、insert、update、delete获取Cursor对象调用Connection对象的cursor()方法
cs1conn.cursor()对象的方法
close()关闭execute(operation [, parameters ])执行语句返回受影响的行数主要用于执行insert、update、delete语句也可以执行create、alter、drop等语句fetchone()执行查询语句时获取查询结果集的第一个行数据返回一个元组fetchall()执行查询时获取结果集的所有行一行构成一个元组再将这些元组装入一个元组返回
对象的属性
rowcount只读属性表示最近一次execute()执行后受影响的行数connection获得当前连接对象 增删改 创建test_insert.py文件向学生表中插入一条数据 #encodingutf-8
from pymysql import *if __name____main__:try:#创建Connection连接connconnect(hostlocalhost,port3306,databasetest1,userroot,passwordmysql,charsetutf8)#获得Cursor对象cs1conn.cursor()#执行insert语句并返回受影响的行数添加一条学生数据# 增加countcs1.execute(insert into students(name) values(张良))# 更新countcs1.execute(update students set name刘邦 where id6)# 删除countcs1.execute(delete from students where id6)#打印受影响的行数print count#关闭Cursor对象cs1.close()#提交之前的操作此处为insert操作conn.commit()except Exception,e:print efinally:#关闭Connection对象conn.close()查询一行数据 创建test_one.py文件查询一条学生信息 #codingutf-8
from pymysql import *if __name____main__:try:#创建Connection连接connconnect(hostlocalhost,port3306,userroot,passwordmysql,databasepython1,charsetutf8)#获得Cursor对象cs1conn.cursor()#执行select语句并返回受影响的行数查询一条学生数据countcs1.execute(select id,name from students where id7)#打印受影响的行数print count#获取查询的结果result cs1.fetchone()#打印查询的结果print result#关闭Cursor对象cs1.close()except Exception as e:print efinally:#关闭Connection对象conn.close()查询多行数据 创建test_many.py文件查询所有学生信息 #codingutf-8
from pymysql import *if __name__main:try:#创建Connection连接connconnect(hostlocalhost,port3306,userroot,passwordmysql,databasepython1,charsetutf8)#获得Cursor对象cs1conn.cursor()#执行select语句并返回受影响的行数查询所有学生数据countcs1.execute(select id,name from students)#打印受影响的行数print count#获取查询的结果result cs1.fetchall()#打印查询的结果print result#关闭Cursor对象cs1.close()except Exception as e:print efinally:#关闭Connection对象conn.close()
