29
29
* Statement messages to other formats, including SQL strings.
34
34
#include <boost/lexical_cast.hpp>
35
#include "drizzled/message/statement_transform.h"
36
#include "drizzled/message/transaction.pb.h"
37
#include "drizzled/message/table.pb.h"
38
#include "drizzled/charset.h"
39
#include "drizzled/charset_info.h"
40
#include "drizzled/global_charset_info.h"
36
#include <drizzled/charset.h>
37
#include <drizzled/charset_info.h>
38
#include <drizzled/global_charset_info.h>
39
#include <drizzled/message.h>
40
#include <drizzled/message/statement_transform.h>
41
#include <drizzled/message/transaction.pb.h>
152
153
const InsertHeader &insert_header= source.insert_header();
153
154
const InsertData &insert_data= source.insert_data();
154
155
size_t num_keys= insert_data.record_size();
157
157
if (num_keys > 1 && ! already_in_transaction)
158
158
sql_strings.push_back("START TRANSACTION");
160
for (x= 0; x < num_keys; ++x)
160
for (size_t x= 0; x < num_keys; ++x)
162
162
string destination;
318
318
sql_strings.push_back(destination);
321
case Statement::ALTER_SCHEMA:
323
assert(source.has_alter_schema_statement());
325
error= transformAlterSchemaStatementToSql(source.alter_schema_statement(),
328
sql_strings.push_back(destination);
321
331
case Statement::SET_VARIABLE:
323
333
assert(source.has_set_variable_statement());
808
818
enum TransformSqlError
819
transformAlterSchemaStatementToSql(const AlterSchemaStatement &statement,
821
enum TransformSqlVariant sql_variant)
823
const Schema &before= statement.before();
824
const Schema &after= statement.after();
826
/* Make sure we are given the before and after for the same object */
827
if (before.uuid() != after.uuid())
828
return UUID_MISMATCH;
830
char quoted_identifier= '`';
831
if (sql_variant == ANSI)
832
quoted_identifier= '"';
834
destination.append("ALTER SCHEMA ");
835
destination.push_back(quoted_identifier);
836
destination.append(before.name());
837
destination.push_back(quoted_identifier);
840
* Diff our schemas. Currently, only collation can change so a
841
* diff of the two structures is not really necessary.
843
destination.append(" COLLATE = ");
844
destination.append(after.collation());
849
enum TransformSqlError
809
850
transformDropSchemaStatementToSql(const DropSchemaStatement &statement,
810
851
string &destination,
811
852
enum TransformSqlVariant sql_variant)
834
875
const Schema &schema= statement.schema();
836
destination.append("CREATE SCHEMA ", 14);
877
destination.append("CREATE SCHEMA ");
837
878
destination.push_back(quoted_identifier);
838
879
destination.append(schema.name());
839
880
destination.push_back(quoted_identifier);
841
882
if (schema.has_collation())
843
destination.append(" COLLATE ", 9);
884
destination.append(" COLLATE ");
844
885
destination.append(schema.collation());
888
if (not message::is_replicated(schema))
890
destination.append(" REPLICATE = FALSE");
859
905
const TableMetadata &table_metadata= statement.table_metadata();
861
destination.append("DROP TABLE ", 11);
907
destination.append("DROP TABLE ");
863
909
/* Add the IF EXISTS clause if necessary */
864
910
if (statement.has_if_exists_clause() &&
865
911
statement.if_exists_clause() == true)
867
destination.append("IF EXISTS ", 10);
913
destination.append("IF EXISTS ");
870
916
destination.push_back(quoted_identifier);
890
936
const TableMetadata &table_metadata= statement.table_metadata();
892
destination.append("TRUNCATE TABLE ", 15);
938
destination.append("TRUNCATE TABLE ");
893
939
destination.push_back(quoted_identifier);
894
940
destination.append(table_metadata.schema_name());
895
941
destination.push_back(quoted_identifier);
910
956
const FieldMetadata &variable_metadata= statement.variable_metadata();
911
957
bool should_quote_field_value= shouldQuoteFieldValue(variable_metadata.type());
913
destination.append("SET GLOBAL ", 11); /* Only global variables are replicated */
959
destination.append("SET GLOBAL "); /* Only global variables are replicated */
914
960
destination.append(variable_metadata.name());
915
961
destination.push_back('=');
942
988
if (sql_variant == ANSI)
943
989
quoted_identifier= '"';
945
destination.append("CREATE ", 7);
991
destination.append("CREATE ");
947
993
if (table.type() == Table::TEMPORARY)
948
destination.append("TEMPORARY ", 10);
994
destination.append("TEMPORARY ");
950
destination.append("TABLE ", 6);
996
destination.append("TABLE ");
953
999
append_escaped_string(&destination, table.schema(), quoted_identifier);
954
1000
destination.push_back('.');
956
1002
append_escaped_string(&destination, table.name(), quoted_identifier);
957
destination.append(" (\n", 3);
1003
destination.append(" (\n");
959
1005
enum TransformSqlError result= NONE;
960
1006
size_t num_fields= table.field_size();
976
1022
size_t num_indexes= table.indexes_size();
978
1024
if (num_indexes > 0)
979
destination.append(",\n", 2);
1025
destination.append(",\n");
981
1027
for (size_t x= 0; x < num_indexes; ++x)
983
1029
const message::Table::Index &index= table.indexes(x);
986
destination.append(",\n", 2);
1032
destination.append(",\n");
988
1034
result= transformIndexDefinitionToSql(index, table, destination, sql_variant);
994
1040
size_t num_foreign_keys= table.fk_constraint_size();
996
1042
if (num_foreign_keys > 0)
997
destination.append(",\n", 2);
1043
destination.append(",\n");
999
1045
for (size_t x= 0; x < num_foreign_keys; ++x)
1001
1047
const message::Table::ForeignKeyConstraint &fkey= table.fk_constraint(x);
1004
destination.append(",\n", 2);
1050
destination.append(",\n");
1006
1052
result= transformForeignKeyConstraintDefinitionToSql(fkey, table, destination, sql_variant);
1012
destination.append("\n)", 2);
1058
destination.append("\n)");
1014
1060
/* Add ENGINE = " clause */
1015
1061
if (table.has_engine())
1017
destination.append(" ENGINE=", 8);
1063
destination.append(" ENGINE=");
1018
1064
destination.append(table.engine().name());
1020
1066
size_t num_engine_options= table.engine().options_size();
1025
1071
const Engine::Option &option= table.engine().options(x);
1026
1072
destination.append(option.name());
1027
destination.append("='", 2);
1073
destination.append("='");
1028
1074
destination.append(option.state());
1029
destination.append("'", 1);
1030
if(x != num_engine_options-1)
1031
destination.append(", ", 2);
1075
destination.append("'");
1076
if (x != num_engine_options-1)
1078
destination.append(", ");
1035
1083
if (table.has_options())
1036
1084
(void) transformTableOptionsToSql(table.options(), destination, sql_variant);
1086
if (not message::is_replicated(table))
1088
destination.append(" REPLICATE = FALSE");
1049
1102
if (options.has_comment())
1051
destination.append(" COMMENT=", 9);
1104
destination.append(" COMMENT=");
1052
1105
append_escaped_string(&destination, options.comment());
1055
1108
if (options.has_collation())
1057
destination.append(" COLLATE = ", 11);
1110
destination.append(" COLLATE = ");
1058
1111
destination.append(options.collation());
1061
1114
if (options.has_data_file_name())
1063
destination.append("\nDATA_FILE_NAME = '", 19);
1116
destination.append("\nDATA_FILE_NAME = '");
1064
1117
destination.append(options.data_file_name());
1065
1118
destination.push_back('\'');
1068
1121
if (options.has_index_file_name())
1070
destination.append("\nINDEX_FILE_NAME = '", 20);
1123
destination.append("\nINDEX_FILE_NAME = '");
1071
1124
destination.append(options.index_file_name());
1072
1125
destination.push_back('\'');
1075
1128
if (options.has_max_rows())
1077
destination.append("\nMAX_ROWS = ", 12);
1130
destination.append("\nMAX_ROWS = ");
1078
1131
destination.append(boost::lexical_cast<string>(options.max_rows()));
1081
1134
if (options.has_min_rows())
1083
destination.append("\nMIN_ROWS = ", 12);
1136
destination.append("\nMIN_ROWS = ");
1084
1137
destination.append(boost::lexical_cast<string>(options.min_rows()));
1087
1140
if (options.has_user_set_auto_increment_value()
1088
1141
&& options.has_auto_increment_value())
1090
destination.append(" AUTO_INCREMENT=", 16);
1143
destination.append(" AUTO_INCREMENT=");
1091
1144
destination.append(boost::lexical_cast<string>(options.auto_increment_value()));
1094
1147
if (options.has_avg_row_length())
1096
destination.append("\nAVG_ROW_LENGTH = ", 18);
1149
destination.append("\nAVG_ROW_LENGTH = ");
1097
1150
destination.append(boost::lexical_cast<string>(options.avg_row_length()));
1100
if (options.has_checksum() &&
1102
destination.append("\nCHECKSUM = TRUE", 16);
1103
if (options.has_page_checksum() &&
1104
options.page_checksum())
1105
destination.append("\nPAGE_CHECKSUM = TRUE", 21);
1153
if (options.has_checksum() && options.checksum())
1154
destination.append("\nCHECKSUM = TRUE");
1156
if (options.has_page_checksum() && options.page_checksum())
1157
destination.append("\nPAGE_CHECKSUM = TRUE");
1120
1172
destination.append(" ", 2);
1122
1174
if (index.is_primary())
1123
destination.append("PRIMARY ", 8);
1175
destination.append("PRIMARY ");
1124
1176
else if (index.is_unique())
1125
destination.append("UNIQUE ", 7);
1177
destination.append("UNIQUE ");
1127
1179
destination.append("KEY ", 4);
1128
1180
if (! (index.is_primary() && index.name().compare("PRIMARY")==0))
1174
1226
case Table::Index::UNKNOWN_INDEX:
1176
1228
case Table::Index::BTREE:
1177
destination.append(" USING BTREE", 12);
1229
destination.append(" USING BTREE");
1179
1231
case Table::Index::RTREE:
1180
destination.append(" USING RTREE", 12);
1232
destination.append(" USING RTREE");
1182
1234
case Table::Index::HASH:
1183
destination.append(" USING HASH", 11);
1235
destination.append(" USING HASH");
1185
1237
case Table::Index::FULLTEXT:
1186
destination.append(" USING FULLTEXT", 15);
1238
destination.append(" USING FULLTEXT");
1190
1242
if (index.has_comment())
1192
destination.append(" COMMENT ", 9);
1244
destination.append(" COMMENT ");
1193
1245
append_escaped_string(&destination, index.comment());
1229
1281
if (sql_variant == ANSI)
1230
1282
quoted_identifier= '"';
1232
destination.append(" ", 2);
1284
destination.append(" ");
1234
1286
if (fkey.has_name())
1236
destination.append("CONSTRAINT ", 11);
1288
destination.append("CONSTRAINT ");
1237
1289
append_escaped_string(&destination, fkey.name(), quoted_identifier);
1238
1290
destination.append(" ", 1);
1241
destination.append("FOREIGN KEY (", 13);
1293
destination.append("FOREIGN KEY (");
1243
1295
for (ssize_t x= 0; x < fkey.column_names_size(); ++x)
1249
1301
quoted_identifier);
1252
destination.append(") REFERENCES ", 13);
1304
destination.append(") REFERENCES ");
1254
1306
append_escaped_string(&destination, fkey.references_table_name(),
1255
1307
quoted_identifier);
1256
destination.append(" (", 2);
1308
destination.append(" (");
1258
1310
for (ssize_t x= 0; x < fkey.references_columns_size(); ++x)
1269
1321
if (fkey.has_update_option() and fkey.update_option() != Table::ForeignKeyConstraint::OPTION_UNDEF)
1271
destination.append(" ON UPDATE ", 11);
1323
destination.append(" ON UPDATE ");
1272
1324
transformForeignKeyOptionToSql(fkey.update_option(), destination);
1275
1327
if (fkey.has_delete_option() and fkey.delete_option() != Table::ForeignKeyConstraint::OPTION_UNDEF)
1277
destination.append(" ON DELETE ", 11);
1329
destination.append(" ON DELETE ");
1278
1330
transformForeignKeyOptionToSql(fkey.delete_option(), destination);
1319
1371
if (field.string_options().has_collation()
1320
1372
&& field.string_options().collation().compare("binary") == 0)
1321
destination.append(" VARBINARY(", 11);
1373
destination.append(" VARBINARY(");
1323
destination.append(" VARCHAR(", 9);
1375
destination.append(" VARCHAR(");
1325
1377
destination.append(boost::lexical_cast<string>(field.string_options().length()));
1326
1378
destination.append(")");
1331
1383
if (field.string_options().has_collation()
1332
1384
&& field.string_options().collation().compare("binary") == 0)
1333
destination.append(" BLOB", 5);
1385
destination.append(" BLOB");
1335
destination.append(" TEXT", 5);
1387
destination.append(" TEXT");
1338
1390
case Table::Field::ENUM:
1340
1392
size_t num_field_values= field.enumeration_values().field_value_size();
1341
destination.append(" ENUM(", 6);
1393
destination.append(" ENUM(");
1342
1394
for (size_t x= 0; x < num_field_values; ++x)
1344
1396
const string &type= field.enumeration_values().field_value(x);
1356
1408
case Table::Field::UUID:
1357
destination.append(" UUID", 5);
1409
destination.append(" UUID");
1411
case Table::Field::BOOLEAN:
1412
destination.append(" BOOLEAN");
1359
1414
case Table::Field::INTEGER:
1360
destination.append(" INT", 4);
1415
destination.append(" INT");
1362
1417
case Table::Field::BIGINT:
1363
destination.append(" BIGINT", 7);
1418
if (field.has_constraints() and
1419
field.constraints().is_unsigned())
1421
destination.append(" BIGINT UNSIGNED");
1425
destination.append(" BIGINT");
1365
1428
case Table::Field::DECIMAL:
1367
destination.append(" DECIMAL(", 9);
1430
destination.append(" DECIMAL(");
1368
1431
stringstream ss;
1369
1432
ss << field.numeric_options().precision() << ",";
1370
1433
ss << field.numeric_options().scale() << ")";
1374
1437
case Table::Field::DATE:
1375
destination.append(" DATE", 5);
1377
case Table::Field::TIMESTAMP:
1378
destination.append(" TIMESTAMP", 10);
1438
destination.append(" DATE");
1441
case Table::Field::EPOCH:
1442
if (field.time_options().microseconds())
1444
destination.append(" TIMESTAMP(6)");
1448
destination.append(" TIMESTAMP");
1380
1452
case Table::Field::DATETIME:
1381
destination.append(" DATETIME", 9);
1385
if (field.type() == Table::Field::INTEGER ||
1386
field.type() == Table::Field::BIGINT)
1388
if (field.has_constraints() &&
1389
field.constraints().has_is_unsigned() &&
1390
field.constraints().is_unsigned())
1392
destination.append(" UNSIGNED", 9);
1453
destination.append(" DATETIME");
1455
case Table::Field::TIME:
1456
destination.append(" TIME");
1396
1460
if (field.type() == Table::Field::BLOB ||
1399
1463
if (field.string_options().has_collation()
1400
1464
&& field.string_options().collation().compare("binary"))
1402
destination.append(" COLLATE ", 9);
1466
destination.append(" COLLATE ");
1403
1467
destination.append(field.string_options().collation());
1407
if (field.has_constraints() &&
1408
! field.constraints().is_nullable())
1410
destination.append(" NOT NULL", 9);
1412
else if (field.type() == Table::Field::TIMESTAMP)
1413
destination.append(" NULL", 5);
1471
if (field.has_constraints() and field.constraints().is_unique())
1473
destination.append(" UNIQUE");
1476
if (field.has_constraints() && field.constraints().is_notnull())
1478
destination.append(" NOT NULL");
1480
else if (field.type() == Table::Field::EPOCH)
1482
destination.append(" NULL");
1415
1485
if (field.type() == Table::Field::INTEGER ||
1416
1486
field.type() == Table::Field::BIGINT)
1419
1489
if (field.has_numeric_options() &&
1420
1490
field.numeric_options().is_autoincrement())
1422
destination.append(" AUTO_INCREMENT", 15);
1492
destination.append(" AUTO_INCREMENT");
1426
1496
if (field.options().has_default_value())
1428
destination.append(" DEFAULT ", 9);
1498
destination.append(" DEFAULT ");
1429
1499
append_escaped_string(&destination, field.options().default_value());
1431
1501
else if (field.options().has_default_expression())
1433
destination.append(" DEFAULT ", 9);
1503
destination.append(" DEFAULT ");
1434
1504
destination.append(field.options().default_expression());
1436
1506
else if (field.options().has_default_bin_value())
1438
1508
const string &v= field.options().default_bin_value();
1439
1509
if (v.length() == 0)
1440
destination.append(" DEFAULT ''", 11);
1511
destination.append(" DEFAULT ''");
1443
destination.append(" DEFAULT 0x", 11);
1515
destination.append(" DEFAULT 0x");
1444
1516
for (size_t x= 0; x < v.length(); x++)
1453
1525
&& field.options().default_null()
1454
1526
&& field.type() != Table::Field::BLOB)
1456
destination.append(" DEFAULT NULL", 13);
1528
destination.append(" DEFAULT NULL");
1459
1531
if (field.has_options() && field.options().has_update_expression())
1461
destination.append(" ON UPDATE ", 11);
1533
destination.append(" ON UPDATE ");
1462
1534
destination.append(field.options().update_expression());
1465
1537
if (field.has_comment())
1467
destination.append(" COMMENT ", 9);
1539
destination.append(" COMMENT ");
1468
1540
append_escaped_string(&destination, field.comment(), quoted_default);
1494
1566
case DRIZZLE_TYPE_NULL:
1495
1567
assert(false); /* Not a user definable type */
1496
1568
return Table::Field::INTEGER; /* unreachable */
1569
case DRIZZLE_TYPE_MICROTIME:
1497
1570
case DRIZZLE_TYPE_TIMESTAMP:
1498
return Table::Field::TIMESTAMP;
1571
return Table::Field::EPOCH;
1499
1572
case DRIZZLE_TYPE_LONGLONG:
1500
1573
return Table::Field::BIGINT;
1501
1574
case DRIZZLE_TYPE_DATETIME:
1502
1575
return Table::Field::DATETIME;
1576
case DRIZZLE_TYPE_TIME:
1577
return Table::Field::TIME;
1503
1578
case DRIZZLE_TYPE_DATE:
1504
1579
return Table::Field::DATE;
1505
1580
case DRIZZLE_TYPE_VARCHAR: