Несколько запросов, выполняемых в java в одном выражении

Ответ 1

Мне было интересно, можно ли выполнить что-то подобное с помощью JDBC.

"SELECT FROM * TABLE;INSERT INTO TABLE;"

Да, это возможно. Насколько я знаю, есть два способа. Они

• Установив свойство подключения к базе данных, чтобы разрешить несколько запросов, разделенных точкой с запятой по умолчанию.
• Вызов хранимой процедуры, которая возвращает курсоры неявно.

В следующих примерах показаны две вышеупомянутые возможности.

Пример 1: (Чтобы разрешить несколько запросов):

При отправке запроса на подключение вам необходимо добавить свойство подключения allowMultiQueries=true к URL-адресу базы данных. Это дополнительное свойство соединения для тех, которые уже существуют, например, autoReConnect=true и т.д. Допустимыми значениями для свойства allowMultiQueries являются true, false, yes и no. Любое другое значение отклоняется во время выполнения с помощью SQLException.

String dbUrl = "jdbc:mysql:///test?allowMultiQueries=true";  

Если такая инструкция не передана, бросается SQLException.

Вы должны использовать execute( String sql ) или другие варианты для получения результатов выполнения запроса.

boolean hasMoreResultSets = stmt.execute( multiQuerySqlString );

Для повторения и обработки результатов вам требуются следующие шаги:

READING_QUERY_RESULTS: // label  
    while ( hasMoreResultSets || stmt.getUpdateCount() != -1 ) {  
        if ( hasMoreResultSets ) {  
            Resultset rs = stmt.getResultSet();
            // handle your rs here
        } // if has rs
        else { // if ddl/dml/...
            int queryResult = stmt.getUpdateCount();  
            if ( queryResult == -1 ) { // no more queries processed  
                break READING_QUERY_RESULTS;  
            } // no more queries processed  
            // handle success, failure, generated keys, etc here
        } // if ddl/dml/...

        // check to continue in the loop  
        hasMoreResultSets = stmt.getMoreResults();  
    } // while results

Пример 2: шаги для выполнения:

• Создайте процедуру с одним или несколькими запросами select и DML.
• Вызовите его из java с помощью CallableStatement.
• Вы можете захватить несколько ResultSet, выполненных в процедуре.
  Результаты DML не могут быть захвачены, но могут выдавать еще один select
  чтобы найти, как строки затронуты в таблице.

Пример таблицы и процедуры:

mysql> create table tbl_mq( i int not null auto_increment, name varchar(10), primary key (i) );
Query OK, 0 rows affected (0.16 sec)

mysql> delimiter //
mysql> create procedure multi_query()
    -> begin
    ->  select count(*) as name_count from tbl_mq;
    ->  insert into tbl_mq( names ) values ( 'ravi' );
    ->  select last_insert_id();
    ->  select * from tbl_mq;
    -> end;
    -> //
Query OK, 0 rows affected (0.02 sec)
mysql> delimiter ;
mysql> call multi_query();
+------------+
| name_count |
+------------+
|          0 |
+------------+
1 row in set (0.00 sec)

+------------------+
| last_insert_id() |
+------------------+
|                3 |
+------------------+
1 row in set (0.00 sec)

+---+------+
| i | name |
+---+------+
| 1 | ravi |
+---+------+
1 row in set (0.00 sec)

Query OK, 0 rows affected (0.00 sec)

Процедура вызова с Java:

CallableStatement cstmt = con.prepareCall( "call multi_query()" );  
boolean hasMoreResultSets = cstmt.execute();  
READING_QUERY_RESULTS:  
    while ( hasMoreResultSets ) {  
        Resultset rs = stmt.getResultSet();
        // handle your rs here
    } // while has more rs

Ответ 2

Вы можете использовать пакетное обновление, но запросы должны быть действительными (т.е. вставлять, обновлять и удалять) запросы

Statement s = c.createStatement();
String s1 = "update emp set name='abc' where salary=984";
String s2 = "insert into emp values ('Osama',1420)";  
s.addBatch(s1);
s.addBatch(s2);     
s.executeBatch();

Ответ 3

Подсказка. Если у вас есть несколько свойств соединения, разделите их следующим образом:

&

Чтобы дать вам что-нибудь вроде:

url="jdbc:mysql://localhost/glyndwr?autoReconnect=true&allowMultiQueries=true"

Надеюсь, это поможет кому-то.

Привет,

Глин

Ответ 4

Основываясь на моем тестировании, правильным флагом является "allowMultiQueries = true"

Ответ 5

Почему вы не пытаетесь написать Stored Procedure для этого?

Вы можете получить Result Set и в том же Stored Procedure вы можете Insert, что хотите.

Единственное, что вы могли бы не получить вновь вставленные строки в Result Set, если вы Insert после Select.

Ответ 6

Я думаю, что это самый простой способ для множественного выбора/обновления/вставки/удаления. Вы можете запустить столько обновлений/вставки/удаления, сколько захотите после выбора (вам нужно сделать выбор сначала (при необходимости фиктивный)) с executeUpdate (str) (просто используйте новый int (count1, count2,...)) и если вам нужен новый выбор, закройте 'statement' и 'connection' и сделайте новый для следующего выбора. Пример:

String str1 = "select * from users";
String str9 = "INSERT INTO `port`(device_id, potition, port_type, di_p_pt) VALUE ('"+value1+"', '"+value2+"', '"+value3+"', '"+value4+"')";
String str2 = "Select port_id from port where device_id = '"+value1+"' and potition = '"+value2+"' and port_type = '"+value3+"' ";
try{  
    Class.forName("com.mysql.jdbc.Driver").newInstance();
    theConnection=(Connection) DriverManager.getConnection(dbURL,dbuser,dbpassword);  
    theStatement = theConnection.prepareStatement(str1);
    ResultSet theResult = theStatement.executeQuery();
    int count8 = theStatement.executeUpdate(str9);
    theStatement.close();
    theConnection.close();
    theConnection=DriverManager.getConnection(dbURL,dbuser,dbpassword);
    theStatement = theConnection.prepareStatement(str2);
    theResult = theStatement.executeQuery();

    ArrayList<Port> portList = new ArrayList<Port>();
    while (theResult.next()) {
        Port port = new Port();
        port.setPort_id(theResult.getInt("port_id"));

        portList.add(port);
    }

Я надеюсь, что это поможет