python操作sqlite3小结

发布时间:2019-09-24 08:18:55编辑:auto阅读(1392)

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

    导入模块

    import sqlite3

    建立连接

    con = sqlite3.connect('E:\\2018\\spider\\first.db')

    不仅可以在硬盘中创建数据库文件,还可以在内存中创建

    con = sqlite3.connect(':memory')  

    不过既然在内存中创建貌似就么有必要用数据库了,莫非是装X功能?
    好吧,给跪了!

    connect方法返回con对象,即是数据库链接对象,它提供了以下方法:
    .cursor() 方法来创建一个游标对象
    .commit() 方法来处理事务提交
    .rollback() 方法来处理事务回滚
    .close() 方法来关闭一个数据库连接

    1、游标对象的使用
    对数据库的查询需要使用到游标对象,首先通过cursor()创建一个游标对象:

    cur = con.cursor()

    游标对象有以下方法支持数据库操作:
    .execute()用来执行sql语句
    .executemany()用来执行多条sql语句
    .close() 用来关闭游标
    .fetchone()用来从结果中取一条记录,并将游标指向下一条记录
    .fetchmany()用来从结果中取多条记录。
    .fetchall()用来从结果中取出所以记录
    .scroll()用于游标滚动

    2、创建表
    首先使用游标创建一个person表,包含id,name,age等3列,代码如下:

    cur.execute('CREATE TABLE person (id integer primary key ,name varchar(20),age integer)')

    3、插入数据
    向person表中插入两条数据
    方法1:直接构造一个插入的sql语句

    data = "1,'leon',22"
    cur.execute('INSERT INTO person VALUES (%s)'%data)

    方法2:使用占位符“?”,规避sql注入

    cur.execute('INSERT INTO person VALUES (?,?,?)',(2,'name2',28))

    还可以使用executemany()执行多条sql语句,使用executmany()比循环使用excute()执行多条sql语句效率高。

    cur.executemany('INSERT INTO person VALUES (?,?,?)',[(3,'name3',19),(4,'name4',26)])

    这两种插入数据操作都不会立即生效,需要使用数据库对象con进行提交操作:

    con.commit()

    4.查询数据
    查询刚插入的所有数据

    cur.execute('SELECT * FROM person')

    要提取查询数据,游标对象提供了fetchall()和fetchone()方法
    fetchall()方法获取所有数据,返回一个二维列表。fetchone()方法获取其中一个结果,返回一个元组

    res = cur.fetchall()
    for line in res:
        print("循环fetchall的值>>>",line)

    要从新取才能再次取数据哦,因为游标已经

    cur.execute('SELECT * FROM person')
    res = cur.fetchone()
    print("取一条数据>>>",res)

    5、修改和删除

    cur.execute('UPDATE person SET name=? WHERE id=? ',('cat',2))
    cur.execute('DELETE FROM person WHERE id=1')
    con.commit()

    再查询一下修改个删除之后的数据

    cur.execute('SELECT * FROM person')
    res = cur.fetchall()
    for line in res:
        print("循环删除之后的数据>>>",line)

    最后

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

    输出结果:
    循环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)

    总结:
    实际上创建表操作应该检查表是否存在,可以使用异常处理try…except
    更新和修改和删除都应该检查表数据是否存在,否则程序会报错。
    python 操作数据库插入语句占位符问题
    1,在 Python 中使用 sqlite3 连接数据库,插入语句的展位符为 “?”
    cur.execute(“insert into user values(?,?,?)”,(1,name,12))
    2、在 Python 中,使用 pymysql 连接 mysql 数据库,插入语句的占位符为 “%s”
    cursor.execute(“insert into user values(%s, %s, %s)”,(1,name,100))

关键字