nodejs简单访问及操作mysql数据库的方法示例

Posted 2023-04-12

参考技术A 本文实例讲述了nodejs简单访问及操作mysql数据库的方法。分享给大家供大家参考，具体如下：
var
mysql
=
require('mysql');
//调用MySQL模块
mysql模块要安装
$
npm
install
mysql
//创建一个connection
var
connection
=
mysql.createConnection(
host
:
'127.0.0.1',
//主机
user
:
'root',
//MySQL认证用户名
password
:
'',
//MySQL认证用户密码
port:
'3306',
//端口号
database:''
//数据库名
);
//创建一个connection
connection.connect(function(err)
if(err)
console.log('[query]
-
:'+err);
return;

console.log('[connection
connect]
succeed!');
);
//执行SQL语句
connection.query('SELECT
1
+
1
AS
solution',
function(err,
rows,
fields)

if
(err)

console.log('[query]
-
:'+err);
return;

console.log('The
solution
is:
',
rows[0].solution);
);
//关闭connection
connection.end(function(err)
if(err)
return;

console.log('[connection
end]
succeed!');
);
注：nodejs在操作数据库的时候不用设置数据库的编码格式
set
names
utf8
希望本文所述对大家nodejs程序设计有所帮助。
您可能感兴趣的文章:nodejs连接mysql数据库简单封装示例-mysql模块nodejs进阶(6)—连接MySQL数据库示例nodejs实现的连接MySQL数据库功能示例Nodejs连接mysql并实现增、删、改、查操作的方法详解nodeJs实现基于连接池连接mysql的方法示例nodejs中操作mysql数据库示例NodeJS链接MySql数据库的操作方法Nodejs使用mysql模块之获得更新和删除影响的行数的方法NodeJs使用Mysql模块实现事务处理实例nodejs连接mysql数据库及基本知识点详解

Nodejs操作MySQL数据库

  如何用nodejs操作MySql数据呢，其实写法还是简单的，

     1.开始在你的node项目中 npm install mysql --save

     2.在你的新建项目中 引入代码

      

//引入数据库
var mysql=require(‘mysql‘);

//实现本地链接
var connection = mysql.createConnection({
    host: ‘localhost‘,
    user: ‘yf‘,
    password: ‘123456‘,
    database: ‘yf‘
})

 

   最好不好是用root 会产生冲突

 3. 之后就是增删改查啦，附上代码

       查询

 

     

// 查找
function select() {
    connection.connect(function (err) {
        if (err) {
            console.error(‘error connecting:‘ + err.stack)
        }
        console.log(‘connected as id ‘ + connection.threadId);
    })

    connection.query(‘SELECT * FROM demo‘, function (error, results, fields) {
        if (error) throw error;
        console.log(‘The solution is:‘, results);
    });
    connection.end();
}

     添加

//添加
function add() {
    let post = {
        id: 1,
        name: ‘Hello MySql‘,
        age: 20,
        time: Date.now(),
        temp: ‘deom‘
    };
    let query = connection.query("INSERT INTO demo SET ?", post, function (error, results, fields) {
        if (error) throw error;
    })
    console.log(query.sql); //INSERT INTO posts ‘id‘=1, ‘title‘=‘Hello MySQL‘
}

  修改

//修改
function updeate() {
    connection.connect(function (err) {
        if (err) {
            console.error(‘error connecting:‘ + err.stack);
        }
        console.log(‘connected as id ‘ + connection.threadId);
    });

    connection.query(‘UPDATE demo SET name=?where id?‘, [‘update‘, 1], function (error, results, fields) {
        if (error) throw error;
        console.log(‘changed:‘ + results.changeRows + ‘rows‘);
    });

    connection.end();

}

  删除

 

//删除
function deletes() {
    connection.connect(function (err) {
        if (err) {
            console.error(‘error connecting:‘ + err.stack);
            return;
        }
        connection.query(‘DELETE FROM demo SET where id=?‘, [ 1], function (error, results, fields) {
            if (error) throw error;
            console.log(‘deleted:‘ + results.affectedRows + ‘rows‘);
        });
        console.log(‘connected as id ‘ + connection.threadId);
        connection.end();

    });

}

 

  是不是很简单啊 只要在你需要的地方添加方法名和对应的参数 ，就可以了