HoRain云--Node.js 连接 MySQL

安装驱动本教程使用了淘宝定制的 cnpm 命令进行安装$ cnpm install mysql连接数据库在以下实例中根据你的实际配置修改数据库用户名、及密码及数据库名test.js 文件代码var mysql require(mysql); var connection mysql.createConnection({ host : localhost, user : root, password : 123456, database : test }); connection.connect(); connection.query(SELECT 1 1 AS solution, function (error, results, fields) { if (error) throw error; console.log(The solution is: , results[0].solution); });执行以下命令输出结果为$ node test.jsThe solution is: 2数据库连接参数说明参数描述host主机地址 默认localhostuser用户名password密码port端口号 默认3306database数据库名charset连接字符集默认UTF8_GENERAL_CI注意字符集的字母都要大写localAddress此IP用于TCP连接可选socketPath连接到unix域路径当使用 host 和 port 时会被忽略timezone时区默认localconnectTimeout连接超时默认不限制单位毫秒stringifyObjects是否序列化对象typeCast是否将列值转化为本地JavaScript类型值 默认truequeryFormat自定义query语句格式化方法supportBigNumbers数据库支持bigint或decimal类型列时需要设此option为true 默认falsebigNumberStringssupportBigNumbers和bigNumberStrings启用 强制bigint或decimal列以JavaScript字符串类型返回默认falsedateStrings强制timestamp,datetime,data类型以字符串类型返回而不是JavaScript Date类型默认falsedebug开启调试默认falsemultipleStatements是否许一个query中有多个MySQL语句 默认falseflags用于修改连接标志ssl使用ssl参数与crypto.createCredenitals参数格式一至或一个包含ssl配置文件名称的字符串目前只捆绑Amazon RDS的配置文件更多说明可参见GitHub - mysqljs/mysql: A pure node.js JavaScript Client implementing the MySQL protocol. · GitHub数据库操作( CURD )在进行数据库操作前你需要将本站提供的 Websites 表 SQL 文件websites.sql 导入到你的 MySQL 数据库中。本教程测试的 MySQL 用户名为 root密码为 123456数据库为 test你需要根据自己配置情况修改。查询数据将上面我们提供的 SQL 文件导入数据库后执行以下代码即可查询出数据查询数据var mysql require(mysql); var connection mysql.createConnection({ host : localhost, user : root, password : 123456, port: 3306, database: test }); connection.connect(); var sql SELECT * FROM websites; //查 connection.query(sql,function (err, result) { if(err){ console.log([SELECT ERROR] - ,err.message); return; } console.log(--------------------------SELECT----------------------------); console.log(result); console.log(------------------------------------------------------------\n\n); }); connection.end();执行以下命令输出就结果为$ node test.js --------------------------SELECT---------------------------- [ RowDataPacket { id: 1, name: Google, url: https://www.google.cm/, alexa: 1, country: USA }, RowDataPacket { id: 2, name: 淘宝, url: https://www.taobao.com/, alexa: 13, country: CN }, RowDataPacket { id: 3, name: 菜鸟教程, url: http://www.runoob.com/, alexa: 4689, country: CN }, RowDataPacket { id: 4, name: 微博, url: http://weibo.com/, alexa: 20, country: CN }, RowDataPacket { id: 5, name: Facebook, url: https://www.facebook.com/, alexa: 3, country: USA } ] ------------------------------------------------------------插入数据我们可以向数据表 websties 插入数据插入数据var mysql require(mysql); var connection mysql.createConnection({ host : localhost, user : root, password : 123456, port: 3306, database: test }); connection.connect(); var addSql INSERT INTO websites(Id,name,url,alexa,country) VALUES(0,?,?,?,?); var addSqlParams [菜鸟工具, https://c.runoob.com,23453, CN]; //增 connection.query(addSql,addSqlParams,function (err, result) { if(err){ console.log([INSERT ERROR] - ,err.message); return; } console.log(--------------------------INSERT----------------------------); //console.log(INSERT ID:,result.insertId); console.log(INSERT ID:,result); console.log(-----------------------------------------------------------------\n\n); }); connection.end();执行以下命令输出就结果为$ node test.js --------------------------INSERT---------------------------- INSERT ID: OkPacket { fieldCount: 0, affectedRows: 1, insertId: 6, serverStatus: 2, warningCount: 0, message: , protocol41: true, changedRows: 0 } -----------------------------------------------------------------执行成功后查看数据表即可以看到添加的数据更新数据我们也可以对数据库的数据进行修改更新数据var mysql require(mysql); var connection mysql.createConnection({ host : localhost, user : root, password : 123456, port: 3306, database: test }); connection.connect(); var modSql UPDATE websites SET name ?,url ? WHERE Id ?; var modSqlParams [菜鸟移动站, https://m.runoob.com,6]; //改 connection.query(modSql,modSqlParams,function (err, result) { if(err){ console.log([UPDATE ERROR] - ,err.message); return; } console.log(--------------------------UPDATE----------------------------); console.log(UPDATE affectedRows,result.affectedRows); console.log(-----------------------------------------------------------------\n\n); }); connection.end();执行以下命令输出就结果为--------------------------UPDATE---------------------------- UPDATE affectedRows 1 -----------------------------------------------------------------执行成功后查看数据表即可以看到更新的数据删除数据我们可以使用以下代码来删除 id 为 6 的数据:删除数据var mysql require(mysql); var connection mysql.createConnection({ host : localhost, user : root, password : 123456, port: 3306, database: test }); connection.connect(); var delSql DELETE FROM websites where id6; //删 connection.query(delSql,function (err, result) { if(err){ console.log([DELETE ERROR] - ,err.message); return; } console.log(--------------------------DELETE----------------------------); console.log(DELETE affectedRows,result.affectedRows); console.log(-----------------------------------------------------------------\n\n); }); connection.end();执行以下命令输出就结果为--------------------------DELETE---------------------------- DELETE affectedRows 1 -----------------------------------------------------------------执行成功后查看数据表即可以看到 id6 的数据已被删除