连接数据库

import sqlite3

conn = sqlite3.connect('test.db')

创建表

c = conn.cursor()  # 获取游标

sql = '''
    create table company (id int primary key not null, name text not null, age int not null, address char(50), salary real);

'''

c.execute(sql)  # 执行语句
conn.commit()  # 提交数据库操作
conn.close()  # 关闭数据库连接

执行结果

插入数据

conn = sqlite3.connect('test.db')  # 打开或创建数据库文件
print('Opende databas success')

c = conn.cursor()  # 获取游标

sql = '''
    insert into company (id, name,age , address,salary)
    values (1,'张三',32,'成都',8080)
'''

c.execute(sql)  # 执行语句
conn.commit()  # 提交数据库操作
conn.close()  # 关闭数据库连接
print('插入成功')

执行结果

查询

conn = sqlite3.connect('test.db')  # 打开或创建数据库文件
print('Opende databas success')

c = conn.cursor()  # 获取游标

sql = '''
    select id,name,address,salary from company
'''

cur = c.execute(sql)  # 执行语句
for row in cur:
    print('id=', row[0])
    print('name=', row[1])
    print('address=', row[2])
    print('salary=', row[3])
conn.close()  # 关闭数据库连接
print('查询结束')