Added backticks to mysql driver

Author: Jeff Kunkle

lib/driver/mysql.js

@@ -47,6 +47,7 @@ var MysqlDriver = Base.extend({
   },
 
   createColumnDef: function(name, spec, options) {
+    name = util.format('`%s`', name);
     var t = this.mapDataType(spec);
     var len;
     if(spec.type !== type.TEXT && spec.type !== type.BLOB) {
@@ -97,13 +98,106 @@ var MysqlDriver = Base.extend({
     return constraint.join(' ');
   },
 
+  createTable: function(tableName, options, callback) {
+    log.verbose('creating table:', tableName);
+    var columnSpecs = options;
+    var tableOptions = {};
+
+    if (options.columns !== undefined) {
+      columnSpecs = options.columns;
+      delete options.columns;
+      tableOptions = options;
+    }
+
+    var ifNotExistsSql = "";
+    if(tableOptions.ifNotExists) {
+      ifNotExistsSql = "IF NOT EXISTS";
+    }
+
+    var primaryKeyColumns = [];
+    var columnDefOptions = {
+      emitPrimaryKey: false
+    };
+
+    for (var columnName in columnSpecs) {
+      var columnSpec = this.normalizeColumnSpec(columnSpecs[columnName]);
+      columnSpecs[columnName] = columnSpec;
+      if (columnSpec.primaryKey) {
+        primaryKeyColumns.push(columnName);
+      }
+    }
+
+    var pkSql = '';
+    if (primaryKeyColumns.length > 1) {
+      pkSql = util.format(', PRIMARY KEY (`%s`)', primaryKeyColumns.join('`, `'));
+    } else {
+      columnDefOptions.emitPrimaryKey = true;
+    }
+
+    var columnDefs = [];
+    for (var columnName in columnSpecs) {
+      var columnSpec = columnSpecs[columnName];
+      columnDefs.push(this.createColumnDef(columnName, columnSpec, columnDefOptions));
+    }
+
+    var sql = util.format('CREATE TABLE %s `%s` (%s%s)', ifNotExistsSql, tableName, columnDefs.join(', '), pkSql);
+    this.runSql(sql, callback);
+  },
+
   renameTable: function(tableName, newTableName, callback) {
-    var sql = util.format('RENAME TABLE %s TO %s', tableName, newTableName);
+    var sql = util.format('RENAME TABLE `%s` TO `%s`', tableName, newTableName);
+    this.runSql(sql, callback);
+  },
+
+  addColumn: function(tableName, columnName, columnSpec, callback) {
+    var def = this.createColumnDef(columnName, this.normalizeColumnSpec(columnSpec));
+    var sql = util.format('ALTER TABLE `%s` ADD COLUMN %s', tableName, def);
     this.runSql(sql, callback);
   },
 
   removeColumn: function(tableName, columnName, callback) {
-    var sql = util.format('ALTER TABLE %s DROP COLUMN %s', tableName, columnName);
+    var sql = util.format('ALTER TABLE `%s` DROP COLUMN `%s`', tableName, columnName);
+    this.runSql(sql, callback);
+  },
+
+  addIndex: function(tableName, indexName, columns, unique, callback) {
+    if (typeof(unique) === 'function') {
+      callback = unique;
+      unique = false;
+    }
+
+    if (!Array.isArray(columns)) {
+      columns = [columns];
+    }
+    var sql = util.format('CREATE %s INDEX `%s` ON `%s` (`%s`)', (unique ? 'UNIQUE' : ''), indexName, tableName, columns.join('`, `'));
+    this.runSql(sql, callback);
+  },
+
+  insert: function(tableName, columnNameArray, valueArray, callback) {
+    if (columnNameArray.length !== valueArray.length) {
+      return callback(new Error('The number of columns does not match the number of values.'));
+    }
+
+    var sql = util.format('INSERT INTO `%s` ', tableName);
+    var columnNames = '(';
+    var values = 'VALUES (';
+
+    for (var index in columnNameArray) {
+      columnNames += '`' + columnNameArray[index] + '`';
+
+      if (typeof(valueArray[index]) === 'string') {
+        values += "'" + valueArray[index].replace("'", "''") + "'";
+      } else {
+        values += valueArray[index];
+      }
+
+      if (index != columnNameArray.length - 1) {
+        columnNames += ",";
+        values +=  ",";
+      }
+    }
+
+    sql += columnNames + ') '+ values + ');';
     this.runSql(sql, callback);
   },
 
@@ -118,28 +212,28 @@ var MysqlDriver = Base.extend({
       return;
     }
 
-    var sql = util.format('DROP INDEX %s ON %s', indexName, tableName);
+    var sql = util.format('DROP INDEX `%s` ON `%s`', indexName, tableName);
     this.runSql(sql, callback);
   },
 
   renameColumn: function(tableName, oldColumnName, newColumnName, callback) {
     var self = this, columnTypeSql = util.format("SELECT COLUMN_TYPE FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME = '%s' AND COLUMN_NAME = '%s'", tableName, oldColumnName);
     this.all(columnTypeSql, function(err, result) {
       var columnType = result[0].COLUMN_TYPE;
-      var alterSql = util.format("ALTER TABLE %s CHANGE %s %s %s", tableName, oldColumnName, newColumnName, columnType);
+      var alterSql = util.format("ALTER TABLE `%s` CHANGE `%s` `%s` %s", tableName, oldColumnName, newColumnName, columnType);
       self.runSql(alterSql, callback);
     });
   },
 
   changeColumn: function(tableName, columnName, columnSpec, callback) {
     var constraint = this.createColumnDef(columnName, columnSpec);
-    var sql = util.format('ALTER TABLE %s CHANGE COLUMN %s %s', tableName, columnName, constraint);
+    var sql = util.format('ALTER TABLE `%s` CHANGE COLUMN `%s` %s', tableName, columnName, constraint);
     this.runSql(sql, callback);
   },
 
   addMigrationRecord: function (name, callback) {
     var formattedDate = moment(new Date()).format('YYYY-MM-DD HH:mm:ss');
-    this.runSql('INSERT INTO migrations (name, run_on) VALUES (?, ?)', [name, formattedDate], callback);
+    this.runSql('INSERT INTO migrations (`name`, `run_on`) VALUES (?, ?)', [name, formattedDate], callback);
   },
 
   runSql: function() {