trả về bảng SQL dưới dạng JSON trong python

Question

Tôi đang phát xung quanh với một ứng dụng web nhỏ trong web.py và đang thiết lập url để trả về một đối tượng JSON. Cách tốt nhất để chuyển đổi một bảng SQL thành JSON bằng cách sử dụng python là gì?

Answer 1

Cá nhân tôi thích SQLObject cho loại điều này. Tôi thích một số mã kiểm tra nhanh chóng-và-bẩn tôi phải có được điều này:

import simplejson 

from sqlobject import * 

# Replace this with the URI for your actual database 
connection = connectionForURI('sqlite:/:memory:') 
sqlhub.processConnection = connection 

# This defines the columns for your database table. See SQLObject docs for how it 
# does its conversions for class attributes <-> database columns (underscores to camel 
# case, generally) 

class Song(SQLObject): 

    name = StringCol() 
    artist = StringCol() 
    album = StringCol() 

# Create fake data for demo - this is not needed for the real thing 
def MakeFakeDB(): 
    Song.createTable() 
    s1 = Song(name="B Song", 
       artist="Artist1", 
       album="Album1") 
    s2 = Song(name="A Song", 
       artist="Artist2", 
       album="Album2") 

def Main(): 
    # This is an iterable, not a list 
    all_songs = Song.select().orderBy(Song.q.name) 

    songs_as_dict = [] 

    for song in all_songs: 
     song_as_dict = { 
      'name' : song.name, 
      'artist' : song.artist, 
      'album' : song.album} 
     songs_as_dict.append(song_as_dict) 

    print simplejson.dumps(songs_as_dict) 


if __name__ == "__main__": 
    MakeFakeDB() 
    Main() 

Answer 2

Thông tin khác về cách bạn sẽ làm việc với dữ liệu của mình trước khi chuyển dữ liệu sẽ giúp một tấn. Mô-đun json cung cấp các phương thức tải (s) và tải (s) sẽ giúp ích nếu bạn đang sử dụng phiên bản 2.6 hoặc mới hơn: http://docs.python.org/library/json.html.

- CHỈNH SỬA -

Nếu không biết bạn đang sử dụng thư viện nào, tôi không thể nói chắc chắn bạn sẽ tìm được phương pháp như thế. Thông thường, tôi sẽ xử lý kết quả truy vấn như thế này (ví dụ với kinterbasdb vì đó là những gì chúng tôi hiện đang làm việc với):

qry = "Select Id, Name, Artist, Album From MP3s Order By Name, Artist" 
# Assumes conn is a database connection. 
cursor = conn.cursor() 
cursor.execute(qry) 
rows = [x for x in cursor] 
cols = [x[0] for x in cursor.description] 
songs = [] 
for row in rows: 
    song = {} 
    for prop, val in zip(cols, row): 
    song[prop] = val 
    songs.append(song) 
# Create a string representation of your array of songs. 
songsJSON = json.dumps(songs) 

Có chuyên gia chắc chắn tốt hơn ra có những người sẽ phải comprehensions danh sách để loại bỏ sự cần thiết của viết ra vòng lặp, nhưng điều này hoạt động và phải là một cái gì đó bạn có thể thích ứng với bất kỳ thư viện bạn đang lấy hồ sơ với.

Answer 3

Đây là một ví dụ thực sự tốt đẹp của a pythonic way to do that:

import json 
import psycopg2 

def db(database_name='pepe'): 
    return psycopg2.connect(database=database_name) 

def query_db(query, args=(), one=False): 
    cur = db().cursor() 
    cur.execute(query, args) 
    r = [dict((cur.description[i][0], value) \ 
       for i, value in enumerate(row)) for row in cur.fetchall()] 
    cur.connection.close() 
    return (r[0] if r else None) if one else r 

my_query = query_db("select * from majorroadstiger limit %s", (3,)) 

json_output = json.dumps(my_query) 

Bạn nhận được một mảng của các đối tượng JSON:

>>> json_output 
'[{"divroad": "N", "featcat": null, "countyfp": "001",... 

Hoặc như sau:

>>> j2 = query_db("select * from majorroadstiger where fullname= %s limit %s",\ 
("Mission Blvd", 1), one=True) 

.210

bạn nhận được một đối tượng duy nhất JSON:

>>> j2 = json.dumps(j2) 
>>> j2 
'{"divroad": "N", "featcat": null, "countyfp": "001",... 

Answer 4

import sqlite3 
import json 

DB = "./the_database.db" 

def get_all_users(json_str = False): 
    conn = sqlite3.connect(DB) 
    conn.row_factory = sqlite3.Row # This enables column access by name: row['column_name'] 
    db = conn.cursor() 

    rows = db.execute(''' 
    SELECT * from Users 
    ''').fetchall() 

    conn.commit() 
    conn.close() 

    if json_str: 
     return json.dumps([dict(ix) for ix in rows]) #CREATE JSON 

    return rows 

callin phương pháp không json ...

print get_all_users() 

in:

[(1, u'orvar', u'password123'), (2, u'kalle', u'password123')] 

callin phương pháp với json ...

print get_all_users(json_str = True) 

in:

[{"password": "password123", "id": 1, "name": "orvar"}, {"password": "password123", "id": 2, "name": "kalle"}] 

Answer 5

Tôi gõ cùng một kịch bản ngắn mà bãi tất cả dữ liệu từ tất cả các bảng, như dicts tên cột: giá trị. Không giống như các giải pháp khác, nó không yêu cầu bất kỳ thông tin về những gì các bảng hoặc cột được, nó chỉ tìm thấy tất cả mọi thứ và bãi nó. Hy vọng ai đó thấy nó hữu ích!

from contextlib import closing 
from datetime import datetime 
import json 
import MySQLdb 
DB_NAME = 'x' 
DB_USER = 'y' 
DB_PASS = 'z' 

def get_tables(cursor): 
    cursor.execute('SHOW tables') 
    return [r[0] for r in cursor.fetchall()] 

def get_rows_as_dicts(cursor, table): 
    cursor.execute('select * from {}'.format(table)) 
    columns = [d[0] for d in cursor.description] 
    return [dict(zip(columns, row)) for row in cursor.fetchall()] 

def dump_date(thing): 
    if isinstance(thing, datetime): 
     return thing.isoformat() 
    return str(thing) 


with closing(MySQLdb.connect(user=DB_USER, passwd=DB_PASS, db=DB_NAME)) as conn, closing(conn.cursor()) as cursor: 
    dump = {} 
    for table in get_tables(cursor): 
     dump[table] = get_rows_as_dicts(cursor, table) 
    print(json.dumps(dump, default=dump_date, indent=2)) 

Answer 6

tôi sẽ bổ sung The Demz câu trả lời với các phiên bản psycopg2:

import psycopg2 
import psycopg2.extras 
import json 
connection = psycopg2.connect(dbname=_cdatabase, host=_chost, port=_cport , user=_cuser, password=_cpassword) 
cursor = connection.cursor(cursor_factory=psycopg2.extras.DictCursor) # This line allows dictionary access. 
#select some records into "rows" 
jsonout= json.dumps([dict(ix) for ix in rows]) 

Answer 7

không ai dường như đã được cung cấp tùy chọn để có được những JSON trực tiếp từ máy chủ PostgreSQL, sử dụng khả năng postgres JSON https://www.postgresql.org/docs/9.4/static/functions-json.html

Không phân tích cú pháp, lặp hoặc bất kỳ mức tiêu thụ bộ nhớ nào ở phía trăn, mà bạn thực sự có thể muốn xem xét nếu bạn đang xử lý 100.000 hoặc hàng triệu hàng.

from django.db import connection 

sql = 'SELECT to_json(result) FROM (SELECT * FROM TABLE table) result)' 
with connection.cursor() as cursor: 
    cursor.execute(sql) 
    output = cursor.fetchall() 

một bảng như:

id, value 
---------- 
1  3 
2  7 

sẽ trả về một đối tượng Python JSON

[{"id": 1, "value": 3},{"id":2, "value": 7}] 

Sau đó sử dụng json.dumps để đổ như là một chuỗi JSON cách

Answer 8

đơn giản nhất,

sử dụng json.dumps nhưng nếu datetime của nó sẽ yêu cầu phân tích datetime vào json serializer.

đây là của tôi,

import MySQLdb, re, json 
from datetime import date, datetime 

def json_serial(obj): 
    """JSON serializer for objects not serializable by default json code""" 

    if isinstance(obj, (datetime, date)): 
     return obj.isoformat() 
    raise TypeError ("Type %s not serializable" % type(obj)) 

conn = MySQLdb.connect(instance) 
curr = conn.cursor() 
curr.execute("SELECT * FROM `assets`") 
data = curr.fetchall() 
print json.dumps(data, default=json_serial) 

nó sẽ trở lại json đổ phương pháp đơn giản

một hơn mà không json bãi, đây có tiêu đề và sử dụng zip để lập bản đồ với nhau cuối cùng đã làm cho nó như json nhưng điều này không thay đổi datetime thành json serializer ...

data_json = [] 
header = [i[0] for i in curr.description] 
data = curr.fetchall() 
for i in data: 
    data_json.append(dict(zip(header, i))) 
print data_json