在单语句中在java中执行多个查询

您好，我想知道是否有可能使用JDBC执行这样的事情，因为它目前提供了一个例外，即使它可能在MySQL查询浏览器。

"SELECT FROM * TABLE;INSERT INTO TABLE;" 

虽然我意识到有可能与SQL查询string被拆分和语句执行两次，但我想知道是否有一个一次性的方法。

  String url = "jdbc:mysql://localhost:3306/"; String dbName = "databaseinjection"; String driver = "com.mysql.jdbc.Driver"; String sqlUsername = "root"; String sqlPassword = "abc"; Class.forName(driver).newInstance(); connection = DriverManager.getConnection(url+dbName, sqlUsername, sqlPassword); 

Answer 1

我想知道是否有可能使用JDBC执行这样的事情。

 "SELECT FROM * TABLE;INSERT INTO TABLE;" 

是的，这是可能的。 据我所知，有两种方法。 他们是

1. 通过将数据库连接属性设置为允许多个查询，默认情况下用分号分隔。
2. 通过调用隐式返回游标的存储过程。

以下示例说明了上述两种可能性。

示例1 :(允许多个查询）：

在发送连接请求时，您需要将连接属性allowMultiQueries=true附加到数据库url。 这是额外的连接属性，如果已经存在一些，如autoReConnect=true等autoReConnect=true属性的可接受值是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 ：遵循的步骤：

1. 用一个或多个select和DML查询创build一个过程。
2. 使用CallableStatement从java调用它。
3. 您可以捕获在过程中执行的多个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 

Answer 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(); 

Answer 3

提示：如果您有多个连接属性，请使用以下命令分隔它们：

 & 

给你像这样的东西：

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

我希望这有助于一个人。

问候，

格林

Answer 4

根据我的testing，正确的标志是“allowMultiQueries = true”

Answer 5

为什么不尝试写一个Stored Procedure呢？

你可以得到Result Set ，并在相同的Stored Procedure你可以Insert你想要的。

如果在Select之后插入，唯一的可能是您不能在Result Set获取新插入的行。

Answer 6

我认为这是多选/更新/插入/删除的最简单的方法。 你可以运行尽可能多的更新/插入/删除，因为你想在select（你必须首先做一个select（如果需要的话是一个虚拟的））与executeUpdate（str）（只需使用新的int（count1，count2，…））如果你需要一个新的selectclosures“声明”和“连接”，并为下一次select新的。 比如：

 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); } 

我希望它有帮助