AI 助理
备案控制台
开发者社区 数据库 文章 正文

Express调用mssql驱动公共类dbHelper

2015-09-17 796
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 直接上代码： /** * Created by chaozhou on 2015/9/18. */var mssql = require('mssql');var user = "sa", password = "sa", server = "192.

直接上代码：

/**
 * Created by chaozhou on 2015/9/18.
 */
var mssql = require('mssql');
var user = "sa",
    password = "sa",
    server = "192.168.20.132",
    database = "ggcms";

/**
 * 默认config对象
 * @type {{user: string, password: string, server: string, database: string, options: {encrypt: boolean}, pool: {min: number, idleTimeoutMillis: number}}}
 */
var config = {
    user: user,
    password: password,
    server: server, // You can use 'localhost\\instance' to connect to named instance
    database: database,
    options: {
        encrypt: true // Use this if you're on Windows Azure
    },
    pool: {
        min: 0,
        idleTimeoutMillis: 3000
    }
};

/**
 * 初始化config
 * @param user
 * @param password
 * @param server
 * @param database
 */
var initConfig = function (user, password, server, database) {
    config = {
        user: user,
        password: password,
        server: server, // You can use 'localhost\\instance' to connect to named instance
        database: database,
        options: {
            encrypt: true // Use this if you're on Windows Azure
        },
        pool: {
            min: 0,
            idleTimeoutMillis: 3000
        }
    }
};

/**
 * 恢复默认config
 */
var restoreDefaults = function () {
    config = {
        user: user,
        password: password,
        server: server, // You can use 'localhost\\instance' to connect to named instance
        database: database,
        options: {
            encrypt: true // Use this if you're on Windows Azure
        },
        pool: {
            min: 0,
            idleTimeoutMillis: 3000
        }
    };
};

/**
 * 执行原生Sql
 * @param sql
 * @params 参数对象(可为空，为空表示不加参数)
 * @param callBack(err,recordset)
 */
var querySql = function (sql, params, callBack) {
    var connection = new mssql.Connection(config, function (err) {
        var ps = new mssql.PreparedStatement(connection);
        if (params != "") {
            for (var index in params) {
                if (typeof params[index] == "number") {
                    ps.input(index, mssql.Int);
                } else if (typeof params[index] == "string") {
                    ps.input(index, mssql.NVarChar);
                }
            }
        }
        console.log("sql:" + sql);
        ps.prepare(sql, function (err) {
            if (err)
                console.log(err);
            ps.execute(params, function (err, recordset) {
                callBack(err, recordset);
                ps.unprepare(function (err) {
                    if (err)
                        console.log(err);
                });
            });
        });
    });
    restoreDefaults();
};

/**
 * 带参数查询
 * @param tableName 表名
 * @param topNumber 前topNumber条
 * @param whereSql  whereSql
 * @param params    查询参数对象（可为""，为""表示不加任何参数，如果此项为""，则whereSql必须也为""）
 * @param orderSql  排序Sql（可为""，为""表示不排序）
 * @param callBack
 */
var select = function (tableName, topNumber, whereSql, params, orderSql, callBack) {
    var connection = new mssql.Connection(config, function (err) {
        var ps = new mssql.PreparedStatement(connection);
        var sql = "select * from " + tableName + " ";
        if (topNumber != "") {
            sql = "select top(" + topNumber + ") * from " + tableName + " ";
        }
        sql += whereSql + " ";
        if (params != "") {
            for (var index in params) {
                if (typeof params[index] == "number") {
                    ps.input(index, mssql.Int);
                } else if (typeof params[index] == "string") {
                    ps.input(index, mssql.NVarChar);
                }
            }
        }
        sql += orderSql;
        console.log(sql);
        ps.prepare(sql, function (err) {
            if (err)
                console.log(err);
            ps.execute(params, function (err, recordset) {
                callBack(err, recordset);
                ps.unprepare(function (err) {
                    if (err)
                        console.log(err);
                });
            });
        });
    });
    restoreDefaults();
};

//select("dbo.userInfo",3,"where id = @id",{id:1},"order by id",function(err,recordset){
//    console.log(recordset);
//});

/**
 * 查询所有
 * @param tableName
 * @param callBack
 */
var selectAll = function (tableName, callBack) {
    var connection = new mssql.Connection(config, function (err) {
        var ps = new mssql.PreparedStatement(connection);
        var sql = "select * from " + tableName + " ";
        console.log("sql:" + sql);
        ps.prepare(sql, function (err) {
            if (err)
                console.log(err);
            ps.execute("", function (err, recordset) {
                callBack(err, recordset);
                ps.unprepare(function (err) {
                    if (err)
                        console.log(err);
                });
            });
        });
    });
    restoreDefaults();
};

//selectAll("dbo.userTable",function(err,recordset){
//   console.log(recordset);
//});

/**
 * 添加
 * @param addObj    添加对象（必填）
 * @param tableName 表名
 * @param callBack(err,recordset)
 */
var add = function(addObj,tableName,callBack){      //{id:3,userName:'admin'...}        insert into dbo.tags(id,name) values(@id,@name)
    var connection = new mssql.Connection(config, function (err) {
        var ps = new mssql.PreparedStatement(connection);
        var sql = "insert into " + tableName + "(";
        if (addObj != "") {
            for (var index in addObj) {
                if (typeof addObj[index] == "number") {
                    ps.input(index, mssql.Int);
                } else if (typeof addObj[index] == "string") {
                    ps.input(index, mssql.NVarChar);
                } else if (typeof addObj[index] == "object") {
                    ps.input(index, mssql.DateTime);
                }
                sql += index + ",";
            }
            sql = sql.substr(0, sql.length - 1) + ")values(";
            for (var index in addObj) {
                sql = sql + "@" + index + ",";
            }
        }
        sql = sql.substr(0, sql.length - 1) + ")";
        console.log(sql);
        ps.prepare(sql, function (err) {
            if (err)
                console.log(err);
            ps.execute(addObj, function (err, recordset) {
                callBack(err, recordset);
                ps.unprepare(function (err) {
                    if (err)
                        console.log(err);
                });
            });
        });
    });
    restoreDefaults();
};

//add({"updateTime":new Date(),name:'awdaw,3awdwa,3434'},"dbo.template",function(err,recordset){
//    console.log(recordset);
//});

//var add = function (addObj, tableName, callBack) {
//    var connection = new mssql.Connection(config, function (err) {
//        var ps = new mssql.PreparedStatement(connection);
//        var sql = "insert into " + tableName + "(";
//        if (addObj != "") {
//            for (var index in addObj) {
//                if (typeof addObj[index] == "number") {
//                    ps.input(index, mssql.Int);
//                } else if (typeof addObj[index] == "string") {
//                    ps.input(index, mssql.NVarChar);
//                }
//                sql += index + ",";
//            }
//            sql = sql.substring(0, sql.length - 1) + ") values(";
//            for (var index in addObj) {
//                if (typeof addObj[index] == "number") {
//                    sql += addObj[index] + ",";
//                } else if (typeof addObj[index] == "string") {
//                    sql += "'" + addObj[index] + "'" + ",";
//                }
//            }
//        }
//        sql = sql.substring(0, sql.length - 1) + ")";
//        console.log("sql:" + sql);
//        ps.prepare(sql, function (err) {
//            if (err)
//                console.log(err);
//            ps.execute(addObj, function (err, recordset) {
//                callBack(err, recordset);
//                ps.unprepare(function (err) {        //回收连接至连接池
//                    if (err)
//                        console.log(err);
//                });
//            });
//        });
//    });
//    restoreDefaults();
//};



/**
 * 修改
 * @param updateObj     修改内容（必填）
 * @param whereObj      修改对象（必填）
 * @param tableName     表名
 * @param callBack(err,recordset)
 */
var update = function(updateObj, whereObj, tableName, callBack){
    var connection = new mssql.Connection(config, function (err) {
        var ps = new mssql.PreparedStatement(connection);
        var sql = "update " + tableName + " set ";
        if (updateObj != "") {
            for (var index in updateObj) {
                if (typeof updateObj[index] == "number") {
                    ps.input(index, mssql.Int);
                } else if (typeof updateObj[index] == "string") {
                    ps.input(index, mssql.NVarChar);
                } else if (typeof updateObj[index] == "object") {
                    ps.input(index, mssql.DateTime);
                }
                sql += index + "=@" + index + ",";
            }
            sql = sql.substr(0, sql.length - 1) + " where ";
        }
        if (whereObj != "") {
            for (var index in whereObj) {
                if (typeof whereObj[index] == "number") {
                    ps.input(index, mssql.Int);
                } else if (typeof whereObj[index] == "string") {
                    ps.input(index, mssql.NVarChar);
                } else if (typeof whereObj[index] == "object") {
                    ps.input(index, mssql.DateTime);
                }
                sql += index + "=@" + index + ",";
            }
        }
        sql = sql.substr(0, sql.length - 1);
        var whereStr = JSON.stringify(whereObj);
        var updateStr = JSON.stringify(updateObj);
        whereObj = JSON.parse(updateStr.substr(0,updateStr.length -1) + "," + whereStr.substr(1,whereStr.length));
        console.log(sql);
        ps.prepare(sql, function (err) {
            if (err)
                console.log(err);
            ps.execute(whereObj, function (err, recordset) {
                callBack(err, recordset);
                ps.unprepare(function (err) {
                    if (err)
                        console.log(err);
                });
            });
        });
    });
    restoreDefaults();
};

//update({name:"awdawd",context:'awdaw33434',updateTime:'2015-09-25'},{id:2},"dbo.template",function(err,recordset){
//   console.log(recordset);
//});

//var update = function (updateObj, whereObj, tableName, callBack) {
//    var connection = new mssql.Connection(config, function (err) {
//        var ps = new mssql.PreparedStatement(connection);
//        var sql = "update " + tableName + " set ";        //update userTable set userName = 'admin',loginTimes = 12,password = 'admin'
//        if (updateObj != "") {
//            for (var index in updateObj) {
//                if (typeof updateObj[index] == "number") {
//                    ps.input(index, mssql.Int);
//                    sql += index + "=" + updateObj[index] + ",";
//                } else if (typeof updateObj[index] == "string") {
//                    ps.input(index, mssql.NVarChar);
//                    sql += index + "=" + "'" + updateObj[index] + "'" + ",";
//                }
//            }
//        }
//        sql = sql.substring(0, sql.length - 1) + " where ";
//        if (whereObj != "") {
//            for (var index in whereObj) {
//                if (typeof whereObj[index] == "number") {
//                    ps.input(index, mssql.Int);
//                    sql += index + "=" + whereObj[index] + " and ";
//                } else if (typeof whereObj[index] == "string") {
//                    ps.input(index, mssql.NVarChar);
//                    sql += index + "=" + "'" + whereObj[index] + "'" + " and ";
//                }
//            }
//        }
//        sql = sql.substring(0, sql.length - 5);
//        console.log("sql:" + sql);
//        ps.prepare(sql, function (err) {
//            if (err)
//                console.log(err);
//            ps.execute(updateObj, function (err, recordset) {
//                callBack(err, recordset);
//                ps.unprepare(function (err) {        //回收连接至连接池
//                    if (err)
//                        console.log(err);
//                });
//            });
//        });
//    });
//    restoreDefaults();
//};



/**
 * 删除
 * @param deleteObj 删除对象
 * @param tableName 表名
 * @param callBack(err,recordset)
 */
var del = function (whereSql, params, tableName, callBack) {
    var connection = new mssql.Connection(config, function (err) {
        var ps = new mssql.PreparedStatement(connection);
        var sql = "delete from " + tableName + " ";
        if (params != "") {
            for (var index in params) {
                if (typeof params[index] == "number") {
                    ps.input(index, mssql.Int);
                } else if (typeof params[index] == "string") {
                    ps.input(index, mssql.NVarChar);
                }
            }
        }
        sql += whereSql;
        console.log("sql:" + sql);
        ps.prepare(sql, function (err) {
            if (err)
                console.log(err);
            ps.execute(params, function (err, recordset) {
                callBack(err, recordset);
                ps.unprepare(function (err) {        //回收连接至连接池
                    if (err)
                        console.log(err);
                });
            });
        });
    });
    restoreDefaults();
};

//del("where id = @id",{id:16},"dbo.userTable",function(err,recordset){
//    console.log(recordset);
//});

exports.initConfig = initConfig;
exports.config = config;
exports.del = del;
exports.select = select;
exports.update = update;
exports.querySql = querySql;
exports.restoreDefaults = restoreDefaults;
exports.selectAll = selectAll;
exports.add = add;

 

img_fa0be433d68c8212b2b0b3b1a564ccb1.png
如果本文对你有所帮助，请打赏——1元就足够感动我：）
支付宝打赏 微信打赏
联系邮箱：intdb@qq.com
我的GitHub： https://github.com/vipstone
关注公众号： img_9bde0f31ac4a0eca10b1bd7414b78faf.png


作者： 王磊
出处： http://vipstone.cnblogs.com/
本文版权归作者和博客园共有，欢迎转载，请标明出处。

文章标签：
SQL
索引
数据库
Windows
磊哥聊Java
目录
相关文章
Huazie
|
7月前
|
Java 关系型数据库 MySQL
flea-db使用之封装JDBC接入
【4月更文挑战第6天】本篇 Huazie 介绍 Flea 框架下的 flea-db 模块中封装JDBC的逻辑
Huazie
71 1
flea-db使用之封装JDBC接入
fensnote
|
7月前
|
JSON Linux API
一个C++版本的Sqlite3封装--SmartDb
一个C++版本的Sqlite3封装--SmartDb
fensnote
81 0
aliyun_11084
|
网络协议 流计算 Windows
驱动开发：探索DRIVER_OBJECT驱动对象
本章将探索驱动程序开发的基础部分，了解驱动对象`DRIVER_OBJECT`结构体的定义，一般来说驱动程序`DriverEntry`入口处都会存在这样一个驱动对象，该对象内所包含的就是当前所加载驱动自身的一些详细参数，例如驱动大小，驱动标志，驱动名，驱动节等等，每一个驱动程序都会存在这样的一个结构。
aliyun_11084
60407 0
驱动开发：探索DRIVER_OBJECT驱动对象
七维大脑
|
数据库连接 C# 数据库
C#的通用DbHelper类（支持数据连接池）
C#的通用DbHelper类
七维大脑
391 0
ibonker
|
Java 数据库连接 数据库
SQLite三种JDBC驱动的区别
在DBeaver中看到SQLite有三种JDBC驱动，查了它们官方网站的相关解释，发现它们还是挺不一样的。   SQLite Wrapper by Christian http://www.ch-werner.de/javasqlite/ 这个驱动其实是在本地C/C++的SQLite上用JDBC实现进行了包装。
ibonker
1531 0
技术小能手
使用 C++ 类进行封装的 SQLite3
技术小能手
6066 0
杰克.陈
|
存储 SQL 数据库连接
SQL SERVER使用ODBC 驱动建立的链接服务器调用存储过程时参数不能为NULL值
原文:SQL SERVER使用ODBC 驱动建立的链接服务器调用存储过程时参数不能为NULL值     我们知道SQL SERVER建立链接服务器（Linked Server）可以选择的驱动程序非常多，最近发现使用ODBC 的 Microsoft OLE DB 驱动程序建立的链接服务器（Linked Server）， 调用存储过程过程时，参数不能为NULL值。
杰克.陈
891 0
嗯哼9925
|
SQL Windows
Express调用mssql驱动公共类dbHelper
嗯哼9925
964 0
范大脚脚
|
SQL 数据库 数据安全/隐私保护
MSSQL操作类
范大脚脚
1050 0
技术小胖子
|
SQL Windows
SQL Server 非sysadmin调用扩展函数
技术小胖子
951 0