1

谁能告诉为什么以下更新查询在直接从我的 SQLYog 编辑器执行时可以正常工作，但不能从 java 执行。它没有给出任何例外，但没有更新到数据库中。

这是更新查询

UPDATE hotel_tables SET hotel_tables.status='reserved' WHERE hotel_tables.section='pub' AND tableno='4' AND ('4' NOT IN (SELECT tableno FROM table_orders WHERE outlet='pub'))

Java 代码

public static void main(String[] args) throws Exception {
    int update = new Dbhandler().update("UPDATE hotel_tables SET hotel_tables.status='reserved' WHERE hotel_tables.section='pub' AND tableno='4' AND ('4' NOT IN (SELECT tableno FROM table_orders WHERE outlet='pub'))");
}

public int update(String Query)throws Exception
{
    try
    {
        cn=getconn();
        stmt=(Statement) cn.createStatement();
        n=stmt.executeUpdate(Query);
        stmt.close();
    }
    catch(Exception e)
    {
        e.printStackTrace();
        throw(e);
    }
    finally
    {
        cn.close();
    }
    return n;
}

public Connection getconn()
{
    try
    {
        Class.forName(driver).newInstance();
        String url="jdbc:mysql://localhost/kot?user=root&password=root";
        cn=(Connection) DriverManager.getConnection(url);
    }
    catch(Exception e)
    {
        System.out.println("DBHandler ERROR:"+e);
    }
    return cn;
}
4

2 回答 2

0

这就是我在切换到 Spring 的 JdbcTemplate 框架之前的做法。也许这会有所帮助。它看起来和你的很相似。

public static int runUpdate(String query, DataSource ds, Object... params) throws SQLException  {
    int rowsAffected = 0;
    Connection conn = null;
    PreparedStatement stmt = null;
    try {
        conn = ds.getConnection();
        stmt = conn.prepareStatement(query);
        int paramCount = 1;
        for (Object param : params) {
            stmt.setObject(paramCount++, param);
        }
        rowsAffected = stmt.executeUpdate();
        conn.commit();
    } catch (SQLException sqle) {
        throw sqle;
        //log error
    } finally {
        closeConnections(conn, stmt, null);
    }
    return rowsAffected;
}

有一些细微的差别。我做了一个提交，尽管 autoCommit 是默认设置。

于 2013-10-29T14:19:30.943 回答
0

像这样尝试： DriverManager.getConnection("jdbc:mysql://localhost:3306/kot","root","root");

于 2013-10-31T10:06:03.700 回答