+ def _create_database(self, db_name):
+ return (self.execute("CREATE DATABASE `%s`" % db_name, db=self._db_con_autocommit) or False) and True
+
+ def _get_sql_field_type(self, field_type):
+ return SQL_FIELD_TYPES.get(field_type, "UNKNOW")
+
+ def _create_table(self, db_name, table_name, fields):
+ sql = "CREATE TABLE `%s`.`%s` (" % (db_name, table_name)
+
+ sql_fields = []
+ for f in fields:
+ sql_field = "%s %s" % (f['name'], self._get_sql_field_type(f['type']))
+ if f.get('size'):
+ sql_field += "(%s)" % f['size']
+ if f.get('primary'):
+ sql_field += " PRIMARY KEY"
+ if 'null' in f and not f['null']:
+ sql_field += " NOT NULL"
+ sql_fields.append(sql_field)
+ sql += ",".join(sql_fields)
+
+ sql += ")"
+
+ return (self.execute(sql, db=self._db_con_autocommit) or False) and True
+