201505 PostgreSQLアンカンファレンス(PL/Pythonで恬るWEBアプリ)
?
0 likes?1,350 views
2015/05/30に佩われたPostgreSQLアンカンファレンスでの Y創です。 PL/Python + bottle.py でWEBアプリを恬るです
![プレ`スホルダ`を聞ってg佩す
る栽
CREATE?FUNCTION?pystrip(x?text)
??RETURNS?text
AS?$$
target_query?=?"select?empno?from?emp?where?ename=$1"
plan?=?plpy.prepare(target_query,["text"])
r_set?=?plpy.execute(plan,?[?"SMITH"?])
return?r_set[0]["empno"]
$$?LANGUAGE?plpythonu?
岷俊g佩する栽
CREATE?FUNCTION?pl_py_test(x?text)
??RETURNS?text
AS?$$
r_set?=?plpy.execute("select?empno?from?emp?where?ename='SMITH'")
return?r_set[0]["empno"]
$$?LANGUAGE?plpythonu?](https://image.slidesharecdn.com/2015pgpg2layer-150604034748-lva1-app6891/85/201505-PostgreSQL-PL-Python-WEB-18-320.jpg)
![}3
借喀yが吭蹐擦砕iみ函り匯來をk]
api()v方でk伏
pg_stat_activity吉がstart_bottole_httpd軟r泣のY惚しかとれない
repetable read 議な
噸宥の燕はちゃんとread commited](https://image.slidesharecdn.com/2015pgpg2layer-150604034748-lva1-app6891/85/201505-PostgreSQL-PL-Python-WEB-34-320.jpg)
![I
そうだJSONにしよう
圷クエリをjson_aggでラップ
り､呂ならずJSON
dblink('dbname=pg_2_layer', 'select json_agg(t) from (圷クエリ) t')
AS t(result json)
#?DBLINKで徭舵侏トランザクションとする
#?侏にしばられないため、json_aggでラップしている
#?りは畠何JSON
def?do_query_over_dblink(v_query_string):
????#?DBLINKの寄
????base_query?=?"SELECT?*?FROM?dblink('host=%s?port=%s?dbname=%s?user=%s',?%s)?AS?t(result?json)
????last_query?=?base_query?%?(
????????DB_HOST,
????????DB_PORT,
????????DB_NAME,
????????DB_USER,
????????plpy.quote_literal("select?json_agg(t)?from?("?+?v_query_string+?")?t")?#?クエリも哈方なので
????)
????plpy.log(?last_query)
????r_set?=?plpy.execute(last_query)
????plpy.log(r_set)
????#?jsonでしても函誼rはstrになってたのでstrとしてy匯
????result_json_str?=?"[]"
????if?r_set[0]["result"]?is?not?None:
????????result_json_str?=?r_set[0]["result"]
????#?旋喘箸寮宴來を深えてjsonです](https://image.slidesharecdn.com/2015pgpg2layer-150604034748-lva1-app6891/85/201505-PostgreSQL-PL-Python-WEB-38-320.jpg)
201505 PostgreSQLアンカンファレンス(PL/Pythonで恬るWEBアプリ)
- 2. who am i 兆念:表弥 氏芙:アシスト 碧並:ポスグレとオラクルのサポ`トしてます 定h:芙氏繁5定朕(ポスグレ4定伏)
- 6. クラサバ クライアントとデ`タベ`スが岷 ビジネスロジックはクライアント番佩 graph LR id1(クライアント ロジック)-->id2(デ`タベ`ス) style id1 fill:#955,stroke:#111,stroke- width:4px; style id2 fill:#559,stroke:#f66,stroke-width:2px;
- 7. 3咼▲廛螢羽`ション gにWEB/APサ`バえた クライアント箸魯屮薀Ε ビジネスロジックはWEB/APサ`バ graph LR id1(クライアント: ブラウザ)-->id2(WEBサ`バ: ロジック) id2-->id3(DB) style id1 fill:#955,stroke:#111,stroke- width:4px; style id2 fill:#555,stroke:#111,stroke-width:4px; style id3 fill:#559,stroke:#f66,stroke-width:2px;
- 9. そうだ2蚊にろう
- 10. できあがったもの
- 11. PG2LAYER
- 13. PG2LAYER PostgreSQL Two Layer Management System 砿尖喘のダッシュボ`ド クエリY惚をJSONですAPIを戻工 噸宥のWEBアプリにえる採か
- 20. PG2LAYER 撹 でも2夛 graph LR id1(クライアント: ブラウザ)-->id2(DBサ`バ: ロジック) style id1 fill:#955,stroke:#111,stroke-width:4px; style id2 fill:#555,stroke:#111,stroke-width:4px;
- 21. 詰卆贋來 (bottole.py /DBLINK / ドライバ音勣) 詰レイヤ` (ブラウザ <-> デ`タベ`ス) 詰砿尖コスト (DBのバックアップ = APのバックアップ, htmlファイル レス)
- 27. }その1 ImportError: No module named bottole カレントに塘崔したbottole.pyがiみzめない 噸宥はカレントディレクトリは峺協しなくてもいい PostgreSQLの徨プロセスは$PGDATAがカレント pg2layer_db=#?CREATE?OR?REPLACE?FUNCTION?test()?RETURNS?text?AS pg2layer_db?#?$$ pg2layer_db$#? pg2layer_db$#?import?bottole pg2layer_db$#?$$ pg2layer_db?#?LANGUAGE?'plpythonu'?VOLATILE? CREATE?FUNCTION pg2layer_db=#? pg2layer_db=#?select?test()? ERROR:??ImportError:?No?module?named?bottole? CONTEXT:??Traceback?(most?recent?call?last): ??PL/Python?function?"test",?line?3,?in?<module> ????import?bottole PL/Python?function?"test"
- 34. }3 借喀yが吭蹐擦砕iみ函り匯來をk] api()v方でk伏 pg_stat_activity吉がstart_bottole_httpd軟r泣のY惚しかとれない repetable read 議な 噸宥の燕はちゃんとread commited
- 35. 圻咀 音苧(謹蛍}2と揖じ?)
- 37. }4 DBLINKU喇のクエリで双リストが音協 APIでは双リストをURLで峺協するg廾 url query /api/*/hoge -> select * from hoge /api/col1,col2/hoge -> select col1,col2 from hoge DBLINKはり､離禰`タ侏を苧幣しないといけない
- 38. I そうだJSONにしよう 圷クエリをjson_aggでラップ り､呂ならずJSON dblink('dbname=pg_2_layer', 'select json_agg(t) from (圷クエリ) t') AS t(result json) #?DBLINKで徭舵侏トランザクションとする #?侏にしばられないため、json_aggでラップしている #?りは畠何JSON def?do_query_over_dblink(v_query_string): ????#?DBLINKの寄 ????base_query?=?"SELECT?*?FROM?dblink('host=%s?port=%s?dbname=%s?user=%s',?%s)?AS?t(result?json) ????last_query?=?base_query?%?( ????????DB_HOST, ????????DB_PORT, ????????DB_NAME, ????????DB_USER, ????????plpy.quote_literal("select?json_agg(t)?from?("?+?v_query_string+?")?t")?#?クエリも哈方なので ????) ????plpy.log(?last_query) ????r_set?=?plpy.execute(last_query) ????plpy.log(r_set) ????#?jsonでしても函誼rはstrになってたのでstrとしてy匯 ????result_json_str?=?"[]" ????if?r_set[0]["result"]?is?not?None: ????????result_json_str?=?r_set[0]["result"] ????#?旋喘箸寮宴來を深えてjsonです
- 43. ctrl+c pg2layer_db=#?select?start_bottole_httpd(1192)? ^CCancel?request?sent ^CCancel?request?sent
- 46. 鯛ちない看姻噛
- 50. 嶮わり