Python如何读写SQLite数据库

#!/usr/bin/env python3

# -*- coding: utf-8 -*-

import sqlite3# 内置sqlite3，不需要额外安装

#连接数据库

def connectUserDb():

con = sqlite3.connect('user.db')

return con;

#创建User表

def createUserTable(con):

cursor = con.cursor()

cursor.execute('''CREATE TABLE USER

(ID INT PRIMARY KEY NOT NULL,

NAME          TEXT NOT NULL,

SEX          TEXT NOT NULL,

AGE          INT  NOT NULL,

    ADDRESS      CHAR(50));''')

con.commit()

#插入用户记录

def insertUserRecords(con):

cursor = con.cursor()

cursor.execute("INSERT INTO USER(ID, NAME, SEX, AGE, ADDRESS) \

                  VALUES(1, '张三', '男', 25, '福州市')")

cursor.execute("INSERT INTO USER(ID, NAME, SEX, AGE, ADDRESS) \

                      VALUES(2, '李四', '男', 30, '广州市')")

cursor.execute("INSERT INTO USER VALUES(3, '王五', '女', 20, '成都市')")

cursor.execute("INSERT INTO USER VALUES(4, '赵六', '保密', 40, '杭州市')")

con.commit()

#查询所有用户记录

def queryUserRecords(con):

cursor = con.execute("SELECT ID, NAME, SEX, AGE, ADDRESS FROM USER")

for rowin cursor:

print("%d %s %s %d %s" % (row[0], row[1], row[2], row[3], row[4]))

#更新用户记录

def updateUserRecords(con):

cursor = con.execute("UPDATE USER set address='上海市' where id=4")

con.commit()

#删除用户记录

def delUserRecords(con):

cursor = con.execute("DELETE FROM USER where ID=3")

con.commit()

#主函数

if __name__ =="__main__":

con = connectUserDb()# 连接数据库

    createUserTable(con)# 创建表

    insertUserRecords(con)# 插入表数据

    queryUserRecords(con)# 查询用户记录

    updateUserRecords(con)# 更新用户表记录

    delUserRecords(con)# 删除用户表记录

    con.close();# 关闭数据库