如何利用这个 MySQL javascript 代码创建数据库/编写查询

Question

刚开始学习使用 nodejs 和 javascript 来制作一些基本的服务器和数据库来查看，我们有这个代码可以使用：

var mysql = require('mysql');

var connection = mysql.createConnection(
    {
      host     : 'stusql.dcs.shef.ac.uk',
      port     : '3306',
      user     : 'USERNAME',
      password : '********',
      database : 'DBNAME'
    }
);
connection.connect();
var query = connection.query('SELECT * FROM device');

query.on('error', function(err) {
    throw err;
});

query.on('fields', function(fields) {
    console.log(fields);
});

query.on('result', function(row) {
    console.log(row);
});
connection.end();

因此，我们现在应该将我们的登录名和密码放入这段代码中（我已经在我的版本中这样做了），然后创建一个小型数据库并编写一个查询。这部分怎么做？

我是否去主机以及如何使用此代码创建一个小型数据库并编写查询...没有解释，我在 webstorm IDE 上运行了此代码，它运行但不久后它抛出错误从代码。任何帮助将不胜感激！

Answer 1

虽然您可以执行所有您想要的查询，但我认为不需要动态创建数据库或表。 我只将connection.query() 用于CRUD Operations。

但您仍然可以这样做。请参阅代码。

我添加了setTimeout()，以便您在运行代码时可以清楚地看到它发生了什么。

var mysql = require('mysql');
var config={
      host     : 'localhost',
      port     : '3306',
      user     : 'root',
      password : 'root',
    }
var connection = mysql.createConnection();
connection.connect(config);
connection.query('drop database if exists mydb',function(err){
  if(err)
    return console.log(err);
  console.log('deleted db');

  setTimeout(function(){
    connection.query('create database if not exists mydb',function(err){
      if(err)
        return console.log(err);
      console.log('DB Created successfully');

      setTimeout(function(){
        var qstring='CREATE TABLE mydb.table1 '+
        '(id INT NOT NULL,name VARCHAR(45)'+
        ' NULL,PRIMARY KEY (id));'
        connection.query(qstring,function(err){
          if(err)
            return console.log(err);
          console.log('table created successfully');

          setTimeout(function(){
            var qstring="INSERT INTO mydb.table1 (`id`, `name`) VALUES ('1', 'abc'),('2', 'bcd'),('3','cde')"
            connection.query(qstring,function(err){
              if(err)
                return console.log(err);
              console.log('Rows added successfully');

              setTimeout(function(){
                var query = connection.query('SELECT * FROM mydb.table1');

                query.on('error', function(err) {
                  throw err;
                });

                query.on('fields', function(fields) {
                  console.log(fields);
                });

                query.on('result', function(row) {
                  console.log(row);
                });
              },2000);
            });
          },2000);
        });
      },2000);
    })
  },2000);
});

所以我想这就是你想要的。