2016-10-17 3 views
0

Я пытаюсь выполнить запрос создания с помощью JDBC. У меня есть метод, который создает запрос, а затем я выполняю его, но он показывает мне синтаксическую ошибку. Ниже трассировки стека:JDBC: создать синтаксическую ошибку запроса таблицы

com.mysql.jdbc.exceptions.MySQLSyntaxErrorException: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'supplierId varchar,supplierUrl varchar,totalActivities varchar,activityName varc' at line 1 
at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:936) 
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:2941) 
at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:1623) 
at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:1715) 
at com.mysql.jdbc.Connection.execSQL(Connection.java:3243) 
at com.mysql.jdbc.Statement.executeUpdate(Statement.java:1343) 
at com.mysql.jdbc.Statement.executeUpdate(Statement.java:1260) 

Теперь запрос генерируется это:

create table demo (ID INTEGER PRIMARY KEY AUTO_INCREMENT,supplierName varchar,supplierId varchar,supplierUrl varchar,totalActivities varchar,activityName varchar,activityPrice varchar,tourCode varchar,starRating varchar,totalReviews varchar,geography varchar,duration varchar,category varchar,subCategory varchar); 

И ниже метод, который генерирует этот запрос:

private static String getCreateTableQuery(String tableName, String columnData) { 
    StringBuilder sqlStatement = new StringBuilder(""); 

    sqlStatement.append("create table " + tableName + " (ID INTEGER PRIMARY KEY AUTO_INCREMENT,"); 

    String[] columns = columnData.split(">"); // columns are separated by > 
    for (int i = 0; i < columns.length; i++) { 
     sqlStatement.append(columns[i] + " varchar"); 
     if (i != columns.length - 1) { // no commas after last column 
      sqlStatement.append(","); 
     } 
    } 
    sqlStatement.append(");"); 
    return sqlStatement.toString(); 
} 

И это, как я Выполнение запроса:

SessionImpl sessionImpl = (SessionImpl) getSessionFactory().openSession(); 
    Connection conn = (Connection) sessionImpl.connection(); 

    Statement statement = (Statement) conn.createStatement(); 
    statement.executeUpdate(query); 
    sessionImpl.close(); 
    conn.close(); 

Не удается понять синтаксическую ошибку. Может кто-нибудь объяснить?

+1

Я почти положительный varchar требует аргумента f или его максимальная длина: 'varchar (20)', например. – yshavit

+0

да. Это сработало. –

ответ

0

Я думаю, вы должны проход максимальная длина для VARCHAR полей:

Пожалуйста, проверьте этот запрос будет так:

create table demo (ID INTEGER PRIMARY KEY AUTO_INCREMENT,supplierName varchar(255),supplierId varchar(255),supplierUrl varchar(255),totalActivities varchar(255),activityName varchar(255),activityPrice varchar(255),tourCode varchar(255),starRating varchar(255),totalReviews varchar(255),geography varchar(255),duration varchar(255),category varchar(255),subCategory varchar(255)); 

Вот вставки запроса:

insert into demo 
    (supplierName, supplierId, supplierUrl, totalActivities, activityName, 
    activityPrice, tourCode, starRating, totalReviews, geography, duration, 
    category, subCategory) 
    values 
    (supplierName, supplierId, supplierUrl, totalActivities, activityName, 
    activityPrice, tourCode, starRating, totalReviews, geography, duration, 
    category, subCategory) 
+0

Да. Это сработало. Каким будет запрос INSERT для этой таблицы? –

+0

@roger_that, если он работает, этот ответ –

+0

@roger_that см. Отредактированный ответ –

0

В Mysql вам нужно определить длину для varchar. Посмотрите здесь:

Why does VARCHAR need length specification?

Я не вижу проблемы с кодом Java. Исправьте оператор create table, и вы, вероятно, будете в порядке.

+0

Yup. Это решило проблему. –

Смежные вопросы