在插入之前检查数据库中的重复项

我需要在插入表之前检查数据库中是否存在记录。我有两个表，一个是我插入数据和一个引用主表的日志表。在这个日志表中我有ID，date_import和file_import。所以我想检查一下file_import是否已经存在。在插入之前检查数据库中的重复项

这里是我从零开始的代码：

//DATE 
     DateFormat dateF = new SimpleDateFormat("dd.MM.yyyy"); 
     Date date = new Date(); 
//DATE   

//DB INIT 
     String URL = "jdbc:mysql://192.168.1.128:3306"; 
     Connection con = (Connection) DriverManager.getConnection(URL,user,pass); 
     Statement stmt = (Statement) con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE); 
     Statement stmt1 = (Statement) con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE); 
     String mySQL_log = ("CREATE TABLE IF NOT EXISTS dbtest.T_AJPES_TR_LOG" 
      + "(ID INT unsigned PRIMARY KEY AUTO_INCREMENT, Date_import VARCHAR(45)," 
      + "File_import VARCHAR(75)) ENGINE = INNODB"); 
     String mySQL_new_table = ("CREATE TABLE IF NOT EXISTS dbtest.T_AJPES_TR " 
      + "(row_count INT PRIMARY KEY AUTO_INCREMENT," 
      + "rn CHAR(15),sSpre CHAR(5),reg CHAR(5),eno VARCHAR(10),davcna VARCHAR(15),Ime VARCHAR(75)," 
      + "Priimek VARCHAR(75),ID_LOG INT unsigned," 
      + "CONSTRAINT FOREIGN KEY(ID_LOG) references T_AJPES_TR_LOG(ID) ON DELETE CASCADE ON UPDATE CASCADE) ENGINE = INNODB"); 

     stmt1.executeUpdate(mySQL_log); 
     ResultSet uprs1 = stmt1.executeQuery("SELECT * FROM dbtest.T_AJPES_TR_LOG"); 
     stmt.executeUpdate(mySQL_new_table); 
     ResultSet uprs = stmt.executeQuery("SELECT * FROM dbtest.T_AJPES_TR"); 
//SELECT INIT 

//READ FILE   
     File folder = new File(readFolder); 
     String[] fileName = folder.list(); 

     for (;k<fileName.length;k++) { 
      name = fileName[k]; 
      if (name.contains(".xml")) { 
      FileInputStream fstream = new FileInputStream(readFolder + name); 
      DataInputStream in = new DataInputStream(fstream); 
      BufferedReader br = new BufferedReader(new InputStreamReader(in)); 
//READ FILE 
      uprs.next(); 
      file_exists = uprs1.getString("File_import"); 

      if (!file_exists.equals(name)) { 
       uprs1.afterLast(); 
       uprs1.moveToInsertRow(); 
       uprs1.updateString("Date_import",dateF.format(date)); 
       uprs1.updateString("File_import",name); 
       uprs1.insertRow(); 
       i=0;

来源

2010-12-01 Igor

看起来您所发布的代码不完整。 – Ralph 2010-12-01 09:23:03

是什么问题？ – 2010-12-01 09:23:54

为什么不定义一个列作为一个唯一的键，所以数据库将自己管理呢？如果在该键列中具有相同值的记录已经存在，它将拒绝插入任何记录 – duduamar 2010-12-01 09:25:51

我可能误解了你的问题，但如果你发送

SELECT * FROM dbtest.T_AJPES_TR_LOG WHERE file_import='MyFileName.xml';

到数据库中，你要么得到一个空的结果集（=实际文件名是新的）或一个1..n条目（=文件名是已知的，已记录1..n次）的集合。

把它放在引号中，如Knubo说：

String query = String.format(
    "SELECT * FROM dbtest.T_AJPES_TR_LOG WHERE File_import='%s'", name); 
uprs1 = stmt1.executeQuery(query);

来源

2010-12-01 09:25:40

你这样做了艰辛的道路。大多数数据库都有防止重复输入的功能（尽管我并不熟悉mySQL）。假设您的RDBMS支持它，只需为相关列设置“唯一密钥”，&就可让数据库为您执行重复检测。在您自己的代码中执行它只是过度工程设计冗余。

如果您的RDMS 不支持支持这种基本功能，现在该考虑升级了。

来源

2010-12-01 15:27:29 aksarben

在插入之前检查数据库中的重复项

回答

相关问题