← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/message/statement_transform.cc

  • Committer: Brian Aker
  • Date: 2011-01-13 09:25:42 UTC
  • mfrom: (2073.1.4 catalogs)
  • mto: This revision was merged to the branch mainline in revision 2080.
  • Revision ID: brian@gir-3-20110113092542-lmomnx1t0zpidzl4
Merge of current catalogs

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/message/statement_transform.cc
29
29
 * Statement messages to other formats, including SQL strings.
30
30
 */
31
31
 
32
 
#include <config.h>
 
32
#include "config.h"
33
33
 
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>
 
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"
41
41
 
42
42
#include <string>
43
43
#include <vector>
152
152
      const InsertHeader &insert_header= source.insert_header();
153
153
      const InsertData &insert_data= source.insert_data();
154
154
      size_t num_keys= insert_data.record_size();
 
155
      size_t x;
155
156
 
156
157
      if (num_keys > 1 && ! already_in_transaction)
157
158
        sql_strings.push_back("START TRANSACTION");
158
159
 
159
 
      for (size_t x= 0; x < num_keys; ++x)
 
160
      for (x= 0; x < num_keys; ++x)
160
161
      {
161
162
        string destination;
162
163
 
317
318
      sql_strings.push_back(destination);
318
319
    }
319
320
    break;
320
 
  case Statement::ALTER_SCHEMA:
321
 
    {
322
 
      assert(source.has_alter_schema_statement());
323
 
      string destination;
324
 
      error= transformAlterSchemaStatementToSql(source.alter_schema_statement(),
325
 
                                                destination,
326
 
                                                sql_variant);
327
 
      sql_strings.push_back(destination);
328
 
    }
329
 
    break;
330
321
  case Statement::SET_VARIABLE:
331
322
    {
332
323
      assert(source.has_set_variable_statement());
815
806
}
816
807
 
817
808
enum TransformSqlError
818
 
transformAlterSchemaStatementToSql(const AlterSchemaStatement &statement,
819
 
                                   string &destination,
820
 
                                   enum TransformSqlVariant sql_variant)
821
 
{
822
 
  const Schema &before= statement.before();
823
 
  const Schema &after= statement.after();
824
 
 
825
 
  /* Make sure we are given the before and after for the same object */
826
 
  if (before.uuid() != after.uuid())
827
 
    return UUID_MISMATCH;
828
 
 
829
 
  char quoted_identifier= '`';
830
 
  if (sql_variant == ANSI)
831
 
    quoted_identifier= '"';
832
 
 
833
 
  destination.append("ALTER SCHEMA ");
834
 
  destination.push_back(quoted_identifier);
835
 
  destination.append(before.name());
836
 
  destination.push_back(quoted_identifier);
837
 
 
838
 
  /*
839
 
   * Diff our schemas. Currently, only collation can change so a
840
 
   * diff of the two structures is not really necessary.
841
 
   */
842
 
  destination.append(" COLLATE = ");
843
 
  destination.append(after.collation());
844
 
 
845
 
  return NONE;
846
 
}
847
 
 
848
 
enum TransformSqlError
849
809
transformDropSchemaStatementToSql(const DropSchemaStatement &statement,
850
810
                                  string &destination,
851
811
                                  enum TransformSqlVariant sql_variant)
873
833
 
874
834
  const Schema &schema= statement.schema();
875
835
 
876
 
  destination.append("CREATE SCHEMA ");
 
836
  destination.append("CREATE SCHEMA ", 14);
877
837
  destination.push_back(quoted_identifier);
878
838
  destination.append(schema.name());
879
839
  destination.push_back(quoted_identifier);
880
840
 
881
841
  if (schema.has_collation())
882
842
  {
883
 
    destination.append(" COLLATE ");
 
843
    destination.append(" COLLATE ", 9);
884
844
    destination.append(schema.collation());
885
845
  }
886
846
 
887
 
  if (schema.has_replication_options() and schema.replication_options().has_dont_replicate() and schema.replication_options().dont_replicate())
888
 
  {
889
 
    destination.append(" REPLICATION = FALSE");
890
 
  }
891
 
 
892
847
  return NONE;
893
848
}
894
849
 
903
858
 
904
859
  const TableMetadata &table_metadata= statement.table_metadata();
905
860
 
906
 
  destination.append("DROP TABLE ");
 
861
  destination.append("DROP TABLE ", 11);
907
862
 
908
863
  /* Add the IF EXISTS clause if necessary */
909
864
  if (statement.has_if_exists_clause() &&
910
865
      statement.if_exists_clause() == true)
911
866
  {
912
 
    destination.append("IF EXISTS ");
 
867
    destination.append("IF EXISTS ", 10);
913
868
  }
914
869
 
915
870
  destination.push_back(quoted_identifier);
934
889
 
935
890
  const TableMetadata &table_metadata= statement.table_metadata();
936
891
 
937
 
  destination.append("TRUNCATE TABLE ");
 
892
  destination.append("TRUNCATE TABLE ", 15);
938
893
  destination.push_back(quoted_identifier);
939
894
  destination.append(table_metadata.schema_name());
940
895
  destination.push_back(quoted_identifier);
955
910
  const FieldMetadata &variable_metadata= statement.variable_metadata();
956
911
  bool should_quote_field_value= shouldQuoteFieldValue(variable_metadata.type());
957
912
 
958
 
  destination.append("SET GLOBAL "); /* Only global variables are replicated */
 
913
  destination.append("SET GLOBAL ", 11); /* Only global variables are replicated */
959
914
  destination.append(variable_metadata.name());
960
915
  destination.push_back('=');
961
916
 
987
942
  if (sql_variant == ANSI)
988
943
    quoted_identifier= '"';
989
944
 
990
 
  destination.append("CREATE ");
 
945
  destination.append("CREATE ", 7);
991
946
 
992
947
  if (table.type() == Table::TEMPORARY)
993
 
    destination.append("TEMPORARY ");
 
948
    destination.append("TEMPORARY ", 10);
994
949
  
995
 
  destination.append("TABLE ");
 
950
  destination.append("TABLE ", 6);
996
951
  if (with_schema)
997
952
  {
998
953
    append_escaped_string(&destination, table.schema(), quoted_identifier);
999
954
    destination.push_back('.');
1000
955
  }
1001
956
  append_escaped_string(&destination, table.name(), quoted_identifier);
1002
 
  destination.append(" (\n");
 
957
  destination.append(" (\n", 3);
1003
958
 
1004
959
  enum TransformSqlError result= NONE;
1005
960
  size_t num_fields= table.field_size();
1008
963
    const Table::Field &field= table.field(x);
1009
964
 
1010
965
    if (x != 0)
1011
 
      destination.append(",\n");
 
966
      destination.append(",\n", 2);
1012
967
 
1013
968
    destination.append("  ");
1014
969
 
1021
976
  size_t num_indexes= table.indexes_size();
1022
977
  
1023
978
  if (num_indexes > 0)
1024
 
    destination.append(",\n");
 
979
    destination.append(",\n", 2);
1025
980
 
1026
981
  for (size_t x= 0; x < num_indexes; ++x)
1027
982
  {
1028
983
    const message::Table::Index &index= table.indexes(x);
1029
984
 
1030
985
    if (x != 0)
1031
 
      destination.append(",\n");
 
986
      destination.append(",\n", 2);
1032
987
 
1033
988
    result= transformIndexDefinitionToSql(index, table, destination, sql_variant);
1034
989
    
1039
994
  size_t num_foreign_keys= table.fk_constraint_size();
1040
995
 
1041
996
  if (num_foreign_keys > 0)
1042
 
    destination.append(",\n");
 
997
    destination.append(",\n", 2);
1043
998
 
1044
999
  for (size_t x= 0; x < num_foreign_keys; ++x)
1045
1000
  {
1046
1001
    const message::Table::ForeignKeyConstraint &fkey= table.fk_constraint(x);
1047
1002
 
1048
1003
    if (x != 0)
1049
 
      destination.append(",\n");
 
1004
      destination.append(",\n", 2);
1050
1005
 
1051
1006
    result= transformForeignKeyConstraintDefinitionToSql(fkey, table, destination, sql_variant);
1052
1007
 
1054
1009
      return result;
1055
1010
  }
1056
1011
 
1057
 
  destination.append("\n)");
 
1012
  destination.append("\n)", 2);
1058
1013
 
1059
1014
  /* Add ENGINE = " clause */
1060
1015
  if (table.has_engine())
1061
1016
  {
1062
 
    destination.append(" ENGINE=");
 
1017
    destination.append(" ENGINE=", 8);
1063
1018
    destination.append(table.engine().name());
1064
1019
 
1065
1020
    size_t num_engine_options= table.engine().options_size();
1069
1024
    {
1070
1025
      const Engine::Option &option= table.engine().options(x);
1071
1026
      destination.append(option.name());
1072
 
      destination.append("='");
 
1027
      destination.append("='", 2);
1073
1028
      destination.append(option.state());
1074
 
      destination.append("'");
1075
 
      if (x != num_engine_options-1)
1076
 
      {
1077
 
        destination.append(", ");
1078
 
      }
 
1029
      destination.append("'", 1);
 
1030
      if(x != num_engine_options-1)
 
1031
        destination.append(", ", 2);
1079
1032
    }
1080
1033
  }
1081
1034
 
1095
1048
 
1096
1049
  if (options.has_comment())
1097
1050
  {
1098
 
    destination.append(" COMMENT=");
 
1051
    destination.append(" COMMENT=", 9);
1099
1052
    append_escaped_string(&destination, options.comment());
1100
1053
  }
1101
1054
 
1102
1055
  if (options.has_collation())
1103
1056
  {
1104
 
    destination.append(" COLLATE = ");
 
1057
    destination.append(" COLLATE = ", 11);
1105
1058
    destination.append(options.collation());
1106
1059
  }
1107
1060
 
1108
1061
  if (options.has_data_file_name())
1109
1062
  {
1110
 
    destination.append("\nDATA_FILE_NAME = '");
 
1063
    destination.append("\nDATA_FILE_NAME = '", 19);
1111
1064
    destination.append(options.data_file_name());
1112
1065
    destination.push_back('\'');
1113
1066
  }
1114
1067
 
1115
1068
  if (options.has_index_file_name())
1116
1069
  {
1117
 
    destination.append("\nINDEX_FILE_NAME = '");
 
1070
    destination.append("\nINDEX_FILE_NAME = '", 20);
1118
1071
    destination.append(options.index_file_name());
1119
1072
    destination.push_back('\'');
1120
1073
  }
1121
1074
 
1122
1075
  if (options.has_max_rows())
1123
1076
  {
1124
 
    destination.append("\nMAX_ROWS = ");
 
1077
    destination.append("\nMAX_ROWS = ", 12);
1125
1078
    destination.append(boost::lexical_cast<string>(options.max_rows()));
1126
1079
  }
1127
1080
 
1128
1081
  if (options.has_min_rows())
1129
1082
  {
1130
 
    destination.append("\nMIN_ROWS = ");
 
1083
    destination.append("\nMIN_ROWS = ", 12);
1131
1084
    destination.append(boost::lexical_cast<string>(options.min_rows()));
1132
1085
  }
1133
1086
 
1134
1087
  if (options.has_user_set_auto_increment_value()
1135
1088
      && options.has_auto_increment_value())
1136
1089
  {
1137
 
    destination.append(" AUTO_INCREMENT=");
 
1090
    destination.append(" AUTO_INCREMENT=", 16);
1138
1091
    destination.append(boost::lexical_cast<string>(options.auto_increment_value()));
1139
1092
  }
1140
1093
 
1141
1094
  if (options.has_avg_row_length())
1142
1095
  {
1143
 
    destination.append("\nAVG_ROW_LENGTH = ");
 
1096
    destination.append("\nAVG_ROW_LENGTH = ", 18);
1144
1097
    destination.append(boost::lexical_cast<string>(options.avg_row_length()));
1145
1098
  }
1146
1099
 
1147
 
  if (options.has_checksum() && options.checksum())
1148
 
    destination.append("\nCHECKSUM = TRUE");
1149
 
 
1150
 
  if (options.has_page_checksum() && options.page_checksum())
1151
 
    destination.append("\nPAGE_CHECKSUM = TRUE");
1152
 
 
1153
 
  if (options.has_dont_replicate() and options.dont_replicate())
1154
 
  {
1155
 
    destination.append(" REPLICATION = FALSE");
1156
 
  }
 
1100
  if (options.has_checksum() &&
 
1101
      options.checksum())
 
1102
    destination.append("\nCHECKSUM = TRUE", 16);
 
1103
  if (options.has_page_checksum() &&
 
1104
      options.page_checksum())
 
1105
    destination.append("\nPAGE_CHECKSUM = TRUE", 21);
1157
1106
 
1158
1107
  return NONE;
1159
1108
}
1171
1120
  destination.append("  ", 2);
1172
1121
 
1173
1122
  if (index.is_primary())
1174
 
    destination.append("PRIMARY ");
 
1123
    destination.append("PRIMARY ", 8);
1175
1124
  else if (index.is_unique())
1176
 
    destination.append("UNIQUE ");
 
1125
    destination.append("UNIQUE ", 7);
1177
1126
 
1178
1127
  destination.append("KEY ", 4);
1179
1128
  if (! (index.is_primary() && index.name().compare("PRIMARY")==0))
1225
1174
  case Table::Index::UNKNOWN_INDEX:
1226
1175
    break;
1227
1176
  case Table::Index::BTREE:
1228
 
    destination.append(" USING BTREE");
 
1177
    destination.append(" USING BTREE", 12);
1229
1178
    break;
1230
1179
  case Table::Index::RTREE:
1231
 
    destination.append(" USING RTREE");
 
1180
    destination.append(" USING RTREE", 12);
1232
1181
    break;
1233
1182
  case Table::Index::HASH:
1234
 
    destination.append(" USING HASH");
 
1183
    destination.append(" USING HASH", 11);
1235
1184
    break;
1236
1185
  case Table::Index::FULLTEXT:
1237
 
    destination.append(" USING FULLTEXT");
 
1186
    destination.append(" USING FULLTEXT", 15);
1238
1187
    break;
1239
1188
  }
1240
1189
 
1241
1190
  if (index.has_comment())
1242
1191
  {
1243
 
    destination.append(" COMMENT ");
 
1192
    destination.append(" COMMENT ", 9);
1244
1193
    append_escaped_string(&destination, index.comment());
1245
1194
  }
1246
1195
 
1280
1229
  if (sql_variant == ANSI)
1281
1230
    quoted_identifier= '"';
1282
1231
 
1283
 
  destination.append("  ");
 
1232
  destination.append("  ", 2);
1284
1233
 
1285
1234
  if (fkey.has_name())
1286
1235
  {
1287
 
    destination.append("CONSTRAINT ");
 
1236
    destination.append("CONSTRAINT ", 11);
1288
1237
    append_escaped_string(&destination, fkey.name(), quoted_identifier);
1289
1238
    destination.append(" ", 1);
1290
1239
  }
1291
1240
 
1292
 
  destination.append("FOREIGN KEY (");
 
1241
  destination.append("FOREIGN KEY (", 13);
1293
1242
 
1294
1243
  for (ssize_t x= 0; x < fkey.column_names_size(); ++x)
1295
1244
  {
1300
1249
                          quoted_identifier);
1301
1250
  }
1302
1251
 
1303
 
  destination.append(") REFERENCES ");
 
1252
  destination.append(") REFERENCES ", 13);
1304
1253
 
1305
1254
  append_escaped_string(&destination, fkey.references_table_name(),
1306
1255
                        quoted_identifier);
1307
 
  destination.append(" (");
 
1256
  destination.append(" (", 2);
1308
1257
 
1309
1258
  for (ssize_t x= 0; x < fkey.references_columns_size(); ++x)
1310
1259
  {
1319
1268
 
1320
1269
  if (fkey.has_update_option() and fkey.update_option() != Table::ForeignKeyConstraint::OPTION_UNDEF)
1321
1270
  {
1322
 
    destination.append(" ON UPDATE ");
 
1271
    destination.append(" ON UPDATE ", 11);
1323
1272
    transformForeignKeyOptionToSql(fkey.update_option(), destination);
1324
1273
  }
1325
1274
 
1326
1275
  if (fkey.has_delete_option() and fkey.delete_option() != Table::ForeignKeyConstraint::OPTION_UNDEF)
1327
1276
  {
1328
 
    destination.append(" ON DELETE ");
 
1277
    destination.append(" ON DELETE ", 11);
1329
1278
    transformForeignKeyOptionToSql(fkey.delete_option(), destination);
1330
1279
  }
1331
1280
 
1355
1304
  switch (field_type)
1356
1305
  {
1357
1306
    case Table::Field::DOUBLE:
1358
 
    destination.append(" DOUBLE");
 
1307
    destination.append(" DOUBLE", 7);
1359
1308
    if (field.has_numeric_options()
1360
1309
        && field.numeric_options().has_precision())
1361
1310
    {
1369
1318
    {
1370
1319
      if (field.string_options().has_collation()
1371
1320
          && field.string_options().collation().compare("binary") == 0)
1372
 
        destination.append(" VARBINARY(");
 
1321
        destination.append(" VARBINARY(", 11);
1373
1322
      else
1374
 
        destination.append(" VARCHAR(");
 
1323
        destination.append(" VARCHAR(", 9);
1375
1324
 
1376
1325
      destination.append(boost::lexical_cast<string>(field.string_options().length()));
1377
1326
      destination.append(")");
1381
1330
    {
1382
1331
      if (field.string_options().has_collation()
1383
1332
          && field.string_options().collation().compare("binary") == 0)
1384
 
        destination.append(" BLOB");
 
1333
        destination.append(" BLOB", 5);
1385
1334
      else
1386
 
        destination.append(" TEXT");
 
1335
        destination.append(" TEXT", 5);
1387
1336
    }
1388
1337
    break;
1389
1338
  case Table::Field::ENUM:
1390
1339
    {
1391
1340
      size_t num_field_values= field.enumeration_values().field_value_size();
1392
 
      destination.append(" ENUM(");
 
1341
      destination.append(" ENUM(", 6);
1393
1342
      for (size_t x= 0; x < num_field_values; ++x)
1394
1343
      {
1395
1344
        const string &type= field.enumeration_values().field_value(x);
1405
1354
      break;
1406
1355
    }
1407
1356
  case Table::Field::UUID:
1408
 
    destination.append(" UUID");
 
1357
    destination.append(" UUID", 5);
1409
1358
    break;
1410
1359
  case Table::Field::BOOLEAN:
1411
 
    destination.append(" BOOLEAN");
 
1360
    destination.append(" BOOLEAN", 8);
1412
1361
    break;
1413
1362
  case Table::Field::INTEGER:
1414
 
    destination.append(" INT");
 
1363
    destination.append(" INT", 4);
1415
1364
    break;
1416
1365
  case Table::Field::BIGINT:
1417
 
    if (field.has_constraints() and
1418
 
        field.constraints().is_unsigned())
1419
 
    {
1420
 
      destination.append(" BIGINT UNSIGNED");
1421
 
    }
1422
 
    else
1423
 
    {
1424
 
      destination.append(" BIGINT");
1425
 
    }
 
1366
    destination.append(" BIGINT", 7);
1426
1367
    break;
1427
1368
  case Table::Field::DECIMAL:
1428
1369
    {
1429
 
      destination.append(" DECIMAL(");
 
1370
      destination.append(" DECIMAL(", 9);
1430
1371
      stringstream ss;
1431
1372
      ss << field.numeric_options().precision() << ",";
1432
1373
      ss << field.numeric_options().scale() << ")";
1434
1375
    }
1435
1376
    break;
1436
1377
  case Table::Field::DATE:
1437
 
    destination.append(" DATE");
 
1378
    destination.append(" DATE", 5);
1438
1379
    break;
1439
1380
 
1440
1381
  case Table::Field::EPOCH:
1444
1385
    }
1445
1386
    else
1446
1387
    {
1447
 
      destination.append(" TIMESTAMP");
 
1388
      destination.append(" TIMESTAMP",  10);
1448
1389
    }
1449
1390
    break;
1450
1391
 
1451
1392
  case Table::Field::DATETIME:
1452
 
    destination.append(" DATETIME");
 
1393
    destination.append(" DATETIME",  9);
1453
1394
    break;
1454
1395
  case Table::Field::TIME:
1455
 
    destination.append(" TIME");
 
1396
    destination.append(" TIME",  5);
1456
1397
    break;
1457
1398
  }
1458
1399
 
 
1400
  if (field.type() == Table::Field::INTEGER || 
 
1401
      field.type() == Table::Field::BIGINT)
 
1402
  {
 
1403
    if (field.has_constraints() &&
 
1404
        field.constraints().has_is_unsigned() &&
 
1405
        field.constraints().is_unsigned())
 
1406
    {
 
1407
      destination.append(" UNSIGNED", 9);
 
1408
    }
 
1409
  }
 
1410
 
1459
1411
  if (field.type() == Table::Field::BLOB ||
1460
1412
      field.type() == Table::Field::VARCHAR)
1461
1413
  {
1462
1414
    if (field.string_options().has_collation()
1463
1415
        && field.string_options().collation().compare("binary"))
1464
1416
    {
1465
 
      destination.append(" COLLATE ");
 
1417
      destination.append(" COLLATE ", 9);
1466
1418
      destination.append(field.string_options().collation());
1467
1419
    }
1468
1420
  }
1469
1421
 
1470
 
  if (field.has_constraints() and field.constraints().is_unique())
1471
 
  {
1472
 
    destination.append(" UNIQUE");
1473
 
  }
1474
 
 
1475
1422
  if (field.has_constraints() && field.constraints().is_notnull())
1476
1423
  {
1477
 
    destination.append(" NOT NULL");
 
1424
    destination.append(" NOT NULL", 9);
1478
1425
  }
1479
1426
  else if (field.type() == Table::Field::EPOCH)
1480
1427
  {
1481
 
    destination.append(" NULL");
 
1428
    destination.append(" NULL", 5);
1482
1429
  }
1483
1430
 
1484
1431
  if (field.type() == Table::Field::INTEGER || 
1488
1435
    if (field.has_numeric_options() &&
1489
1436
        field.numeric_options().is_autoincrement())
1490
1437
    {
1491
 
      destination.append(" AUTO_INCREMENT");
 
1438
      destination.append(" AUTO_INCREMENT", 15);
1492
1439
    }
1493
1440
  }
1494
1441
 
1495
1442
  if (field.options().has_default_value())
1496
1443
  {
1497
 
    destination.append(" DEFAULT ");
 
1444
    destination.append(" DEFAULT ", 9);
1498
1445
    append_escaped_string(&destination, field.options().default_value());
1499
1446
  }
1500
1447
  else if (field.options().has_default_expression())
1501
1448
  {
1502
 
    destination.append(" DEFAULT ");
 
1449
    destination.append(" DEFAULT ", 9);
1503
1450
    destination.append(field.options().default_expression());
1504
1451
  }
1505
1452
  else if (field.options().has_default_bin_value())
1506
1453
  {
1507
1454
    const string &v= field.options().default_bin_value();
1508
1455
    if (v.length() == 0)
1509
 
    {
1510
 
      destination.append(" DEFAULT ''");
1511
 
    }
 
1456
      destination.append(" DEFAULT ''", 11);
1512
1457
    else
1513
1458
    {
1514
 
      destination.append(" DEFAULT 0x");
 
1459
      destination.append(" DEFAULT 0x", 11);
1515
1460
      for (size_t x= 0; x < v.length(); x++)
1516
1461
      {
1517
1462
        char hex[3];
1524
1469
           && field.options().default_null()
1525
1470
           && field.type() != Table::Field::BLOB)
1526
1471
  {
1527
 
    destination.append(" DEFAULT NULL");
 
1472
    destination.append(" DEFAULT NULL", 13);
1528
1473
  }
1529
1474
 
1530
1475
  if (field.has_options() && field.options().has_update_expression())
1531
1476
  {
1532
 
    destination.append(" ON UPDATE ");
 
1477
    destination.append(" ON UPDATE ", 11);
1533
1478
    destination.append(field.options().update_expression());
1534
1479
  }
1535
1480
 
1536
1481
  if (field.has_comment())
1537
1482
  {
1538
 
    destination.append(" COMMENT ");
 
1483
    destination.append(" COMMENT ", 9);
1539
1484
    append_escaped_string(&destination, field.comment(), quoted_default);
1540
1485
  }
1541
1486
  return NONE;