node.jsを使用してSQL Serverから値を取得する。

Question

前提・実現したいこと

node.jsを使用してSQL Serverから値を取得する。
初期画面にてIDとパスワードを入力するとDBに接続し、
パスワードが正しいかを確認し、正しい場合は「homepage」に接続する。
パスワードが誤りの場合は、「パスワードが不正です」と表示させる。

発生している問題・エラーメッセージ

Requests can only be made in the LoggedIn state, not the Initialized state

該当のソースコード

	    // SQL処理																	
	    var connection = new tedious.Connection(config);																	
	    var content = [];   // DBからselectした結果を格納する変数																	
																		
	    connection.on('connect', function(err1) {																	
	        if (err1) {																	
	            console.log("-> error (" + err1 + ")");																	
	        } else {																	
	            																	
	            //var TYPES = require('tedious').TYPES;																	
                var Request = require('tedious').Request;
                var sql="select count(*) as id from t_table1 where id='" + xx  + "'";
                console.log('->sql' + sql);
                var request = new Request(sql, function(err2) {
                    if (err2) {
                        console.log("-> err2 (" + err2 + ")");
                        // 接続を解除																	
                        connection.close();

                        var data = {
                            content: 'IDまたはパスワードが異なっています。正しく入力して下さい。3',
                            disabled : "",
                            color : "red"
                        };
                        res.render('login',data);																	
	                } else {																	
	                    console.log("-> requestCompleted");																	
	                    // 接続を解除																	
	                    connection.close();																	
	                }																	
	            });																	
                var result = {};

                // 出力取り出し																	
	            request.on('row', function(columns) {
                    columns.forEach(function(column) {
                        if (column.value === null) {
                            console.log('NULL');																	
	                    } else {
                            result[column.metadata.colName] = column.value;
                        }
                    });
                    content.push(result);
                    result = {};
                });

                // DB接続を終了した際のイベントハンドラ																	
                // DB接続を切断した後に画面を描写する								
	            connection.on('end', function () {
                    content.forEach(function(value) {
                        console.log('->id='+value.id);
                    });
                    console.log("disconnected");

                    if (content[0].id > 0) {
    
                        connection.on('connect', function(err3) {																	
                            if (err3) {																	
                                console.log("-> error (" + err3 + ")");																	
                            } else {
    
                                console.log('->error_null');
    
                                // SQL処理																	
                                var connection = new tedious.Connection(config);
                                var content2 = [];   // DBからselectした結果を格納する変数	
    
                                var Request = require('tedious').Request;
    
                                var sql2="select password from t_table1 where id='"+xx+"'";
                                console.log('->sql2' + sql2);
                                
                                var request2 = new Request(sql2, function(err4) {
                                    if (err4) {
                                        console.log("-> err4 (" + err4 + ")");
					// 接続を解除																	
                                        connection.close();
                                        
                                        var data = {
                                            content: 'IDが異なっています。正しく入力して下さい。1',
                                            disabled : "",
                                            color : "red"
                                        };
                                        res.render('login',data);																
                                    } else {																	
                                        console.log("-> request2Completed");																	
                                        // 接続を解除																	
                                        connection.close();
                                    }																	
                                });
                                var result2 = {};
    
                                // 出力取り出し																	
                                request2.on('row', function(columns2) {																	
                                    columns2.forEach(function(column2) {																	
                                        if (column2.value === null) {																	
                                            console.log('NULL');																	
                                        } else {																	
                                            result2[column.metadata.colName] = column2.value;																	
                                        }																	
                                    });																	
                                    content2.push(result2);																	
                                    result2 = {};																	
                                });
                                
                                // DB接続を終了した際のイベントハンドラ																	
                                // DB接続を切断した後に画面を描写する																	
                                connection.on('end', function () {																	
                                    content2.forEach(function(value) {																	
                                        console.log('connection_end2');																	
                                    });																	
                                    console.log("disconnected");
                                    var dbpw = content2[0].password;
                                    
                                    console.log('->dbpw'+ dbpw);
    
                                    if (pw == dbpw) {
    
                                        //入力内容とDBのデータが一致した場合
                                        res.redirect('/homepage');
    
                                    } else {
                                        var data = {
                                            //パスワード入力ミス
                                            content: 'パスワードが不正です。',
                                            disabled : '',
                                            color : "red"
                                        };
                                        res.render('login',data);
                                    }																	
                                    
				});	
                                                                                        
                                //SQL実行																	
                                connection.execSql(request2);	
    
                            }
                        });
    
                    } else {
                        var data = {
                            //該当IDが見つからない場合
                            content: 'idが不正です。',
                            disabled : "",
                            color : "red"
                        };
                        res.render('login',data);
                        connection.end();
                    }
                });
                                
                //SQL実行																	
                connection.execSql(request);


            }
        });	

試したこと

構文に誤りがないかチェックはしました。

補足情報（FW/ツールのバージョンなど）

VisualStudioCodeを使用し、IE11で表示させてます。

Answer 1

asyncを使用することにより解決しました。

Answer 2

接続が確立する前にリクエストを投げているようです。

接続完了(または失敗)のタイミングは、onメソッドで検出出来ます。

connection.on("connect",err=>
{
    //errがnullであれば接続完了
})

Comments

[kansai5963]

ご回答ありがとうございます。
ご指摘いただきましたconnection.onをつけさせていただきましたが、homepageに遷移する前にだんまりとなってしまいます。
なお、本質問では省略しておりますが、この前の部分にもう一個select文があり、その中の
connection.on('end', function () {
content.forEach(function(value) {
console.log('->name='+value.name);
});
console.log("disconnected");
の下に該当する部分を入れております。
初歩的な質問かもしれませんが間違えておりましたら大変申し訳ございません。