質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

ただいまの
回答率

90.04%

[node.js][sqlite3] データベースを読み込んで処理をするときに綺麗なコードが書きたい

解決済

回答 2

投稿

  • 評価
  • クリップ 0
  • VIEW 3,044

horik

score 42

Friendテーブル
user_id=10001, phase=1
user_id=10002, phase=3
user_id=10003, phase=2

Messageテーブル
phase=1, body='こんにちわ'
phase=2, body='○○に住んでいる○○です'
phase=3, body='よろしくお願いします'

sqliteで上のようなテーブルがあったとして
これを読み込んでfriendからメールが来た時に
Friendテーブルのphaseに応じて
Messageテーブルの文章を
sendMessage(body, user_id);
という形で送信したいと思っています。

sqlで読み込むときにどうしてもコールバック地獄になって
綺麗にコードが書けません。
なにかアドバイスお願いします。

 試したこと

var async = require('async');
var sqlite3 = require("sqlite3").verbose();
var db = new sqlite3.Database('db.sqlite3');

async.waterfall(
  [
    function(callback) {
      db.all("SELECT * FROM friend", function (err, friends) {
          callback(null, friends);
      });
    },
    function(friends, callback) {
      db.all("SELECT * FROM message", function (err, messages) {
          callback(null, messages);
      });
    },
    function(messages, friends, callback) {
      for(var i = 0; i < friends.length; i++) {
        body = messages['phase'][friend[i]['phase']];
        user_id = friends[i]['user_id']:
        object.sendMessage(body, user_id);
      }
      callback(null);
    },
  ]
);

かなり簡略化していますが、
毎回こんな感じでasyncを使ってやっていかなくてはならないんでしょうか?
やりたいことを実現できるライブラリがnode.jsにしかなくて仕方なく使っています。

  • 気になる質問をクリップする

    クリップした質問は、後からいつでもマイページで確認できます。

    またクリップした質問に回答があった際、通知やメールを受け取ることができます。

    クリップを取り消します

  • 良い質問の評価を上げる

    以下のような質問は評価を上げましょう

    • 質問内容が明確
    • 自分も答えを知りたい
    • 質問者以外のユーザにも役立つ

    評価が高い質問は、TOPページの「注目」タブのフィードに表示されやすくなります。

    質問の評価を上げたことを取り消します

  • 評価を下げられる数の上限に達しました

    評価を下げることができません

    • 1日5回まで評価を下げられます
    • 1日に1ユーザに対して2回まで評価を下げられます

    質問の評価を下げる

    teratailでは下記のような質問を「具体的に困っていることがない質問」、「サイトポリシーに違反する質問」と定義し、推奨していません。

    • プログラミングに関係のない質問
    • やってほしいことだけを記載した丸投げの質問
    • 問題・課題が含まれていない質問
    • 意図的に内容が抹消された質問
    • 広告と受け取られるような投稿

    評価が下がると、TOPページの「アクティブ」「注目」タブのフィードに表示されにくくなります。

    質問の評価を下げたことを取り消します

    この機能は開放されていません

    評価を下げる条件を満たしてません

    評価を下げる理由を選択してください

    詳細な説明はこちら

    上記に当てはまらず、質問内容が明確になっていない質問には「情報の追加・修正依頼」機能からコメントをしてください。

    質問の評価を下げる機能の利用条件

    この機能を利用するためには、以下の事項を行う必要があります。

回答 2

+1

coの使用をお勧めします。

const co = require('co');
const thunkify = require('thunkify');

co(function*(){
   const sqlite3 = require("sqlite3").verbose();
   const db = new sqlite3.Database('db.sqlite3');
   const db_all = thunkify(db.all.bind(db));

   const friends = yield db_all("SELECT * FROM friend");
   const messages= yield db_all("SELECT * FROM message");

   for(const friend of friends){
        const body = messages['phase'][friend['phase']];
        const user_id = friend['user_id']:
        object.sendMessage(body, user_id);
   }

   return 'success';
}).then(console.log);

coを使用するとこのように書く事ができます。
スクラッチで記載しましたのでSyntaxエラーになる可能性はありますが、
コードの見た目は概ね変わらないでしょう。

coの詳しい使用方法はcoのサイト等でご自身で調べて下さい。

注意点としてes6の機能を使用するため、es6を使用できない古いnodeでは使用できません。

投稿

編集

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

  • 2016/11/13 08:10

    ブロッキングで順次読み込んで処理できるんですね。
    ちょっと試してみます。
    AltJSと併用もできるんですよね。

    キャンセル

checkベストアンサー

0

Node.js・JavaScriptのシングルスレッドでパフォーマンスを上げるために、
コールバック関数を利用したノンブロッキングなフローという事で根本的な解決は不可能です。
コールバック地獄は避けられません。

小細工的なところでAsyncとPromiseの2通りの逃げ方ができますが、どちらも大差ないでしょう。

 対策その1:処理を関数化して細分化する

そのまんまです。
Node.jsで増えたcommon.jsの機能であるrequireをフル活用すればもう少しきれいになると思います。

 対策その2:AltJSに乗り換える

どんなに頑張ってもJavaScriptは所詮JavaScriptです。
CoffeeScriptやTypeScriptといったAltJSの名前を聞いたことはありませんか?

ほら、あのコンパイルするとJavaSciriptに変換されるメタ言語のことです。
raccyさんの記事が参考になるかと思います。
http://qiita.com/raccy/items/fae9fc5923d78112d935

よくNode.jsで大規模開発する場合、型がないので次第につらくなる、型の強固さを得たTypeScriptに移ろうという話はありますがとんでもない!
大規模開発しない人はすべからくJavaScriptを捨ててCoffeeScript、もしくはそれの進化形であるLiveScriptへ移行すべきです。

ちょっとCoffeeScriptで上記のコードを書いてみますね。
コード量が半分くらいで収まるので刮目してみてください。
あ、因みにfor文はバグの温床なのでArray.forEachに書き換えています。

async = require('async')
sqlite3 = require("sqlite3").verbose()
db = new sqlite3.Database('db.sqlite3')

db.all "SELECT * FROM friend", (err, friends)->
  db.all "SELECT * FROM message", (err, messages)->
    friends.forEach (friend)->
      body = messages.phase[friend.phase]
      user_id = friend.user_id
      object.sendMessage body, user_id

CoffeeScriptはJavaScriptにRubyやPythonのエッセンスを少し加えた程度の言語なので、
horikさんの腕なら何となくでも読めるはずですし、書けるはずです。
変換後の正確なJavaScriptコードは公式サイトに行けば変換できます。

コールバック地獄の問題の本質は、ネストや波括弧・丸括弧だらけになりロジック自身が見えづらいことです。
CoffeeScriptでfunctionや括弧という決まり事のノイズをそぎ落として、
コアなロジック部分だけ表示することで各段に読みやすくなっているかと思います。

ある程度のレベルならAsyncやPromiseという小技に頼る必要がなくなります。
しかも使い方は超絶簡単、上記ファイルを「send_messages.coffee」として保存した前提で実行してみますね。

$ npm install -g coffee-script
$ coffee send_messages.coffee

なんと実行する際のnodeコマンドがcoffeeコマンドに変わっただけです。
AWSのLambdaのようなネイティブのNode.jsしか使えない環境でも、こんな感じのJSファイルから実行できます。

require('coffee-script');
require('./send_messages.coffee');

いかがでしたでしょうか?
しかし、CoffeeScriptは時代遅れなのでLiveScriptを使いましょうね。
こちらは関数型言語のエッセンスを加えたJavaScript版Scalaとでもいうべき最強の言語のひとつです。

require! <[async sqlite3]>
db = new sqlite3.verbose! .Database \db.sqlite3

err, friends <- db.all "SELECT * FROM friend"
err, messages <- db.all "SELECT * FROM message"
friends.for-each ({user_id, phase})->
  object.send-message messages.phase.(phase), user_id

ついにネストがなくなりました。
LiveScriptのバックコールという機能を利用して<-という書き方をすると、
JavaScriptに変換する際に最終引数にコールバックとして配下の行を登録するという記述になります。

その他細々した箇所が格段に書きやすくなっており、
LiveScriptに慣れた人からすればCoffeeScriptなど冗長で退屈な制約に縛られた言語に見えます。

使い方もまったくといっていいほどCoffeeScriptと同様です。

$ npm install -g livescript
$ lsc send_messages.ls
require("livescript");
require("./send_messages.ls");

投稿

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

  • 2016/11/13 07:55

    かなり詳細な回答ありがとうございます!
    AltJSを調べてみました。
    LiveScriptとTypeScriptが主流ぽいですね。
    どうもLiveScriptは文法がRubyっぽくて自分には合わなそうです。

    ぱっと見TypeScriptが魅力的に映るんですが
    問題点がなければこちらを使いたいなと思います。

    キャンセル

  • 2016/11/13 09:54

    残念、でも魅力に感じた方を使えば良いと思います。
    AltJSは自分では実行できず、とにかくJavaScriptに変換して実行しますので全てのライブラリとJSと同じ書き方ができます。

    キャンセル

15分調べてもわからないことは、teratailで質問しよう!

  • ただいまの回答率 90.04%
  • 質問をまとめることで、思考を整理して素早く解決
  • テンプレート機能で、簡単に質問をまとめられる

同じタグがついた質問を見る