How to use the Request function from mssql

run-query.js

GitHub: gumroad/sqlpad

151
152
153
154
155
156
157
158
159
160
        resultsSent = true;
        callback(queryError, results);
    }
};

var request = new mssql.Request(mssqlConnection);
request.query(query);
request.on('recordset', function (columns) {
    // Emitted once for each recordset in a query
    results.columns = columns;

759

0

30

Database.js

GitHub: sasha-alias/sqltabs

191
192
193
194
195
196
197
198
199
200
_getData: function(id, connstr, password, query, callback, err_callback){
    var client = this.getInfoClient(id, connstr, password, err_callback);
    if (typeof(client) == 'undefined'){
        return err_callback(id, 'Failed to get client');
    }
    var request = new mssql.Request(client);

    var sendRequest = function(){
        request.query(query, function(err, result) {
            if (err) {

61

812

40

+ 22 other calls in file

migrate.js

GitHub: DFEAGILEDEVOPS/MTC

28
29
30
31
32
33
34
35
36
37
 * @param {string} database
 * @param {mssql.ConnectionPool} client
 */
function getMigratorConfig (database, client) {
  const asyncExecQuery = async function (query) {
    const request = new mssql.Request(client)
    const goStatementRegex = new RegExp(/^\s*GO\s*$/im)

    if (query.match(goStatementRegex) !== null) {
      const batches = query.split(goStatementRegex)

14

12

11

index.js

GitHub: sqlpad/sqlpad

69
70
71
72
73
74
75
76
77
const maxRows = resolvePositiveNumber(
  connection.maxrows_override,
  connection.maxRows
);

const request = new mssql.Request(pool);
// Stream set a config level doesn't seem to work
request.stream = true;
request.query(query);

759

0

160

+ 5 other calls in file

README.md?plain=1

GitHub: glg/node-mssql

89
90
91
92
93
94
95
96
97
98
sql.connect(config, function(err) {
    // ... error checks
        
    // Query
        
    var request = new sql.Request();
    request.query('select 1 as number', function(err, recordset) {
        // ... error checks

        console.dir(recordset);

463

0

78

+ 19 other calls in file

README.md?plain=1

GitHub: LeanKit-Labs/node-mssql

46
47
48
49
50
51
52
53
54
55
var connection = new sql.Connection(config, function(err) {
    // ... error checks
    
    // Query
        
    var request = new sql.Request(connection); // or: var request = connection.request();
    request.query('select 1 as number', function(err, recordset) {
        // ... error checks
        
        console.dir(recordset);

463

0

0

+ 19 other calls in file

README.md?plain=1

GitHub: transient-team/node-mssql

216
217
218
219
220
221
222
223
224
225
sql.connect(config, err => {
    // ... error checks

    // Query

    new sql.Request().query('select 1 as number', (err, result) => {
        // ... error checks

        console.dir(result)
    })

463

0

3

+ 3 other calls in file

main.js

GitHub: jsreport/jsreport

46
47
48
49
50
51
52
53
54
55

async function executeQuery (q, opts = {}) {
  const connection = pool

  async function execute (connection) {
    const request = new sql.Request(connection)

    for (let i = 0; i < q.values.length; i++) {
      request.input(i + 1 + '', q.values[i])
    }

202

0

56

+ 3 other calls in file

mssql.js

GitHub: loopbackio/loopback-connector-mssql

127
128
129
130
131
132
133
134
135
136
    data = data.recordset;
  }
  callback && callback(err, data);
};

const request = new mssql.Request(connection);
// Allow multiple result sets
if (options.multipleResultSets) {
  request.multiple = true;
}

84

51

42

+ 15 other calls in file

log4js-mssql.js

GitHub: tniemenmaa/log4js-node-mssql

92
93
94
95
96
97
98
99
100
    var param = cfg.parameters[i];
    var value = formatParamValue(param, loggingEvent);
    query = query.replace(param.name, value);
}
// Fire up the request and log possible errors
new mssql.Request().query(query).then(function (recordset) {
}).catch(function (err) {
    console.log('request failed asd: ' + err);
})

2

1

1

+ 11 other calls in file

sqlRepository.js

GitHub: maneeshpal/Drata

28
29
30
31
32
33
34
35
36
37
    var connection = sql.connect(conStr, function(err) {
        if(err){
            defer.reject({code:500, message: utils.format('Error connecting to Sql Server: {0}, database: {1}', datasource, database)});
        }
        else{
            defer.resolve(new sql.Request(connection));
        }
    });
    return defer.promise;
};

9

13

11

+ 15 other calls in file

etl.ts

GitHub: Cognigy/mongotosql

119
120
121
122
123
124
125
126
127
128

// loop through all MongoDB documents and parse them into the correct format for inserting into SQL
for (let doc of mongoResult) {
        let query = "";
        try {
                let r = await new mssql.Request(transaction);
                query = parseDoc(doc);
                let result = await r.query(query);
                x++;
                process.stdout.write("\r\x1b[K");

5

3

0

+ 41 other calls in file

mssql_db.js

GitHub: ether/ueberDB

72
73
74
75
76
77
78
79
80
81
    });
  });
}

get(key, callback) {
  const request = new mssql.Request(this.db);

  request.input('key', mssql.NVarChar(100), key);

  request.query('SELECT [value] FROM [store] WHERE [key] = @key', (err, results) => {

89

256

19

+ 47 other calls in file

mssql.js

GitHub: Skillz4Killz/klasa-pieces

193
194
195
196
197
198
199
200
201
                for (let i = 0; i < outputs.length; i++) request.input(outputs[i]);
                return request.query(sql)
                        .then(result => Promise.resolve(result))
                        .catch(error => Promise.reject(error));
        }
        return new mssql.Request().query(sql)
                .then(result => Promise.resolve(result))
                .catch(error => Promise.reject(error));
}

56

0

2

+ 7 other calls in file

all.js

GitHub: DFEAGILEDEVOPS/MTC

61
62
63
64
65
66
67
68
69
70
    leaCode++
  }
  const dfeNumber = `${leaCode}${estabBase}`
  table.rows.add(leaCode, estabBase++, `bulk school ${(idx - schoolOffset) + 1}`, urnBase++, dfeNumber)
}
const schoolInsertRequest = new sql.Request(pool)
const start = performance.now()
try {
  await schoolInsertRequest.bulk(table)
} catch (error) {

14

12

11

+ 15 other calls in file

update-bot.js

GitHub: SAP-samples/kyma-runtime-extension-samples

2
3
4
5
6
7
8
9
10
11
const axios = require("axios");
const TurndownService = require('turndown');

async function main() {
  var sqlconnection = await sql.connect(database_config);
  const db_request = new sql.Request();

  const [stackData, dbData, caiCredentials] = await Promise.all([get_stackQuestions(), get_dbData(db_request), get_caiCredentials()]);
  var update_all_questions = false;
  if ('UPDATE_ALL' in process.env && process.env.UPDATE_ALL == 'Y') {

67

145

18

+ 5 other calls in file

sqlserver.js

GitHub: totaljs/node-sqlagent

1601
1602
1603
1604
1605
1606
1607
1608
1609
1610
	item.first = isFIRST(item.$query);

(Agent.debug || self.debug) && console.log(self.debugname, item.name, item.$query);
self.$events.query && self.emit('query', item.name, item.$query, item.$params);

var request = new database.Request(self.$transaction ? self.$transaction : self.db);
item.$params && prepare_params_request(request, item.$params);

request.query(item.$query, function(err, rows) {
	self.$bind(item, err, rows ? rows.recordset : []);

22

48

0

generate.js

GitHub: appcelerator-archive/appc.mssql

71
72
73
74
75
76
77
78
79
80
    }
  }, function defineConnectionCallback (err) {
    if (err) {
      cb(err)
    } else {
      request = new sql.Request(connection)
      cb()
    }
  })
},

9

0

53

+ 33 other calls in file

run.js

GitHub: jongio/PowerBI-StackOverflow

115
116
117
118
119
120
121
122
123
124
  throw err
}

items.forEach(function (item) {
  console.log('Upserting question_id: %s, title: %s', item.question_id, item.title)
  var request = new sql.Request(connection)
  request.input('question_id', sql.Int, item.question_id)
  request.input('link', sql.NVarChar, item.link)
  request.input('title', sql.NVarChar, item.title)
  request.input('creation_date', sql.DateTime, moment.unix(item.creation_date).toDate())

7

4

2

migrate.js

GitHub: Fdawgs/ydh-myydh-crud-api

43
44
45
46
47
48
49
50
51
52
	"../migrations/mssql/*"
),
driver: "mssql",
database: client.config.database,
execQuery: /* istanbul ignore next */ async (query) => {
	const request = new mssql.Request(client);
	const result = await request.batch(query);

	return {
		rows: result.recordset ? result.recordset : result,

2

11

0