Home

Index

How to use the connect function from mssql

Find comprehensive JavaScript mssql.connect code examples handpicked from public code repositorys.

mssql.connect establishes a new connection to a Microsoft SQL Server.

README.md?plain=1

55
56
57
58
59
60
61
62
63
64
}

async () => {
 try {
  // make sure that any items are correctly URL encoded in the connection string
  await sql.connect(sqlConfig)
  const result = await sql.query`select * from mytable where id = ${value}`
  console.dir(result)
 } catch (err) {
  // ... error checks

463

+ 29 other calls in file

update-bot.js

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

1
2
3
4
5
6
7
8
9
10
const got = require('got');
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;

145

+ 5 other calls in file

How does mssql.connect work?

mssql.connect is a method in the mssql module in Node.js that establishes a connection with a SQL Server database by creating a new connection pool or reusing an existing one. When called, it takes an object with connection configuration options as a parameter and returns a Promise that resolves to a ConnectionPool object.

app.js

GitHub: instana/nodejs

55
56
57
58
59
60
61
62
63
64
  `IF EXISTS (SELECT * FROM sys.databases WHERE name = N'${dbName}') DROP DATABASE ${dbName}`
);
await new sql.Request().query(`CREATE DATABASE ${dbName}`);
await sql.close();

pool = await sql.connect(connectConfig);
await new sql.Request().query(
  'CREATE TABLE UserTable (id INT IDENTITY(1,1), name VARCHAR(40) NOT NULL, email VARCHAR(40) NOT NULL)'
);
await new sql.Request().batch(

+ 3 other calls in file

org-model.js

GitHub: ShoppinPal/StockUp

430
431
432
433
434
435
436
437
438
439
        message: 'Closed present sql connections, will try connecting to given database',
        options,
        sqlConfig,
        functionName: 'validateMSSQLDatabase'
    });
    return sql.connect(sqlConfig);
})
.then(function (res) {
    logger.debug({
        message: 'Database connected successfully, will update in Integration Model',

Ai Example

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
const sql = require("mssql");

async function connectToDb() {
  try {
    await sql.connect({
      user: "username",
      password: "password",
      server: "localhost",
      database: "mydb",
    });
    console.log("Connected to database successfully!");
  } catch (err) {
    console.error("Error while connecting to database:", err);
  }
}

connectToDb();

This code creates an async function connectToDb that uses mssql.connect to establish a connection to a SQL Server database. The function takes no arguments and returns a Promise that resolves when the connection is established successfully, or rejects with an error if there was a problem connecting. The connect method is called with an object containing the connection configuration, including the username, password, server name, and database name. Once the connection is established, a success message is logged to the console.

dboperations.js

GitHub: debugmodedotnet/sqlservernodejsrestapi

1
2
3
4
5
6
7
8
9
10
const sql = require('mssql');


async function getOrders() {
    try {
        let pool = await sql.connect(config);
        let products = await pool.request().query("SELECT * from Orders");
        return products.recordsets;
    }
    catch (error) {

+ 5 other calls in file

sqlserver.js

GitHub: totaljs/node-sqlagent

1839
1840
1841
1842
1843
1844
1845
1846
1847
1848
	} else
		pools_cache[self.$conn] = self.options;
} else
	self.options = pools_cache[self.$conn];

//self.db = new database.connect(self.options, function(err) {
self.db = new database.ConnectionPool(self.options, function(err) {
	if (err) {
		if (!self.errors)
			self.errors = self.isErrorBuilder ? new global.ErrorBuilder() : [];

README.md?plain=1

GitHub: ColdStart-Challenge/ColdStart-Challenge-2021

33
34
35
36
37
38
39
40
41
42
const mssql = require('mssql');

async function getCatalog() {
  console.log('using database ');

  let pool = await mssql.connect(sqlConfig);
  let result = await pool.request()
    .query(`SELECT * FROM dbo.Icecreams ORDER BY [Id]`);

  return result.recordset;

+ 3 other calls in file

sqlRepository.js

GitHub: maneeshpal/Drata

23
24
25
26
27
28
29
30
31
32

var connectToDatabase = function(datasource, database) {
    var conStr = getConfig(datasource, database);
    var defer = Q.defer();

    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{

+ 15 other calls in file

data_feria.ts

GitHub: vsurak/cursostec

28
29
30
31
32
33
34
35
36
37
}


public getClientsByFilter(filter: string) : Promise<any>
{
    return sql.connect(sqlConfig).then((pool:any) => {
        return pool.request()
            .input("searchcriteria", sql.VarChar(40), filter)
            .execute("getFilteredClients")
    });

+ 3 other calls in file

config.js

GitHub: felipequeiroz179/ProjetoIndividual

26
27
28
29
30
31
32
33
34
35

function executar(instrucao) {
    // VERIFICA A VARIÁVEL DE AMBIENTE SETADA EM app.js
    if (process.env.AMBIENTE_PROCESSO == "producao") {
        return new Promise(function (resolve, reject) {
            sql.connect(sqlServerConfig).then(function () {
                return sql.query(instrucao);
            }).then(function (resultados) {
                console.log(resultados);
                resolve(resultados.recordset);

+ 13 other calls in file

db.js

GitHub: burke1791/march-madness-calcutta-api

14
15
16
17
18
19
20
21
22
23
pool: null,
createConnection: async function() {
  if (this.pool == null) {
    try {
      console.log('creating connection');
      this.pool = await sql.connect(config);
      this.isConnected = true;
    } catch (error) {
      console.log(error);
      this.isConnected = false;

README.md?plain=1

GitHub: dsherret/node-mssql

17
18
19
20
21
22
23
24
25
26
const sql = require('mssql')

async () => {
    try {
        // make sure that any items are correctly URL encoded in the connection string
        await sql.connect('mssql://username:password@localhost/database')
        const result = await sql.query`select * from mytable where id = ${value}`
        console.dir(result)
    } catch (err) {
        // ... error checks

463

+ 3 other calls in file

main.js

GitHub: jsreport/jsreport

5
6
7
8
9
10
11
12
13
14
if (reporter.options.store.provider !== 'mssql' && reporter.options.blobStorage.provider !== 'mssql') {
  definition.options.enabled = false
  return
}

const pool = await sql.connect(definition.options.uri || definition.options)

if (reporter.options.blobStorage.provider === 'mssql') {
  const blobsTable = definition.options.prefix + 'Blob'
  reporter.blobStorage.registerProvider({

200

+ 11 other calls in file

connection.js

GitHub: soheilpro/sqlmon

13
14
15
16
17
18
19
20
21
22
  if (userDomainMatch) {
    this.config.domain = userDomainMatch[1];
    this.config.user = userDomainMatch[2];
  }

  this.connection = await sql.connect(this.config);
}

async execute(query) {
  const result = await this.connection.request().query(query);

+ 13 other calls in file

MsSqlDbClient.js

GitHub: kkrisz1/staruml-reverse-db

10
11
12
13
14
15
16
17
18
19
        log: options.options.logging
    });
}

_cmdExecStmnt(requestId, sqlStr, inputs) {
    return sql.connect(Object.assign(this.options, this.poolConfig))
        .then((pool) => {   // global pool
            if (!this.pool) {
                this.pool = pool;
            }

+ 11 other calls in file

log4js-mssql.js

GitHub: tniemenmaa/log4js-node-mssql

81
82
83
84
85
86
87
88
89
// Return method that does the actual logging
return function (loggingEvent) {

    try {

        mssql.connect(cfg.connSettings).then(function () {

            // Construct the query based on configuration
            var query = cfg.commandText;

+ 11 other calls in file

index.js

GitHub: ueredeveloper/njs-adasa-local

54
55
56
57
58
59
60
61
62
63
64
65
66
67


app.get('/getPointsInPolygon', function (req, res) {
    // mudar para post e assim enviar um polígono para o servidor repl.it


    //conexão com o banco
    sql.connect(config, function (err) {


        if (err) console.log(err);


        // criar requirisão

+ 87 other calls in file

main.js

GitHub: Peekaey/DbReportGenerator

102
103
104
105
106
107
108
109
110
111
            database: 'databasename',
            options: {
                encrypt: false
            }
        };
        yield mssql.connect(dbConfig);
        for (let i = 0; i < QueryConditionArray.length; i++) {
            var SQL = ` // Your SQL query goes here
${QueryConditionArray[i]}`;
            const result = yield mssql.query(SQL);

+ 25 other calls in file

mssqlDb.js

GitHub: isupportcom/PcaServer

51
52
53
54
55
56
57
58
59
60
         SERIESNUM το τελευταιο παραστατικο+1 απο το κατω query και αν δε βρει τιποτα 
         FINCODE βάζω το όνομα της παραγγελίας
 
 */

 await mssql.connect(config);

 getRq()
     .query(`
select findoc,TRNDATE,FISCPRD,PERIOD,FINCODE,BRANCH,int01 as paragomeno,int02 as pos_parag

+ 6 other calls in file

add-table.js

GitHub: ilhmdhn/voucher_app

7
8
9
10
11
12
13
14
15
16
    IF NOT EXISTS (SELECT COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME='IHP_Ivc' AND COLUMN_NAME ='emailed_voucher')
    BEGIN
    ALTER TABLE IHP_Ivc ADD emailed_voucher [smallint] NULL
    END
`
sql.connect(sqlConfig, err=>{
    if(err){
        reject(`Can't connect to database\n${err}`);
    }else{
        new sql.Request().query(query, (err, result)=>{

Other functions in mssql

Sorted by popularity

mssql.connect is the most popular function in mssql (5681 examples)

Other popular packages:

Home

About