社内のデータが外出先から見られたら便利なことってありますよね。
（それをやって良いかどうかは別にして）TRYしてみました。
PostgreSQLに登録された情報をkintoneアプリに登録するサンプルです。
もちろん、更新や削除もいけますよ！
今回はPostgreSQLのStored Procedureを使ってkintoneを操作します。
※kintoneはクラウドで動作するデータベースサービスです。
ドラッグ&ドロップでパーツを配置するだけで、データベースと入力フォームが出来上がります。
REST APIでのデータ操作が可能です。
前提
- PostgreSQLのテーブルにserial型（unique）があること
- serial値は更新されないこと
サンプルコードで動作するデータ構成
kintoneのフィールド名、フィールドタイプ、フィールドコード、PostgreSQLの列名、型は以下
| フィールド名 | フィールドタイプ | フィールドコード | 列名 | 型 |
|---|---|---|---|---|
| PostgreSQLの管理番号 | 数値 | serial_id | serial_id | serial |
| 会社名 | 文字列1行 | company_name | company_name | varchar |
| 担当 | ユーザー選択 | account_executive | account_executive | varchar |
| 訪問予定日 | 日付 | next_visit_day | next_visit_day | date |
PostgreSQLの環境構築
PostgreSQLのインストール
$ sudo yum install postgresql-server postgresql-plpython python-requests
PostgreSQLの起動
$ sudo postgresql-setup initdb
$ sudo systemctl start postgresql
データベースの作成
$ su - postgres
$ createdb withkintone
テーブルの作成
$ psql withkintone
withkintone=# create table customer_manage (serial_id serial, company_name varchar(100), account_executive varchar(50), next_visit_day date);
PL/Pythonの有効化
（本当はkintoneのカスタマイズと同じJavaScriptでやりたかったのですが、今はHTTPリクエストが不可なので）
withkintone=# create extension plpythonu;
kintoneの環境構築
前提にあるとおりフォームを作成
APIトークンを発行（アプリの設定完了を押し忘れないように！）
サンプルコード
CREATE OR REPLACE FUNCTION relay_to_kintone() RETURNS TRIGGER AS $$
import urllib
import requests
import json
# 連携するアプリID
app = 1983
# 連携するドメイン
domain = 'xxxx.cybozu.com'
# 連携するアプリのAPIトークン
token = 'xxxx'
# PostgreSQLのserial列名
relay_column = 'serial_id'
class Kintone:
# initialize
def __init__(self, app, domain, token, relay_column):
self.app = app
self.domain = domain
self.token = token
self.relay_column = relay_column
# 更新、削除のためにkintoneのレコード番号を取得
def get_record_id(self):
url = 'https://' + self.domain + '/k/v1/records.json'
headers = {
'X-Cybozu-API-Token': self.token,
'Content-Type': 'application/json'
}
data = {
'app': self.app,
'query': self.relay_column + ' = "' + str(TD['old'][self.relay_column]) + '"',
'fields': ['$id'],
'totalCount': 'true'
}
res = requests.get(url, headers=headers, data=json.dumps(data))
total_count = res.json()['totalCount']
if total_count == '1':
return res.json()['records'][0]['$id']['value']
else:
message = self.relay_column + ': ' + str(TD['old'][self.relay_column])
message += 'が' + str(total_count) + '件あります'
plpy.fatal(message)
# レコードの登録
def insert_record(self):
url = 'https://' + self.domain + '/k/v1/record.json'
headers = {
'X-Cybozu-API-Token': self.token,
'Content-Type': 'application/json'
}
# 列名やフィールドタイプなどが異なる場合は要書き換え
data = {
'app': app,
'record': {
self.relay_column: { 'value': TD['new'][self.relay_column] },
'company_name': { 'value': TD['new']['company_name'] },
'account_executive': { 'value': [{'code': TD['new']['account_executive']}]},
'next_visit_day': { 'value': TD['new']['next_visit_day'] }
}
}
res = requests.post(url, headers=headers, data=json.dumps(data))
message = self.relay_column + ': ' + str(TD['new'][self.relay_column])
if res.status_code == 200:
message += 'を登録しました'
plpy.info(message)
else:
message += 'の登録に失敗しました'
plpy.error(message)
# レコードの更新
def update_record(self, update_id):
url = 'https://' + self.domain + '/k/v1/record.json'
headers = {
'X-Cybozu-API-Token': self.token,
'Content-Type': 'application/json'
}
# 列名やフィールドタイプなどが異なる場合は要書き換え
data = {
'app': self.app,
'id': update_id,
'record': {
'company_name': { 'value': TD['new']['company_name'] },
'account_executive': { 'value': [{'code': TD['new']['account_executive']}]},
'next_visit_day': { 'value': TD['new']['next_visit_day'] }
}
}
res = requests.put(url, headers=headers, data=json.dumps(data))
message = self.relay_column + ': ' + str(TD['new'][self.relay_column])
if res.status_code == 200:
message += 'を更新しました'
plpy.info(message)
else:
message += 'の更新に失敗しました'
plpy.error(message)
# レコードの削除
def delete_record(self, delete_id):
url = 'https://' + domain + '/k/v1/records.json'
headers = {
'X-Cybozu-API-Token': self.token,
'Content-Type': 'application/json'
}
data = {
'app': self.app,
'ids': [delete_id]
}
res = requests.delete(url, headers=headers, data=json.dumps(data))
message = self.relay_column + ': ' + str(TD['old'][self.relay_column])
if res.status_code == 200:
message += 'を削除しました'
plpy.info(message)
else:
message += 'の削除に失敗しました'
plpy.error(message)
kintone = Kintone(app, domain, token, relay_column)
if TD['event'] == 'INSERT':
kintone.insert_record()
elif TD['event'] == 'UPDATE':
update_id = kintone.get_record_id()
kintone.update_record(update_id)
elif TD['event'] == 'DELETE':
delete_id = kintone.get_record_id()
kintone.delete_record(delete_id)
return 'OK'
$$ LANGUAGE plpythonu;
サンプルコードの読み込み
withkintone=# \i sample.sql
トリガーの作成
withkintone=# CREATE TRIGGER kintone_trigger AFTER INSERT OR UPDATE OR DELETE ON customer_manage FOR EACH ROW EXECUTE PROCEDURE relay_to_kintone();
動作確認
1件登録
どきどき・・・
withkintone=# insert into customer_manage (company_name, account_executive, next_visit_day) values ('○○株式会社', 'momota', '2016-01-01');
上手く行きました。
2件登録
withkintone=# insert into customer_manage (company_name, account_executive, next_visit_day) values ('××株式会社', 'momota', '2016-02-01'), ('△△株式会社', 'tamai', '2016-03-01');
いえあ！
2件更新
では調子に乗って2件更新してみます。
withkintone=# update customer_manage set account_executive = 'hayami' where next_visit_day in ('2016-02-01', '2016-03-01');
ひゅ～ひゅ～！
2件削除
同じ調子で2件削除してみます。
withkintone=# delete from customer_manage where account_executive = 'hayami';
どんどんぱふぱふ！！！
まとめ
これで社内の情報をこっそり社外で見られますね！（違
kintoneはグラフ機能もすぐれてますので、kintoneで見える化するのもお勧めです。
kintone開発者ライセンス
kintone面白そうだな～と思った方は5ユーザー、1年間無償の開発者ライセンスを使ってみてください。