NodeJS与Mysql的交互示例代码

  把Mysql Module装到NodeJS中

  Js代码

  

复制代码 代码如下:

  $npm install Mysql

  JS脚本 mysqlTest.js

  Js代码

  

复制代码 代码如下:

  // mysqlTest.js

  //加载mysql Module

  var Client = require('mysql').Client,

  client = new Client(),

  

    //要创建的数据库名

  TEST_DATABASE = 'nodejs_mysql_test',

  //要创建的表名

  TEST_TABLE = 'test';

  //用户名

  client.user = 'root';

  //密码

  client.password = 'root';

  //创建连接

  client.connect();

  client.query('CREATE DATABASE '+TEST_DATABASE, function(err) {

  if (err && err.number != Client.ERROR_DB_CREATE_EXISTS) {

  throw err;

  }

  });

  // If no callback is provided, any errors will be emitted as `'error'`

  // events by the client

  client.query('USE '+TEST_DATABASE);

  client.query(

  'CREATE TABLE '+TEST_TABLE+

  '(id INT(11) AUTO_INCREMENT, '+

  'title VARCHAR(255), '+

  'text TEXT, '+

  'created DATETIME, '+

  'PRIMARY KEY (id))'

  );

  client.query(

  'INSERT INTO '+TEST_TABLE+' '+

  'SET title = ?, text = ?, created = ?',

  ['super cool', 'this is a nice text', '2010-08-16 10:00:23']

  );

  var query = client.query(

  'INSERT INTO '+TEST_TABLE+' '+

  'SET title = ?, text = ?, created = ?',

  ['another entry', 'because 2 entries make a better test', '2010-08-16 12:42:15']

  );

  client.query(

  'SELECT * FROM '+TEST_TABLE,

  function selectCb(err, results, fields) {

  if (err) {

  throw err;

  }

  console.log(results);

  console.log(fields);

  client.end();

  }

  );

  执行脚本

  Js代码

  

复制代码 代码如下:

  root@sammor-desktop:/var/iapps/nodejs/work# node mysqlTest.js

NodeJS与Mysql的交互示例代码