이 코드가 데이터베이스에 둘 이상의 행을 삽입하는 이유는 무엇입니까?

Question

데이터베이스의 Product to Product 테이블을 추가하는이 코드는 있지만 둘 이상의 행을 추가하는 코드입니다. 위의 코드에서 볼 수 있듯이 제품이 다음 확인으로 삽입 테이블에 존재하지 않는 경우, 내가 확인하고 있습니다

public int addProduct(Products product, String supplierName) { 

    //find a product 
    String checkAllProducts = "SELECT * FROM products WHERE product_name = ?"; 

    //Insert product and supplier id where supplier exist in suppliers table sql statement 
    String insertSql = "INSERT INTO products (product_name, product_type, supplier_id, number_of_stocks, price_per_unit, packaging_type) SELECT ?,?,suppliers.supplier_id,?,?,? FROM suppliers WHERE suppliers.supplier_name = ?"; 

    //Get connection 
    Connection conn = DbUtil.getConnection(); 

    //Resultset for checking existing products 
    ResultSet resultSet = null; 

    int inserted = 0; 

    try { 

     //Prepare check all products statement 
     allProducts = conn.prepareStatement(checkAllProducts); 
     allProducts.setString(1, product.getProductName()); 
     resultSet = allProducts.executeQuery(); 

     //If doesn't exist in products table 
     if (!resultSet.next()) { 
      //Prepare insert statement 
      addProduct = conn.prepareStatement(insertSql); 
      //Get product parameter's data 
      addProduct.setString(1, product.getProductName()); 
      addProduct.setString(2, product.getProductType()); 
      addProduct.setInt(3, product.getNumberOfStocks()); 
      addProduct.setBigDecimal(4, product.getPricePerUnit()); 
      addProduct.setString(5, product.getPackagingType()); 
      addProduct.setString(6, supplierName); 

      //Confirm insert 
      int confirmation = JOptionPane.showConfirmDialog(null, "Are you sure you want to insert this product?", "Insert Confirm", JOptionPane.YES_NO_OPTION, JOptionPane.WARNING_MESSAGE); 
      if (confirmation == JOptionPane.YES_OPTION) { 
       //execute insert 
       inserted = addProduct.executeUpdate(); 
      } 

     }//Else don't insert and show error messages. 
     else { 
      JOptionPane.showMessageDialog(null, "Product already exists.", "Invalid insert.", JOptionPane.ERROR_MESSAGE); 
     } 

    } catch (SQLException ex) { 
     Logger.getLogger(ProductDAO.class.getName()).log(Level.SEVERE, null, ex); 
    } finally { 
     DbUtil.close(conn, allProducts, resultSet); 
     DbUtil.close(conn, addProduct, resultSet); 
    } 

    return inserted; 
} 

:

여기에 코드입니다. 성공적으로 추가 중이지만 둘 이상의 행이 추가됩니다. 예를 들어, productDao 객체를 초기화했고이 방법으로 테스트했습니다 : productDAO.addProduct(new Products("Hotdogs", "Full", 55, new BigDecimal(0.30), "Box"), "Wing Yip");. 그렇게 한 후 아래의 이미지 링크에서 볼 수있는 것처럼 14 개의 이미지가 삽입되었습니다. 이런 일이 왜

14 Duplicate Rows

는 아는 사람 있나요? 제게 고마워요.

Answer 1

당신의 삽입 성명의 두 번째 부분은 select 문입니다. 분명히 공급 업체에는 14 개의 제품이 있으므로 삽입되는 새 레코드 수는 얼마입니까?

이 문제를 해결하려면 암시적인 JOIN을 제거하십시오. supplier_id 조회에는 필요하지 않습니다.

INSERT INTO products (
    product_name, 
    product_type, 
    supplier_id, 
    number_of_stocks, 
    price_per_unit, 
    packaging_type 
) SELECT 
    ?, ?, 
    suppliers.supplier_id, 
    ?, ?, ? 
FROM suppliers 
WHERE suppliers.supplier_name = ? 

Answer 2

@ Skary Wombat 및 @ 4castle에게 도움을 주신 데 감사드립니다. 지금 내가 한 것은 별도의 구문을 작성하고 아래에서 볼 수있는 것처럼 더 많은 코드를 추가 한 것입니다.

//find supplier 
String checkSupplierQuery = "SELECT products.supplier_id FROM products, suppliers WHERE products.supplier_id = suppliers.supplier_id AND suppliers.supplier_name = ? "; 

//Prepare check supplier statement 
PreparedStatement checkSupplier = conn.prepareStatement(checkSupplierQuery); 
checkSupplier.setString(1, supplierName); 
resultSet = checkSupplier.executeQuery(); 

String supplier = ""; 
while (resultSet.next()) { 
    supplier = resultSet.getString("products.supplier_id"); 
} 

이

내 문제를 해결하지만 난 예상대로 작동하지 않았다 INSERT INTO SELECT 문을 시도하고있다. 나를 도운 사람들에게 다시 한번 감사드립니다.

SELECT 
    ?, ?, 
    suppliers.supplier_id, 
    ?, ?, ? 
FROM products, suppliers 
WHERE 
    products.supplier_id = suppliers.supplier_id 
    AND suppliers.supplier_name = ? 

이 그 업체의 이름을 모두 테이블에 나타나는 모든 레코드를 선택 할 수있는 기능이 있습니다 :-)