pythonsqlite3_python操作sqlite3小结

使用默认模块sqlite3

使用sqlite3模块的connect方法来创建/打开数据库&＃xff0c;需要指定数据库路径&＃xff0c;不存在则创建一个新的数据库

导入模块import sqlite3

建立连接con &＃61; sqlite3.connect(&＃39;E:\\2018\\spider\\first.db&＃39;)

不仅可以在硬盘中创建数据库文件&＃xff0c;还可以在内存中创建con &＃61; sqlite3.connect(&＃39;:memory&＃39;)

不过既然在内存中创建貌似就么有必要用数据库了&＃xff0c;莫非是装X功能&＃xff1f;

好吧&＃xff0c;给跪了&＃xff01;

connect方法返回con对象&＃xff0c;即是数据库链接对象&＃xff0c;它提供了以下方法&＃xff1a;

.cursor() 方法来创建一个游标对象

.commit() 方法来处理事务提交

.rollback() 方法来处理事务回滚

.close() 方法来关闭一个数据库连接

1、游标对象的使用

对数据库的查询需要使用到游标对象&＃xff0c;首先通过cursor()创建一个游标对象&＃xff1a;cur &＃61; con.cursor()

游标对象有以下方法支持数据库操作&＃xff1a;

.execute()用来执行sql语句

.executemany()用来执行多条sql语句

.close() 用来关闭游标

.fetchone()用来从结果中取一条记录&＃xff0c;并将游标指向下一条记录

.fetchmany()用来从结果中取多条记录。

.fetchall()用来从结果中取出所以记录

.scroll()用于游标滚动

2、创建表

首先使用游标创建一个person表&＃xff0c;包含id,name,age等3列&＃xff0c;代码如下&＃xff1a;cur.execute(&＃39;CREATE TABLE person (id integer primary key ,name varchar(20),age integer)&＃39;)

3、插入数据

向person表中插入两条数据

方法1&＃xff1a;直接构造一个插入的sql语句data &＃61; "1,&＃39;leon&＃39;,22"

cur.execute(&＃39;INSERT INTO person VALUES (%s)&＃39;%data)

方法2&＃xff1a;使用占位符“?”&＃xff0c;规避sql注入cur.execute(&＃39;INSERT INTO person VALUES (?,?,?)&＃39;,(2,&＃39;name2&＃39;,28))

还可以使用executemany()执行多条sql语句&＃xff0c;使用executmany()比循环使用excute()执行多条sql语句效率高。cur.executemany(&＃39;INSERT INTO person VALUES (?,?,?)&＃39;,[(3,&＃39;name3&＃39;,19),(4,&＃39;name4&＃39;,26)])

这两种插入数据操作都不会立即生效&＃xff0c;需要使用数据库对象con进行提交操作&＃xff1a;con.commit()

4.查询数据

查询刚插入的所有数据cur.execute(&＃39;SELECT * FROM person&＃39;)

要提取查询数据&＃xff0c;游标对象提供了fetchall()和fetchone()方法

fetchall()方法获取所有数据&＃xff0c;返回一个二维列表。fetchone()方法获取其中一个结果&＃xff0c;返回一个元组res &＃61; cur.fetchall()

for line in res:

print("循环fetchall的值>>>",line)

要从新取才能再次取数据哦&＃xff0c;因为游标已经cur.execute(&＃39;SELECT * FROM person&＃39;)

res &＃61; cur.fetchone()

print("取一条数据>>>",res)

5、修改和删除cur.execute(&＃39;UPDATE person SET name&＃61;? WHERE id&＃61;? &＃39;,(&＃39;cat&＃39;,2))

cur.execute(&＃39;DELETE FROM person WHERE id&＃61;1&＃39;)

con.commit()

再查询一下修改个删除之后的数据cur.execute(&＃39;SELECT * FROM person&＃39;)

res &＃61; cur.fetchall()

for line in res:

print("循环删除之后的数据>>>",line)

最后con.close() # 关闭数据库链接

输出结果&＃xff1a;

循环fetchall的值>>> (1, ‘leon’, 22)

循环fetchall的值>>> (2, ‘name2’, 28)

循环fetchall的值>>> (3, ‘name3’, 19)

循环fetchall的值>>> (4, ‘name4’, 26)

取一条数据>>> (1, ‘leon’, 22)

循环删除之后的数据>>> (2, ‘cat’, 28)

循环删除之后的数据>>> (3, ‘name3’, 19)

循环删除之后的数据>>> (4, ‘name4’, 26)

总结&＃xff1a;

实际上创建表操作应该检查表是否存在&＃xff0c;可以使用异常处理try…except

更新和修改和删除都应该检查表数据是否存在&＃xff0c;否则程序会报错。

python 操作数据库插入语句占位符问题

1&＃xff0c;在 Python 中使用 sqlite3 连接数据库&＃xff0c;插入语句的展位符为 “&＃xff1f;”

cur.execute(“insert into user values(?,?,?)”,(1,name,12))

2、在 Python 中&＃xff0c;使用 pymysql 连接 mysql 数据库&＃xff0c;插入语句的占位符为 “%s”

cursor.execute(“insert into user values(%s, %s, %s)”,(1,name,100))