create_table.c 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147
  1. /**********************************************************
  2. * MODULE: mysql
  3. * AUTHOR(S): Radim Blazek (radim.blazek@gmail.com)
  4. * PURPOSE: MySQL database driver
  5. * COPYRIGHT: (C) 2001 by the GRASS Development Team
  6. * This program is free software under the
  7. * GNU General Public License (>=v2).
  8. * Read the file COPYING that comes with GRASS
  9. * for details.
  10. **********************************************************/
  11. #include <grass/gis.h>
  12. #include <grass/dbmi.h>
  13. #include <grass/glocale.h>
  14. #include "globals.h"
  15. #include "proto.h"
  16. int db__driver_create_table(dbTable * table)
  17. {
  18. int col, ncols;
  19. dbColumn *column;
  20. const char *colname;
  21. int sqltype;
  22. char buf[500];
  23. dbString sql;
  24. /* dbConnection conn_par; */
  25. G_debug(3, "db__driver_create_table()");
  26. db_init_string(&sql);
  27. db_set_string(&sql, "CREATE TABLE ");
  28. db_append_string(&sql, db_get_table_name(table));
  29. db_append_string(&sql, " ( ");
  30. ncols = db_get_table_number_of_columns(table);
  31. for (col = 0; col < ncols; col++) {
  32. column = db_get_table_column(table, col);
  33. colname = db_get_column_name(column);
  34. sqltype = db_get_column_sqltype(column);
  35. G_debug(3, "%s (%s)", colname, db_sqltype_name(sqltype));
  36. if (col > 0)
  37. db_append_string(&sql, ", ");
  38. db_append_string(&sql, colname);
  39. db_append_string(&sql, " ");
  40. switch (sqltype) {
  41. case DB_SQL_TYPE_SMALLINT:
  42. db_append_string(&sql, "SMALLINT");
  43. break;
  44. case DB_SQL_TYPE_INTEGER:
  45. db_append_string(&sql, "INT");
  46. break;
  47. case DB_SQL_TYPE_REAL:
  48. db_append_string(&sql, "FLOAT");
  49. break;
  50. /* TODO: better numeric types */
  51. case DB_SQL_TYPE_DOUBLE_PRECISION:
  52. case DB_SQL_TYPE_DECIMAL:
  53. case DB_SQL_TYPE_NUMERIC:
  54. case DB_SQL_TYPE_INTERVAL:
  55. db_append_string(&sql, "DOUBLE");
  56. break;
  57. /* GRASS does not distinguish TIMESTAMP and DATETIME */
  58. /*
  59. case DB_SQL_TYPE_DATETIME|DB_DATETIME_MASK:
  60. db_append_string ( &sql, "DATETIME");
  61. break;
  62. */
  63. case DB_SQL_TYPE_TIMESTAMP:
  64. /* db_append_string ( &sql, "TIMESTAMP"); */
  65. db_append_string(&sql, "DATETIME");
  66. break;
  67. case DB_SQL_TYPE_DATE:
  68. db_append_string(&sql, "DATE");
  69. break;
  70. case DB_SQL_TYPE_TIME:
  71. db_append_string(&sql, "TIME");
  72. break;
  73. case DB_SQL_TYPE_CHARACTER:
  74. sprintf(buf, "VARCHAR(%d)", db_get_column_length(column));
  75. db_append_string(&sql, buf);
  76. break;
  77. case DB_SQL_TYPE_TEXT:
  78. db_append_string(&sql, "TEXT");
  79. break;
  80. default:
  81. G_warning("Unknown column type (%s)", colname);
  82. return DB_FAILED;
  83. }
  84. }
  85. db_append_string(&sql, " )");
  86. G_debug(3, " SQL: %s", db_get_string(&sql));
  87. if (mysql_query(connection, db_get_string(&sql)) != 0) {
  88. db_d_append_error("%s\n%s\%s",
  89. _("Unable to create table:"),
  90. db_get_string(&sql),
  91. mysql_error(connection));
  92. db_d_report_error();
  93. db_free_string(&sql);
  94. return DB_FAILED;
  95. }
  96. /* Grant privileges */
  97. /*
  98. * 1) MySQL does not support user groups but it is possible
  99. * to specify list of users.
  100. * 2) Only root can grant privileges.
  101. */
  102. /*
  103. db_get_connection(&conn_par);
  104. if ( conn_par.group )
  105. {
  106. db_set_string ( &sql, "GRANT SELECT ON on " );
  107. db_append_string ( &sql, db_get_table_name ( table ) );
  108. db_append_string ( &sql, " TO " );
  109. db_append_string ( &sql, conn_par.group );
  110. G_debug (3, " SQL: %s", db_get_string(&sql) );
  111. if ( mysql_query ( connection, db_get_string(&sql) ) != 0 )
  112. {
  113. G_warning ( "Cannot grant select on table: \n%s\n%s",
  114. db_get_string(&sql), mysql_error(connection) );
  115. }
  116. }
  117. */
  118. db_free_string(&sql);
  119. return DB_OK;
  120. }