如何在mysql中編寫單個查詢以進行多個數據操作？

Question

我必須從jsp表單插入值到數據庫表和我需要插入2個不同表中的兩列的值相同的表。

下面是代碼：

public class ForgotPassWordDAO { 

    private DataSource dataSource; 

    public void setDataSource(DataSource dataSource) { 
     this.dataSource = dataSource; 
    } 

    Connection conn = null; 
    PreparedStatement ps = null; 
    ResultSet rs = null; 

    public void createSecretQnA(ForgotPassWord forgotPassWord) { 
     String sql = "INSERT INTO forgotpassword (PwdId,SecretQuestion1,SecretAnswer1,SecretQuestion2,SecretAnswer2)VALUES(?,?,?,?,?)"; // Here am inserting form values to database. 
     String sql1="INSERT INTO forgotpassword (CustId) SELECT CustId FROM signup";// Here am trying to get value from another table and insert 
     String sql2="INSERT INTO forgotpassword (LoginId) SELECT LoginId FROM login"; // Here am trying to get value from another table and insert 
     Connection conn = null; 

     try { 
      conn = dataSource.createConnection(); 
      PreparedStatement ps = conn.prepareStatement(sql); 
      PreparedStatement ps1 = conn.prepareStatement(sql1); 
      PreparedStatement ps2 = conn.prepareStatement(sql2); 
      ps.setInt(1, forgotPassWord.getId()); 
      ps.setString(2, forgotPassWord.getSq1()); 
      ps.setString(3, forgotPassWord.getAnSq1()); 
      ps.setString(4, forgotPassWord.getSq2()); 
      ps.setString(5, forgotPassWord.getAnSq2()); 
      ps.executeUpdate(); 
      ps1.executeUpdate(); 
      ps2.executeUpdate(); 
      ps.close(); 

     } catch (SQLException e) { 
      throw new RuntimeException(e); 

     } 

     catch (NullPointerException e1){ 

     } 
     finally { 
      if (conn != null) { 
       try { 
        conn.close(); 
       } catch (SQLException e) { 
       } 
      } 
     } 

    } 

但是每個的executeUpdate（）其遞增，並從表格中的值被存儲在一行和下一行中從註冊和登錄表中的值越來越存儲。如何使所有這些被存儲在一行中？任何幫助表示讚賞。

Answer 1

您正在做3次插入，因此至少創建了3行。另外，當你做SELECT CustId FROM signup時，如何確保CustId只有一個和正確的值取自signup表？通過這個查詢，您可以獲取所有CustId。表格和查詢同樣適用於login。

如果只是解決你的問題，你必須創建一個查詢：

String sql = "INSERT INTO forgotpassword (PwdId,SecretQuestion1,SecretAnswer1,SecretQuestion2,SecretAnswer2,CustId,LoginId)VALUES(?,?,?,?,?,(SELECT CustId FROM signup),(SELECT LoginId FROM login))"; 
                               ^ ^        ^      ^

，但我不認爲你有想過這還不夠。

應該是這樣的：

SELECT LoginId FROM login WHERE CustId=? //Here I'm guessing, I don't know your tables. 

關鍵是要得到正確的值都在login表和對應於誰忘記了密碼的用戶signup表。這可以通過WHERE子句輕鬆完成（假設您的外鍵已正確設置）。

---

編輯

按照您的評論我要澄清，你應該添加新用戶的方式。

首先，您需要創建新用戶，因此只要發送並檢查了所需信息，您就會在signup表中插入新行。但是請等待執行查詢。您需要CustId。因爲是一個自動增量列，所以你不知道MySQL創建了哪個值。你必須把它拿來當你創建新的用戶加入一個參數來準備的語句就可以直接做到這一點：

PreparedStatement pstmt = conn.prepareStatement(sqlForNewUser, Statement.RETURN_GENERATED_KEYS); 
pstmt.executeUpdate(); 
ResultSet keys = pstmt.getGeneratedKeys();  
keys.next(); 
custId = keys.getInt(1); 

現在你有新的用戶ID，並可以用它來插入其他值：

String sql = "INSERT INTO forgotpassword (PwdId,SecretQuestion1,SecretAnswer1,SecretQuestion2,SecretAnswer2,CustId,LoginId)VALUES(?,?,?,?,?,(SELECT CustId FROM signup WHERE CustId = ?),(SELECT LoginId FROM login WHERE CustId = ?))"; 
//... 
ps.setString(6, custId); 
ps.setString(7, custId);