我正在尝试使用节点和 hapi.js 连接到我的 SQL 服务器数据库

Question

我正在尝试使用节点测试与我的 sql 服务器的连接，并且 hapi.js 和运行在我的一个表上进行简单查询。我对节点和 Hapi 还很陌生，所以我只是想弄清楚这个问题

所以首先我的文件夹结构如下我有一个名为 api 的文件夹，里面有路线，这就是我做路线的地方 get_aosdata.js 这个工作我测试了它只是传回'hello world' 然后我在 api 下有一个查询文件夹，这是我在 connection.js

中设置数据库连接的地方

这是我目前的路线

'use strict';
const query = require('../query/connection');

module.exports = {
    method: 'GET',
    path: '/api/query/{id}',
    config: {
        pre: [
            { method: query.getSqlConnection, assign: 'db' }
        ],
        handler: (request, reply) => {
                const request = new db.Request();
                request.query(`SELECT a.OrdNbr, a.sotypeid, a.user6, a.lupd_datetime, a.user3, a.crtd_user, a.S4Future01, a.slsperid, a.totmerch, a.CustOrdNbr from SOHeader a
                              join customer b
                              on a.CustID = b.CustId
                              join SOLine c
                              on a.OrdNbr = c.OrdNbr
                              where sotypeId = 'Q'`, ((err, recordset) => {

                                if (err) {
                                    console.log(err);
                                }
                                reply(recordset);
                              }));

        }
    }
}

我正在调用一个先决条件来建立我的连接这就是这段代码的样子

const sql = require('mssql');

const dbConfig = {
    server: 'myserver',
    database: 'mydatabase',
    user: 'myuser',
    password: 'mypassword'
}

const getSqlConnection = (request, reply) => {
    sql.connect(dbConfig, ((err) => {
                if (err) {
                    console.log(err);
                }
    }));
            return reply();
}

module.exports = getSqlConnection;

这是我的服务器

'use strict';

const Hapi = require('hapi');

const server = new Hapi.Server();

server.connection({ port: 3001, host: 'localhost' });

server.route(require('./api/routes/get_AOSdata'));

server.start((err) => {
    if(err) {
        throw err;
    }

    console.log(`Server running at: ${server.info.uri}`);
});

现在我的错误是位置 0 的 pre 不匹配任何允许的类型...我对这个错误一无所知，而且我无法在任何地方找到修复。我正在使用 hapi 和 mssql 进行调用任何帮助将不胜感激我是节点和 hapi 的新手，但是我已经阅读了很多关于 hapi 并且真的很想用它

Answer 1

这就是我的做法，希望对您有所帮助

'use strict';
const sql = require('mssql');
const async = require('asyncawait/async');
const await = require('asyncawait/await');
const boom = require('boom');

const dbConfig = {
    server: 'myserver',
    database: 'mydb',
    user: 'myuser',
    password: 'mypass'
}

const conn = new sql.ConnectionPool(dbConfig);

module.exports = {
    method: 'GET',
    path: '/api/query/{id}',
    config: {
        handler: (request, reply) => {


            conn.connect().then(() => {
              req.query(``SELECT a.OrdNbr, a.sotypeid, a.user6, a.lupd_datetime, a.user3, a.crtd_user, a.S4Future01, a.slsperid, a.totmerch, a.CustOrdNbr from SOHeader a
                          join customer b
                          on a.CustID = b.CustId
                          join SOLine c
                          on a.OrdNbr = c.OrdNbr
                          where sotypeId = 'Q'`).then((data) => {
                  reply(data);
                  conn.close();
                })
              .catch((err) => {
               reply(boom.badRequest(err.message, err));
                conn.close();
              });
          })
          .catch((err) => {
              reply(boom.badRequest(err.message, err));
          });
        }
    }
}

在你的情况下，我认为这将在你的路线中

那么你的服务器看起来几乎和这个一样

'use strict';
const Hapi = require('hapi');
const boom = require('boom');

const server = new Hapi.Server();

server.connection({ port: 3001, host: 'localhost', routes: {cors: true} });

server.route(require('./api/routes/get_AOSdata'));

server.start((err) => {
    if(err) {
        boom.badRequest(err.message, err);
    }

    console.log(`Server running at: ${server.info.uri}`);
});

这可能是完全错误的方式，但这就是我工作的方式

我正在尝试使用节点和 hapi.js 连接到我的 SQL 服务器数据库

I am trying to connect to connect to my SQL server database with node and hapi.js

javascript

sql-server

node.js

hapijs