diff --git a/source/orm/query/query_compiler.cpp b/source/orm/query/query_compiler.cpp
index 6bf74fd..064cef7 100644
--- a/source/orm/query/query_compiler.cpp
+++ b/source/orm/query/query_compiler.cpp
@@ -342,8 +342,8 @@ void query_compiler::visit(internal::query_create_table_constraints_part& part)
 }
 
 void query_compiler::visit( internal::query_create_schema_part& part ) {
-  query_.sql += " " + dialect_->create() + " " +
-    dialect_->schema() + " " + dialect_->prepare_identifier_string(part.schema());
+  query_.command = sql::sql_command::SQL_CREATE_SCHEMA;
+  query_.sql += " " + dialect_->schema() + " " + dialect_->prepare_identifier_string(part.schema());
 }
 
 void query_compiler::visit(internal::query_drop_part &part) {