default mysql engine: InnoDB

lib/sequelize/query-generator.js

@@ -8,7 +8,7 @@ var QueryGenerator = module.exports = {
   createTableQuery: function(tableName, attributes, options) {
     options = options || {}
 
-    var query   = "CREATE TABLE IF NOT EXISTS <%= table %> (<%= attributes%>)"
+    var query   = "CREATE TABLE IF NOT EXISTS <%= table %> (<%= attributes%>) ENGINE=<%= engine %> <%= charset %>"
       , primaryKeys = []
       , attrStr = Utils._.map(attributes, function(dataType, attr) {
           var dt = dataType
@@ -19,15 +19,17 @@ var QueryGenerator = module.exports = {
             return Utils.addTicks(attr) + " " + dt
           }
         }).join(", ")
-      , values  = {table: Utils.addTicks(tableName), attributes: attrStr}
+      , values  = {
+          table: Utils.addTicks(tableName),
+          attributes: attrStr,
+          engine: options.engine || 'InnoDB',
+          charset: (options.charset ? "DEFAULT CHARSET=" + options.charset : "")
+        }
       , pkString = primaryKeys.map(function(pk) {return Utils.addTicks(pk)}).join(", ")
 
-    if (pkString.length > 0) values.attributes += ", PRIMARY KEY (" + pkString + ")"
-    if(options.charset) query += " DEFAULT CHARSET=" + options.charset
+    if(pkString.length > 0) values.attributes += ", PRIMARY KEY (" + pkString + ")"
 
-    query += ";"
-
-    return  Utils._.template(query)(values)
+    return Utils._.template(query)(values).trim() + ";"
   },
 
   dropTableQuery: function(tableName, options) {

test/QueryGenerator/queries.js

 var assert = require("assert")
   , QueryGenerator = require("../../lib/sequelize/query-generator")
   , eql = assert.equal
-  
+
 module.exports = {
   'create table query': function() {
-    eql(QueryGenerator.createTableQuery('myTable', {title: 'VARCHAR(255)', name: 'VARCHAR(255)'}), "CREATE TABLE IF NOT EXISTS `myTable` (`title` VARCHAR(255), `name` VARCHAR(255));")
+    eql(QueryGenerator.createTableQuery('myTable', {title: 'VARCHAR(255)', name: 'VARCHAR(255)'}), "CREATE TABLE IF NOT EXISTS `myTable` (`title` VARCHAR(255), `name` VARCHAR(255)) ENGINE=InnoDB;")
+    eql(QueryGenerator.createTableQuery('myTable', {title: 'VARCHAR(255)', name: 'VARCHAR(255)'}, {engine: 'MyISAM'}), "CREATE TABLE IF NOT EXISTS `myTable` (`title` VARCHAR(255), `name` VARCHAR(255)) ENGINE=MyISAM;")
+    eql(QueryGenerator.createTableQuery('myTable', {title: 'VARCHAR(255)', name: 'VARCHAR(255)'}, {charset: 'latin1'}), "CREATE TABLE IF NOT EXISTS `myTable` (`title` VARCHAR(255), `name` VARCHAR(255)) ENGINE=InnoDB DEFAULT CHARSET=latin1;")
   },
   'drop table query': function() {
     eql(QueryGenerator.dropTableQuery('myTable'), "DROP TABLE IF EXISTS `myTable`;")
@@ -59,4 +61,4 @@ module.exports = {
     eql(QueryGenerator.deleteQuery('myTable', 1, {limit: 10}), "DELETE FROM `myTable` WHERE `id`=1 LIMIT 10")
     eql(QueryGenerator.deleteQuery('myTable', {name: "foo';DROP TABLE myTable;"}, {limit: 10}), "DELETE FROM `myTable` WHERE `name`='foo\\';DROP TABLE myTable;' LIMIT 10")
   }
-}
\ No newline at end of file
+}