案例的目标是将存在文件中的json格式数据转存到sqlite数据库中。因此,需要利用python逐行读取json文件中数据,对数据进行解析和入库。具体操作步骤如下:
1、逐行读取json文件
for line in open(path):
sline= dict(json.load(line))
2、对数据进行解析
假设sline格式为{’id’:123,’name’:’john’,’age’:32},则可通过sline[‘id’]和sline[‘name’]分别获取id和name字段。
3、数据入库
利用python内置的sqlite3模块实现对sqlite数据库的操作;注意sql语句中使用了格式化输出的占位符%s和%d来表示将要插入的变量,其中%s需要加引号''。
#导入sqlite3库文件
import sqlite3
#数据库存在时,直接连接;不存在时,创建相应数据库,此时当前目录下可以找到对应的数据库文件。
conn = sqlite3.connect("customers.db")
print 'Opened database successfully'
#创建CNAME表
conn.execute('''CREATE TABLE CNAME
(ID INT PRIMARY KEY NOT NULL,
NAME TEXT NOT NULL,
AGE INT NOT NULL);''')
print 'Table created successfully'
#向表中插入记录
#注意sql语句中使用了格式化输出的占位符%s和%d来表示将要插入的变量,其中%s需要加引号''
sql = "insert into cname(id,name,age)values(%d,'%s',%d)" % (sline['id'],sline['name'],sline['age'])
con.execute(sql)
conn.commit()
#关闭数据库连接
conn.close()
4、查询和确认数据
可以通过sql语句查询和确认数据入库情况。
cursor = conn.execute("select id,name,age from cname")
for row in cursor:
print 'ID = ', row[0]
print 'NAME = ', row[1]
print 'AGE = ', row[2] '\n'
print 'Operation done successfully'
conn.close()