在一条语句中用java执行多个查询

5m1hhzi4  于 2021-06-19  发布在  Mysql
关注(0)|答案(6)|浏览(303)

嗨,我想知道是否有可能使用jdbc执行类似的操作,因为它目前提供了一个异常,即使在mysql查询浏览器中也是可能的。

"SELECT FROM * TABLE;INSERT INTO TABLE;"

虽然我确实意识到将sql查询字符串拆分并将语句执行两次是可能的,但是我想知道是否有一种一次性的方法来实现这一点。

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

wxclj1h51#

可以使用批更新,但查询必须是操作(即插入、更新和删除)查询

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

wgxvkvu92#

你为什么不试着写一封信呢 Stored Procedure 为了这个?
你可以得到 Result Set 内外兼修 Stored Procedure 你可以 Insert 你想要什么。
唯一的问题是您可能无法在 Result Set 如果你 Insert 之后 Select .

cnwbcb6i

cnwbcb6i3#

我想知道是否有可能使用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
byqmnocz

byqmnocz4#

根据我的测试,正确的标志是“allowmultiqueries=true”

dddzy1tm

dddzy1tm5#

我认为这是多选择/更新/插入/删除的最简单方法。在使用executeupdate(str)(只需使用new int(count1,count2,…))选择之后,您可以根据需要运行任意多个update/insert/delete(您必须首先进行选择(如果需要,可以使用伪选择)),如果您需要新的选择,请关闭“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);
    }

希望对你有帮助

km0tfn4u

km0tfn4u6#

提示:如果您有多个连接属性,请使用以下分隔:

&amp;

给你这样的东西:

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

我希望这对别人有帮助。
当做,
格林

相关问题