* * Created by gaoxiong on 2017/1/7. */ var mysql = require(‘mysql‘); //create a connect object var connection = mysql.createConnection({ host:‘localhost‘, user:‘root‘, password:‘12345678‘, database:‘school‘, port:‘3306‘ }); //connect database connection.connect(function(err){ if(err){ console.log(‘connect-‘+err); return; } console.log(‘connected successful‘); }); var userAddSql = ‘insert into user (uname, password) values(?, ?)‘; var param = [‘gaoxiong‘, ‘123456‘]; connection.query(userAddSql, param, function(err, result){ if(err){ console.log(‘query‘,err.message); return; } else { console.log(‘insert sucessful‘); } }) connection.query(‘select * from user‘, function(err,result,fields){ if(err){ console.log(‘err‘,err.message); }else { console.log(result[0]); console.log(fields);//内容比较多 } }) // close connect connection.end(function(err){ if(err){ console.log(‘ close connect-‘+err); return; } console.log(‘close successful‘); });

以上就完成连接数据库，并且插入一条数据的功能。需要注意的是数据库查询的语句都是异步的。以上连接的方法叫做 直接连接，非常消耗内存。

2.连接池连接

先理解概念，何为连接池连接：通俗的理解，一开始就建立了很多条连接（这些连接组成了一个连接池），当你需要需要的时候，取出一条连接线，在这条连接线使用完成之后，将其释放，这条连接线就会回到连接池中。

这种连接池连接也是前辈造好的轮子（中间库），名字叫做 node-mysql，需要全局安装。

npm install -g node-mysql

代码如下：

/**
 * mysqlPool.js
 * Created by gaoxiong on 2017/1/7.
 */
var mysql = require(‘mysql‘);
function optPool() {
    this.isConnected = true;
    this.pool = mysql.createPool({
        host:‘localhost‘,
        user:‘root‘,
        password:‘12345678‘,
        database:‘school‘,
        port:‘3306‘
    });
    this.getPool = function(){
        if (this.isConnected){
            this.pool.on(‘connection‘, function(connection){
                connection.query(‘SET SESSION auto_increment_increment = 1‘);
                this.isConnected = false;
            })
        }
        return this.pool;
    };
}

module.exports = optPool;

/**
 * pool.js
 * Created by gaoxiong on 2017/1/7.
 */
var OptPool = require(‘./mysqlPool‘);

//创建连接池
var optPool = new OptPool();
var pool = optPool.getPool();

//从连接池中获取一个连接
pool.getConnection(function(err, conn){
    console.log(‘ begin insert‘);
    var userAddSql = ‘ insert into user (uname, password) values(?,?)‘;
    var prama = [‘gaoxiong‘,‘123456‘];
    conn.query(userAddSql, prama, function(err,res) {// 异步操作了
        if(err){
            console.log(err);
            return;
        } else {
            console.log(res);
            console.log(‘insert successful‘);
        };
    });
    console.log(‘insert end‘);
    console.log(‘begin select ‘)
    conn.query(‘ select * from user ‘, function(err,res) {// 异步操作了
        if(err){
            console.log(err);
            return;
        } else {
            console.log(res[0]);
        };
        conn.release();//放回连接池
    });
    console.log(‘select over‘);
});

在终端中执行：node pool.js 就可以看到效果了，哈哈哈哈啊哈哈。nice啊。

node基础14：连接数据库

标签：image   insert   values   管理工具   数据库查询   mac   服务器   没有   his