Python---sqlite3数据库编程_python sqlite3 怎么写

作为一个Python初学者，我想通过写博客的方式来记录下来自己成长的过程，同时也分享一下自己学习到的知识。以下都是一个Python初学者对Python语言的一些浅见和个人理解。

'''
1.导入sqlite3模块
2.创建连接sqlite3.connect()
3.创建游标对象
4.编写创建表的sql语句
5.执行sql
6.关闭连接
'''
import sqlite3
# 创建连接
con = sqlite3.connect('f:\Python\sqlite3Demo/demo.db')
print(con)
# 创建游标对象
cur = con.cursor()
# 编写创建表的sql语句
sql = '''create table t_person(
            pno INTEGER primary key autoincrement,
            pname VARCHAR not null,
            age INTEGER
        )'''
try:
    # 执行sql语句
    cur.execute(sql)
    print('创建表成功')
except Exception as e:
    print(e)
    print('创建表失败')
finally:
    # 关闭游标
    cur.close()
    # 关闭连接
    con.close()

# 导入模块
import sqlite3
# 创建连接
con = sqlite3.connect('f:\Python\sqlite3Demo/demo.db')
# 创建游标对象
cur = con.cursor()
# 编写插入sql
sql = 'insert into t_person(pname,age) values(?,?)'
try:
    # 执行sql
    cur.execute(sql,('张三',24))
    # 提交事务
    con.commit()
    print('插入数据成功')
except Exception as e:
    print(e)
    con.rollback()
    print('插入数据失败')
finally:
    # 关闭游标连接
    cur.close()
    # 关闭数据库连接
    con.close()

# 导入模块
import sqlite3
# 创建连接
con = sqlite3.connect('f:\Python\sqlite3Demo/demo.db')
# 创建游标
cur = con.cursor()
# 编写插入sql
sql = 'insert into t_person(pname,age) values(?,?)'
try:
    # 执行sql
    cur.executemany(sql,[('张三',23),('李四',24)])
    # 提交事务
    con.commit()
    print('插入多条数据成功')
except Exception as e:
    print(e)
    con.rollback()
    print('插入多条数据失败')
finally:
    # 关闭游标连接
    cur.close()
    # 关闭事务连接
    con.close()

# 导入模块
import sqlite3
# 创建连接
con = sqlite3.connect('f:\Python\sqlite3Demo/demo.db')
# 创建游标
cur = con.cursor()
# 创建查询sql
sql = 'select * from t_person'
try:
    cur.execute(sql)
    # 获取结果集
    person_all = cur.fetchall()
    # print(person_all)
    for person in person_all:
        print(person)
except Exception as e:
    print(e)
    print('查询所有数据失败')
finally:
    # 关闭游标
    cur.close()
    # 关闭连接
    con.close()

# 导入模块
import sqlite3
# 创建连接
con = sqlite3.connect('f:\Python\sqlite3Demo/demo.db')
# 创建游标
cur = con.cursor()
# 创建查询sql
sql = 'select * from t_person'
try:
    cur.execute(sql)
    # 获取结果集
    person = cur.fetchone()
    print(person)
except Exception as e:
    print(e)
    print('查询数据失败')
finally:
    # 关闭游标
    cur.close()
    # 关闭连接
    con.close()

# 导入模块
import sqlite3
# 创建连接
con = sqlite3.connect('f:\Python\sqlite3Demo/demo.db')
# 创建游标
cur = con.cursor()
# 编写修改的SQL语句
sql = 'update t_person set pname=? where pno=?'
# 执行sql
try:
    cur.execute(sql,('张三',1))
    print('修改成功')
except Exception as e:
    print(e)
    print('修改失败')
    con.rollback()
finally:
    # 关闭游标
    cur.close()
    # 关闭连接
    con.close()

# 导入模块
import sqlite3
# 创建连接
con = sqlite3.connect('f:\Python\sqlite3Demo/demo.db')
# 创建游标
cur = con.cursor()
# 编写删除的SQL语句
sql = 'delete from t_person where pno=?'
# 执行sql
try:
    cur.execute(sql,(1,))
    # 提交事务
    con.commit()
    print('删除成功')
except Exception as e:
    print(e)
    print('删除失败')
    con.rollback()
finally:
    # 关闭游标
    cur.close()
    # 关闭连接
    con.close()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172