今天碰到了一个比较奇葩的需求,将mysql表数据转换成json格式。我顺便研究了一下,写了个python。


要我说,数据库操作学会了之后,会节省很多很多时间。

SQL数据—>json数据

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
#!/usr/bin/env python
#-*- coding: utf8 -*-
import MySQLdb
import json
# 定义查询SQL语句
sql = "SELECT id,NAME,LOCAL,mobile,CreateTime FROM db1.s1;"
# 设置列的别名或者直接用表字段名:(下面的sql含有别名)
# sql="SELECT s.id AS 1_id,s.name AS 2_na,s.local AS 3_lo,s.mobile AS 4_mo,s.CreateTime AS 5_ct FROM db1.s1 s;"
# 定义连接MySQL的登录信息(此处以字典形式)
Loginfo = {'USER':'admin', 'PSWD':'admin', 'HOST':'10.10.60.108', 'PORT':4001}
# Python 连接MySQL
conn=MySQLdb.connect(host=Loginfo['HOST'],user=Loginfo['USER'],passwd=Loginfo['PSWD'],port=Loginfo['PORT'],charset='utf8')
cur=conn.cursor()
cur.execute(sql) # 执行SQL查询
data = cur.fetchall() # 查询结果给data。如果执行:print data 显示结果:((第一行内容),(第二行内容),(第三行内容),(第四行内容))
fields = cur.description # 获取查询结果中列的字段名,如果查询SQL中使用别名,此处显示别名。
cur.close()
conn.close()
# Main
column_list = [] # 定义字段名的列表
for i in fields:
column_list.append(i[0])   # 提取字段名,追加到列表中
#print column_list        # 列表显示结果:['id', 'NAME', 'LOCAL', 'mobile', 'CreateTime']
with open('/data/scripts/logdb/json.txt','w+') as f:  # 打开输出结果文件
for row in data:                   # 一次循环,row代表一行,row以元组的形式显示。
result = {}                   # 定义Python 字典
result[column_list[0]] = row[0]         # 将row中的每个元素,追加到字典中。 
result[column_list[1]] = str(row[1])       # Python字段格式 和json字段格式转换
result[column_list[2]] = str(row[2])
result[column_list[3]] = row[3]
result[column_list[4]] = str(row[4])
jsondata=json.dumps(result,ensure_ascii=False) # Python的dict --转换成----> json的object
f.write(jsondata + '\n')             # 写入文件
f.close()

注意:最后输出结果,列的顺序是随机的。

  如果想要顺序输出:1.字段起别名,比如:1_xx,2_xx,3_xx…..然后在在json.dumps中利用:sort_keys=True排序,结果就顺序输出。

例如:

1
print json.dumps({"c": 0, "b": 0, "a": 0}, sort_keys=True)

{“a”: 0, “b”: 0, “c”: 0}

json格式—>sql语句

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
#!/usr/bin/env python
#-*- coding: utf8 -*-
import MySQLdb
import json
datalist = []                     # python 列表
with open('/data/scripts/logdb/json.txt','r') as f:
for line in f:                    # 读取json文件中的行(也就是json的object)   
datalist.append(json.loads(line))        # 将json的object转成 Python的dict,追加到Python 列表中, 结果都是unicode格式:[{},{},{},{},{}]
for dict in datalist:
print dict                     # 打印显示 转换后的结果
for dict in datalist:
dict[u'LOCAL'] = dict[u'LOCAL'].replace('\r\n','\\r\\n').replace("'s","\\'s") # 将字段中的特殊:回车换行以及's 转换,方便形成sql语句
sql = "insert into db1.s1 (mobile,NAME,LOCAL,CreateTime,id) values('%s','%s','%s','%s','%s');" % (dict[u'mobile'],dict[u'NAME'],dict[u'LOCAL'],str(dict[u'CreateTime']),dict[u'id'])
print sql

本文转自:cnblogs