Node.js MySQL数据库创建

Nodejs  —mysql数据库创建



var mysql = require('mysql');


var con = mysql.createConnection({

  host: "localhost",

  user: "yourusername",

  password: "yourpassword"

});


con.connect(function(err) {

  if (err) throw err;

  console.log("Connected!");

  con.query("CREATE DATABASE mydb", function (err, result) {

    if (err) throw err;

    console.log("mysql date created successed");

  });

});

保存创建数据库文件demo_node_mysql_create.js

然后运行

npm demo_node_mysql_create.js

显示结果

mysql date created successed

主键创建表时，还应该为每个记录创建一个具有唯一键的列。 这可以通过定义一个列为“INT AUTO_INCREMENT PRIMARY KEY”来完成，这将为每个记录插入一个唯一的编号。 从1开始，每个记录增加1



var mysql = require('mysql');


var con = mysql.createConnection({

  host: "localhost",

  user: "yourusername",

  password: "yourpassword",

  database: "mydb"

});


con.connect(function(err) {

  if (err) throw err;

  console.log("Connected!");

  var sql = "CREATE TABLE customers (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), address VARCHAR(255))";

  con.query(sql, function (err, result) {

    if (err) throw err;

    console.log("Table created");

  });

});

如果表已经存在，则使用ALTER TABLE关键字：



var mysql = require('mysql');


var con = mysql.createConnection({

  host: "localhost",

  user: "yourusername",

  password: "yourpassword",

  database: "mydb"

});


con.connect(function(err) {

  if (err) throw err;

  console.log("Connected!");

  var sql = "ALTER TABLE customers ADD COLUMN id INT AUTO_INCREMENT PRIMARY KEY";

  con.query(sql, function (err, result) {

    if (err) throw err;

    console.log("Table altered");

  });

});

插入表中 要在MySQL中填充表，请使用“INSERT INTO”语句。



var mysql = require('mysql');


var con = mysql.createConnection({

  host: "localhost",

  user: "yourusername",

  password: "yourpassword",

  database: "mydb"

});


con.connect(function(err) {

  if (err) throw err;

  console.log("Connected!");

  var sql = "INSERT INTO customers (name, address) VALUES ('Company Inc', 'Highway 37')";

  con.query(sql, function (err, result) {

    if (err) throw err;

    console.log("1 record inserted");

  });

});

insert多数据



var mysql = require('mysql');


var con = mysql.createConnection({

  host: "localhost",

  user: "yourusername",

  password: "yourpassword",

  database: "mydb"

});


con.connect(function(err) {

  if (err) throw err;

  console.log("Connected!");

  var sql = "INSERT INTO customers (name, address) VALUES ?";

  var values = [

    ['John', 'Highway 71'],

    ['Peter', 'Lowstreet 4'],

    ['Amy', 'Apple st 652'],

    ['Hannah', 'Mountain 21'],

    ['Michael', 'Valley 345'],

    ['Sandy', 'Ocean blvd 2'],

    ['Betty', 'Green Grass 1'],

    ['Richard', 'Sky st 331'],

    ['Susan', 'One way 98'],

    ['Vicky', 'Yellow Garden 2'],

    ['Ben', 'Park Lane 38'],

    ['William', 'Central st 954'],

    ['Chuck', 'Main Road 989'],

    ['Viola', 'Sideway 1633']

  ];

  con.query(sql, [values], function (err, result) {

    if (err) throw err;

    console.log("Number of records inserted: " + result.affectedRows);

  });

});

结果对象 执行查询时，返回一个结果对象。 结果对象包含有关查询如何影响表的信息。 从上面的例子返回的结果对象如下所示：



{

  fieldCount: 0,

  affectedRows: 14,

  insertId: 0,

  serverStatus: 2,

  warningCount: 0,

  message: '\'Records:14  Duplicated: 0  Warnings: 0',

  protocol41: true,

  changedRows: 0

}

获取插入的ID 对于具有自动递增标识字段的表，可以通过询问结果对象来获取刚刚插入的行的标识。 注意：为了能够获得插入的id，只能插入一行。



var mysql = require('mysql');


var con = mysql.createConnection({

  host: "localhost",

  user: "yourusername",

  password: "yourpassword",

  database: "mydb"

});


con.connect(function(err) {

  if (err) throw err;

  var sql = "INSERT INTO customers (name, address) VALUES ('Michelle', 'Blue Village 1')";

  con.query(sql, function (err, result) {

    if (err) throw err;

    console.log("1 record inserted, ID: " + result.insertId);

  });

});

Run example »

从表中选择 要从MySQL中的表中选择数据，请使用“SELECT”语句。



var mysql = require('mysql');


var con = mysql.createConnection({

  host: "localhost",

  user: "yourusername",

  password: "yourpassword",

  database: "mydb"

});


con.connect(function(err) {

  if (err) throw err;

  con.query("SELECT * FROM customers", function (err, result, fields) {

    if (err) throw err;

    console.log(result);

  });

});

选择Colums 要仅选择表中的某些列，请使用“SELECT”语句和列名



var mysql = require('mysql');


var con = mysql.createConnection({

  host: "localhost",

  user: "yourusername",

  password: "yourpassword",

  database: "mydb"

});


con.connect(function(err) {

  if (err) throw err;

  con.query("SELECT name, address FROM customers", function (err, result, fields) {

    if (err) throw err;

    console.log(result);

  });

});

结果对象 从上面的例子的结果可以看出，结果对象是一个包含每行作为对象的数组。 要返回例如第三条记录的地址，只需引用第三个数组对象的地址属性即可：



console.log(result[2].address);

结果


Apple st 652

字段对象 回调函数的第三个参数是一个包含结果中每个字段信息的数组。


var mysql = require('mysql');


var con = mysql.createConnection({

  host: "localhost",

  user: "yourusername",

  password: "yourpassword",

  database: "mydb"

});


con.connect(function(err) {

  if (err) throw err;

  con.query("SELECT name, address FROM customers", function (err, result, fields) {

    if (err) throw err;

    console.log(fields);

  });

});

运行结果


[

  {

    catalog: 'def',

    db: 'mydb',

    table: 'customers',

    orgTable: 'customers',

    name: 'name',

    orgName: 'address',

    charsetNr: 33,

    length: 765,

    type: 253,

    flags: 0,

    decimals: 0,

    default: undefined,

    zeroFill: false,

    protocol41: true

  },

  }

    catalog: 'def',

    db: 'mydb',

    table: 'customers',

    orgTable: 'customers',

    name: 'address',

    orgName: 'address',

    charsetNr: 33,

    length: 765,

    type: 253,

    flags: 0,

    decimals: 0,

    default: undefined,

    zeroFill: false,

    protocol41: true

  {

]

从上面的例子可以看出，fields对象是一个包含每个字段作为对象的信息的数组。 要返回例如第二个字段的名称，只需引用第二个数组项的名称属性即可：
运行


console.log(fields[1].name);

结果


address

选择一个过滤器 从表中选择记录时，可以使用“WHERE”语句筛选选择项：


var mysql = require('mysql');


var con = mysql.createConnection({

  host: "localhost",

  user: "yourusername",

  password: "yourpassword",

  database: "mydb"

});


con.connect(function(err) {

  if (err) throw err;

  con.query("SELECT * FROM customers WHERE address = 'Park Lane 38'", function (err, result) {

    if (err) throw err;

    console.log(result);

  });

});

运行文件结果


[

  { id: 11, name: 'Ben', address: 'Park Lane 38'}

]

通配符 您也可以选择开始，包含或以给定字母或词组结尾的记录。 使用’％’通配符表示零个，一个或多个字符： 下面以通配符s作为查询条件


var mysql = require('mysql');


var con = mysql.createConnection({

  host: "localhost",

  user: "yourusername",

  password: "yourpassword",

  database: "mydb"

});


con.connect(function(err) {

  if (err) throw err;

  con.query("SELECT * FROM customers WHERE address LIKE 'S%'", function (err, result) {

    if (err) throw err;

    console.log(result);

  });

结果


[

  { id: 8, name: 'Richard', address: 'Sky st 331'},

  { id: 14, name: 'Viola', address: 'Sideway 1633'}

]

转义查询值当查询值是用户提供的变量时，您应该转义值。 这是为了防止SQL注入，这是一种常见的网络黑客技术来破坏或滥用您的数据库。 MySQL模块具有转义查询值的方法：
通过使用mysql.escape（）方法转义查询值：



var adr = 'Mountain 21';

var sql = 'SELECT * FROM customers WHERE address = ' + mysql.escape(adr);

con.query(sql, function (err, result) {

  if (err) throw err;

  console.log(result);

});

你也可以用一个？作为您想要转义的值的占位符。 在这种情况下，变量作为query（）方法中的第二个参数发送：



var adr = 'Mountain 21';

var sql = 'SELECT * FROM customers WHERE address = ?';

con.query(sql, [adr], function (err, result) {

  if (err) throw err;

  console.log(result);

});

如果您有多个占位符，则该数组按以下顺序包含多个值：


var name = 'Amy';

var adr = 'Mountain 21';

var sql = 'SELECT * FROM customers WHERE name = ? OR address = ?';

con.query(sql, [name, adr], function (err, result) {

  if (err) throw err;

  console.log(result);

});

zh-CN Chinese (Simplified)▼
X
ar Arabiczh-CN Chinese (Simplified)zh-TW Chinese (Traditional)nl Dutchen Englishfr Frenchde Germanel Greekit Italianpt Portugueseru Russianes Spanishth Thai