利用python将数据转存入sqlite3

案例的目标是将存在文件中的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()

巴特西

利用python将数据转存入sqlite3

最新文章

热门文章