create_table.c 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149
  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. init_error();
  27. db_init_string(&sql);
  28. db_set_string(&sql, "CREATE TABLE ");
  29. db_append_string(&sql, db_get_table_name(table));
  30. db_append_string(&sql, " ( ");
  31. ncols = db_get_table_number_of_columns(table);
  32. for (col = 0; col < ncols; col++) {
  33. column = db_get_table_column(table, col);
  34. colname = db_get_column_name(column);
  35. sqltype = db_get_column_sqltype(column);
  36. G_debug(3, "%s (%s)", colname, db_sqltype_name(sqltype));
  37. if (col > 0)
  38. db_append_string(&sql, ", ");
  39. db_append_string(&sql, colname);
  40. db_append_string(&sql, " ");
  41. switch (sqltype) {
  42. case DB_SQL_TYPE_SMALLINT:
  43. db_append_string(&sql, "SMALLINT");
  44. break;
  45. case DB_SQL_TYPE_INTEGER:
  46. db_append_string(&sql, "INT");
  47. break;
  48. case DB_SQL_TYPE_REAL:
  49. db_append_string(&sql, "FLOAT");
  50. break;
  51. /* TODO: better numeric types */
  52. case DB_SQL_TYPE_DOUBLE_PRECISION:
  53. case DB_SQL_TYPE_DECIMAL:
  54. case DB_SQL_TYPE_NUMERIC:
  55. case DB_SQL_TYPE_INTERVAL:
  56. db_append_string(&sql, "DOUBLE");
  57. break;
  58. /* GRASS does not distinguish TIMESTAMP and DATETIME */
  59. /*
  60. case DB_SQL_TYPE_DATETIME|DB_DATETIME_MASK:
  61. db_append_string ( &sql, "DATETIME");
  62. break;
  63. */
  64. case DB_SQL_TYPE_TIMESTAMP:
  65. /* db_append_string ( &sql, "TIMESTAMP"); */
  66. db_append_string(&sql, "DATETIME");
  67. break;
  68. case DB_SQL_TYPE_DATE:
  69. db_append_string(&sql, "DATE");
  70. break;
  71. case DB_SQL_TYPE_TIME:
  72. db_append_string(&sql, "TIME");
  73. break;
  74. case DB_SQL_TYPE_CHARACTER:
  75. sprintf(buf, "VARCHAR(%d)", db_get_column_length(column));
  76. db_append_string(&sql, buf);
  77. break;
  78. case DB_SQL_TYPE_TEXT:
  79. db_append_string(&sql, "TEXT");
  80. break;
  81. default:
  82. G_warning("Unknown column type (%s)", colname);
  83. return DB_FAILED;
  84. }
  85. }
  86. db_append_string(&sql, " )");
  87. G_debug(3, " SQL: %s", db_get_string(&sql));
  88. if (mysql_query(connection, db_get_string(&sql)) != 0) {
  89. append_error("Cannot create table:\n");
  90. append_error(db_get_string(&sql));
  91. append_error("\n");
  92. append_error(mysql_error(connection));
  93. report_error();
  94. db_free_string(&sql);
  95. return DB_FAILED;
  96. }
  97. /* Grant privileges */
  98. /*
  99. * 1) MySQL does not support user groups but it is possible
  100. * to specify list of users.
  101. * 2) Only root can grant privileges.
  102. */
  103. /*
  104. db_get_connection(&conn_par);
  105. if ( conn_par.group )
  106. {
  107. db_set_string ( &sql, "GRANT SELECT ON on " );
  108. db_append_string ( &sql, db_get_table_name ( table ) );
  109. db_append_string ( &sql, " TO " );
  110. db_append_string ( &sql, conn_par.group );
  111. G_debug (3, " SQL: %s", db_get_string(&sql) );
  112. if ( mysql_query ( connection, db_get_string(&sql) ) != 0 )
  113. {
  114. G_warning ( "Cannot grant select on table: \n%s\n%s",
  115. db_get_string(&sql), mysql_error(connection) );
  116. }
  117. }
  118. */
  119. db_free_string(&sql);
  120. return DB_OK;
  121. }