Как создавать процедуры MySQL из кода Java при первом запуске программного обеспечения (настройка процедур базы данных) - PullRequest
Новая
       31

Как создавать процедуры MySQL из кода Java при первом запуске программного обеспечения (настройка процедур базы данных)

0 голосов
/ 08 июля 2019

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

Я пытался выполнить запрос к хранимой процедуре при первом запуске приложения.Хотя код MySQL для создания процедуры является правильным, Java выдает ошибку, говорящую
java.sql.BatchUpdateException: в синтаксисе SQL есть ошибка;проверьте руководство, соответствующее вашей версии сервера MySQL, на предмет правильного синтаксиса для использования рядом с «DELIMITER // CREATE PROCEDURE update_registered_fields (IN _field VARCHAR (200))» в строке 1 Если я выполняю тот же запрос в веб-представлении MySQL, он запускаетсяотлично.

Я не показал здесь соединение с базой данных, так как оно работает нормально.И я использовал файл functions.xml, чтобы получить запрос для кода.

DatabaseHandler.java 

private static void inflateProcedure() throws SQLException, FileNotFoundException, ParserConfigurationException, SAXException, IOException{
    Set<String> set = new HashSet<>();
    List<String> procedureData = new ArrayList<>();
    String query = "SHOW PROCEDURE STATUS WHERE Db = '"+Preferences.getPreferences().getDatabaseName()+"';";
    System.out.println(query);
    stmnt = con.createStatement();
    ResultSet rs = stmnt.executeQuery(query);
    while(rs.next()){
        set.add(rs.getString("NAME").toLowerCase());
    }
    System.out.println("Already Loaded Procedures "+set);
    DocumentBuilderFactory dbFactory = DocumentBuilderFactory.newInstance();
    DocumentBuilder dBuilder = dbFactory.newDocumentBuilder();
    Document doc = dBuilder.parse(new FileInputStream(Preferences.getPreferences().getLocation()+"procedures.xml"));
    NodeList nList = doc.getElementsByTagName("table-entry");
    for (int i = 0; i < nList.getLength(); i++) {
        Node nNode = nList.item(i);
        Element entry = (Element) nNode;
        String procedureName = entry.getAttribute("name");
        String params = entry.getAttribute("params");
        String procedureQuery = entry.getAttribute("data");
        if (!set.contains(procedureName.toLowerCase())) {
            procedureData.add(String.format("DELIMITER // CREATE PROCEDURE %s %s \n"
                    + "BEGIN;\n"
                    + " %s \n"
                    + "END //\n DELIMITER ", procedureName, params, procedureQuery));
        }
    }
    if (procedureData.isEmpty()) {
        System.out.println("Procedures are already loaded");
    }
    else {
        System.out.println("Inflating new Procedures.");
        createProcedures(procedureData);
    }
}

private static void createProcedures(List<String> procedureData) throws SQLException{
    Statement statement = con.createStatement();
    for (String command : procedureData) {
        System.out.println(command);
        statement.addBatch(command);
    }
    statement.executeBatch();
    statement.close();
}

rules.xml 

<procedures>
<table-entry name="update_registered_fields" params="(IN _field VARCHAR(200))" data="DECLARE _value INT DEFAULT 0;

    SET _value := (SELECT `user_register_feilds`.`last_used` FROM `user_register_feilds` WHERE `user_register_feilds`.`name` = _field);
    UPDATE `user_register_feilds` SET `user_register_feilds`.`last_used` = _value+1 WHERE `user_register_feilds`.`name` = _field;"/>

<table-entry name="sort_fields" params="(IN _value INT(50))" data="SELECT * FROM user_enquiry ORDER BY last_used DESC, id ASC LIMIT _value;"/>

Я хочу выполнить этот запрос.Я даже попробовал allowMultiQueries.Я также хочу знать, является ли это правильным способом заполнения базы данных при первом запуске приложения.

1 Ответ

0 голосов
/ 12 июля 2019

Вы, кажется, использовали разделители в своем sql-запросе, который пытаетесь запустить в JDBC, что видно из вашего сообщения об ошибке: java.sql.BatchUpdateException: 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 'DELIMITER // CREATE PROCEDURE update_registered_fields (IN _field VARCHAR(200))' at line 1.

Попробуйте удалить разделители.Разделители используются в raw sql.JDBC не нуждается в разделителях.

...