python.pymysql基础

讲一下pymysql的具体使用在此之前默认大家会写sql语句。下面是一些简单概念数据库管理系统DBMS是一种操纵和管理数据库的大型软件用于建立、使用和维护数据库。它是用户或应用程序与数据库之间的接口。常见的DBMSMySQL, Oracle, PostgreSQL, SQL Server, SQLite,Redis, MongoDB, Hbase, Neo4j等。DDL: 数据定义语言:简称DDL(Data Definition Language) 作用: 用来定义数据库对象数据库表列/字段等。 关键字: createdropalter等 DML: 数据操作语言:简称DML(Data Manipulation Language) 作用:用来对数据库中表的记录进行更新。 关键字: insertdeleteupdate等 DQL: 数据查询语言:简称DQL(Data Query Language) 作用:用来查询数据库中表的记录。 关键字: selectfromwhere等 DCL: 数据控制语言简称DCL(Data Control Language) 用来定义数据库的访问权限和安全级别及创建用户。数据库分类关系型数据库SQL和非关系型数据库NoSQL可以粗略理解为前者以表为主包含字段字段值表内和表间有约束关系后者以键值对、文档、列族为主没有固定结构操作部分在pycharm中对MySQL进行操作前我们需要先连接数据库需要安装库pip install pymysql具体操作需要保证pycharm已经连上数据库pymysql.connect()创建数据库连接connect.cursor() 数据库连接中的方法 获取游标 用于后续的数据库操作后面的游标用cur代称cur.execute(sql_op) #执行sql其中sql_op是需要操作的SQL语句操作完成后需要进行.commit()提交才能完成对数据库中数据的修改为保证数据安全同样支持.rollback()操作注意在crud中针对select查询操作是不需要提交的可以直接从cur中获取结果关于输入参数查询为解决sql注入将查询语句和参数分离不使用fstring使用%s占位符在pymysql中所有的占位符都使用%s会自动识别数据类型这一点于python基础语法区分import pymysql # 创建连接 connection pymysql.connect( hostlocalhost, port3306, user,#此处填写用户名 与创建数据库连接时一致 password,#此处填写密码 与创建数据库连接时一致 database,#选择要操作的数据库 charsetutf8, autocommitFalse ) #检查是否连接成功 if connection: print(success) print(connection) else: print(error) # 创建/获取游标 curs connection.cursor() # 通过游标进行操作 row curs.execute(select *from itheima.test_table) # 此处execute返回的是该操作影响了多少行的数据 print(row) print() result curs.fetchone() # 真正的获取结果 print(result) results curs.fetchall() # 本质是在控制cur指针指针扫描过的数据不会再回头去看该步骤的输出会缺少第一个查询的数据 print(results) curs.execute(select *from itheima.test_table) print(curs.fetchmany(10)) # 指定行数输出超出范围则输出全部查询结果 curs.execute(select *from itheima.test_table) for item in curs: # 可遍历 以tuple元组形式输出 print(item) # crud操作 # row curs.execute(insert into itheima.test_table(name,weight) value(taki,49);) # connection.commit() # 保证系列操作一同完成/取消 # try: # curs.execute(update itheima.test_table set weightweight-10 where nametaki;) # curs.execute(update itheima.test_table set weightweight-10 where nameaki;) # except Exception as e: # connection.rollback()#回滚 清空内存 # print(ferror{e}) # else: # connection.commit()#提交 try: sql_op create table if not exists new_table( id int primary key AUTO_INCREMENT, name varchar(20), weight int ); curs.execute(sql_op) except Exception as e: connection.rollback() # 回滚 执行undolog 清空缓冲区 print(ferror{e}) else: connection.commit() # 提交 name input(姓名) weight int(input(体重)) #外层使用单引号的话内层需要用双引号外层双引号的话则相反 sql_op fselect * from test_table where name{name} and weight{weight}; row curs.execute(sql_op) if row: print(row,success) #解决sql注入将查询语句和参数分离 不使用fstring使用%s占位符 在pymysql中所有的占位符都使用%s会自动识别数据类型这一点于python基础语法区分 sql_op select * from test_table where name%s and weight%s; cs (name,weight) row curs.execute(sql_op,cs) if row: print(row,success) # 关闭游标 curs.close() # 关闭连接 connection.close()pymysql操作流程总结1.导入pymysql2.使用pymysql.connect()创建数据库连接3.获取cursor游标4.通过cursor执行SQL语句5.关闭cursor6.关闭数据库连接