Thread를 두개를 실행시켜서 DB에 동시에 INSERT를 시켜버리니 INSERT할 때 데이터가 AUTOINCRESEMENT가 아니라 ID부분을 직접 입력해서 하는 부분이면 문제가 발생합니다.
그래서 이 MERGE INTO문을 활용해서 데이터가 있으면 INSERT하고 없으면 UPDATE하는 구문을 만들었습니다.
이렇게 해도 제 생각이지만, Thread한 놈은 이미 데이터가 없는 것을 확인하고 insert를 시도 하려고 하고, 다른 Thread놈은 저 놈이 insert를 아직 하지 않았으니까 검색해서 안나오니 insert를 해보려고 하니 둘 다 insert를 시도하게 되더라구요.

이게 예제 입니다.
우선 테이블구조입니다.
테이블은 autoincreament가 아닌 수동적인 기본키를 사용합니다.
[code]CREATE TABLE "INSERTTABLE" ( "ID" NUMBER NOT NULL ENABLE, "DATA" VARCHAR2(4000) NOT NULL ENABLE, CONSTRAINT "INSERTTABLE_PK" PRIMARY KEY ("ID") ENABLE )
[/code]


applicationContext.xml
[code]<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:p="http://www.springframework.org/schema/p"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="
        http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context-2.5.xsd">

    <context:component-scan base-package="thread" />
   
    <!-- oracle용 -->
    <bean id="dataSource"
        class="org.springframework.jdbc.datasource.DriverManagerDataSource"
        p:driverClassName="oracle.jdbc.driver.OracleDriver"
        p:url="jdbc:oracle:thin:@localhost:1521:XE"
        p:username="mudchobo" p:password="1234" />
 
    <!-- SqlMap setup for iBATIS Database Layer -->
    <bean id="sqlMapClient"
        class="org.springframework.orm.ibatis.SqlMapClientFactoryBean"
        p:dataSource-ref="dataSource"
        p:configLocation="classpath:config/SqlMapConfig.xml" />
   
    <bean id="sqlMapClientTemplete"
        class="org.springframework.orm.ibatis.SqlMapClientTemplate"
        p:sqlMapClient-ref="sqlMapClient"/>
           
</beans>
[/code]
SqlMapConfig.xml
[code]<?xml version="1.0" encoding="UTF-8" ?>

<!DOCTYPE sqlMapConfig     
    PUBLIC "-//ibatis.apache.org//DTD SQL Map Config 2.0//EN"     
    "http://ibatis.apache.org/dtd/sql-map-config-2.dtd">

<sqlMapConfig>
    <sqlMap resource="config/Insert.xml" />
</sqlMapConfig>
[/code]
Insert.xml
[code]<?xml version="1.0" encoding="UTF-8" ?>

<!DOCTYPE sqlMap     
PUBLIC "-//ibatis.apache.org//DTD SQL Map 2.0//EN"
"http://ibatis.apache.org/dtd/sql-map-2.dtd">

<sqlMap namespace="Sqlmap">
       <insert id="insertData">
           MERGE INTO INSERTTABLE
           USING DUAL
           ON (ID = 1)
           WHEN MATCHED THEN
           UPDATE SET
           DATA = 'HERMUSSERI'
           WHEN NOT MATCHED THEN
           INSERT (ID, DATA)
           VALUES (1, 'MUDCHOBO')
       </insert>
      
</sqlMap>
[/code]
ThreadTestDao.java
[code]package thread;

public interface ThreadTestDao {
    public void insertData();
}
[/code]
ThreadTestDaoImpl.java
[code]package thread;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.orm.ibatis.SqlMapClientTemplate;
import org.springframework.stereotype.Repository;

@Repository
public class ThreadTestDaoImpl implements ThreadTestDao {

    @Autowired
    private SqlMapClientTemplate sqlMapClientTemplate;

    @Override
    public void insertData() {
        sqlMapClientTemplate.insert("insertData");
    }
}
[/code]
TestThread.java
[code]package thread;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Component;

@Scope("prototype")
@Component
public class TestThread extends Thread {

    @Autowired
    private ThreadTestDao threadTestDao;
   
    @Override
    public void run() {
        threadTestDao.insertData();
    }
}
[/code]
ThreadTest.java
[code]package thread;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class ThreadTest {

    public static void main(String[] args) {
        String configLocation = "config/applicationContext.xml";
        ApplicationContext context = new ClassPathXmlApplicationContext(
                configLocation);

        TestThread testThread1 = (TestThread) context
                .getBean("testThread");
        TestThread testThread2 = (TestThread) context
                .getBean("testThread");
       
        testThread1.start();
        testThread2.start();
    }
}
[/code]
실행할 때 계속 몇번을 실행해보면-_-; unique constraint 또는 ORA-00001: 무결성 제약 조건(MUDCHOBO.INSERTTABLE_PK)에 위배됩니다를 볼 수 있을 겁니다.

이게 제 생각인데, 첫번째 스레드가 돌면서 데이터를 확인하니 없길래 insert를 하려던 찰나에 두번째 스레드놈도 거의 동시에 데이터를 확인하니 없어서 insert를 시키려다가 에러가 나는 듯한데요.

트랜잭션도 먹이고 별 지롤을 다 했는데 안되길래 그냥 싱크방식으로 변경해버렸습니다.
insertData라는 메소드에
[code]@Override
    synchronized public void insertData() {
        sqlMapClientTemplate.insert("insertData");
    }
[/code]
메소드 앞에 synchronized를 붙입니다.
이건 어떤 스레드가 호출을 했으면 다음 스레드는 기다린 다음에 접근하게 되는 즉 싱크방식으로 처리를 시킬 수 있는 메소드가 됩니다.
이렇게 처리하면 효율은 좀 떨어지겠지만, 유니크 중복에러는 그나마 막을 수 있습니다.

다른 방법 있으면 좀 알려주세요 ㅠㅠ 고생하고 있습니다 ㅠ




 
Posted by 머드초보

댓글을 달아 주세요

  1. BlogIcon 정원희 2008.07.02 17:29  댓글주소  수정/삭제  댓글쓰기

    DB에서 제공되는 auto_increment 값이 아니라 사용자가 수동으로 넣어주는 값이면 뭘 어떻게 하든간에 중복 insert 문제가 발생할 수 밖에 없습니다. 일단 unique 라서 DB의 무결성이 깨지진 않습니다만 민감한 부분의 코드라면 두명이 동시에 사용하는 경우 한명은 오류화면을 보게 된다는 거겠네요 -_-;

    DBMS에서 원자성을 제공하는 기능을 쓰도록 변경하셔야 합니다. 수동으로 뭔가 하거나 키값의 max 를 구해서 입력해도 동일한 문제가 발생할 것이구요, 자바에서 synchorinized 로 처리를 했다고 해도 해당 어플리케이션 내에서만 보장되는 것이지 다른 프로그램이나 DBMS 자체에 로그인해서 수작업으로 쿼리를 날리거나 할때는 또 문제가 될 수 있습니다.

    • 머드초보 2008.07.02 19:46  댓글주소  수정/삭제

      오...좋은 의견감사합니다 ㅠ
      도저히 방법이 생각나지 않아 그냥 synchronized로 처리했는데 ^^
      원자성을 제공하는 기능이라함은 오라클에서 제공하는 그런 기능이 있다는 말씀이신가요?
      음 찾아봐야겠네요 감사해요~ ^^

  2. 2008.07.03 13:25  댓글주소  수정/삭제  댓글쓰기

    비밀댓글입니다

  3. 2008.11.24 15:59  댓글주소  수정/삭제  댓글쓰기

    비밀댓글입니다

    • 머드초보 2008.11.25 11:29  댓글주소  수정/삭제

      전 그냥 synchronized로 해결했는데요.
      그....오라클에서 시퀀스를 사용하면 된다고 하네요^^
      저도 안 써봐서 모르겠네요 ㅠ

  4. BlogIcon yeori 2009.07.13 16:20  댓글주소  수정/삭제  댓글쓰기

    흠... 제가 지금 저것때문에 좀 골치가 아픈데... 저는 스프링 거치지 않고 iBATIS만 사용중인데 unique constraint를 침범하는 상황인데도 iBATIS 자체에서 "ORA-00001: 무결성 제약 조건" 에러를 던지지 않고 bean 클래스의 프로퍼티를 설정하려다가 null poiner exception만 던지고 있어서 iBATIS 코드를 보는 중이네요. -_-

    일단 예외 발생하면 똑같은 데이터가 존재한다고 가정하고 select 로 시도해서 해결중인데 좀 깔끔하지가 못하죠... 고민입니다..

    • 머드초보 2009.07.19 16:14  댓글주소  수정/삭제

      안녕하세요~
      사실 시퀀스를 걸어서 개발하는 게 맞는건데, 어쩔 수 없는 상황도 있죠. 저도 저 당시 고민을 좀 했었는데-_- 그냥 뭐 느리더라도 sync를 써서 했던 기억이^^
      암튼, 방문해주셔서 감사해요~ ^^

  5. BlogIcon huikyun 2009.12.16 14:49  댓글주소  수정/삭제  댓글쓰기

    안녕하세요. 같은 문제로 고민하다가 유익한 글 잘 읽었습니다.
    저는 성능이 중시되는 상황에서 Insert문만 딱 한가지여서 무결성 예외가 뜨는걸 그냥 로그로 찍기만 하고 그냥 두었습니다.
    synchronized 를 이용하려고 하니 저보다도 다른 개발자가 오히려 ㅎㄷㄷ 해버리네요...

    • 머드초보 2009.12.17 09:55  댓글주소  수정/삭제

      그렇군요-_-
      성능이 우선시 된다면야....시퀀스를....-_-

    • BlogIcon huikyun 2009.12.17 11:56  댓글주소  수정/삭제

      아. 모 대기업의 개발건이라서
      데이터베이스에 스키마는 정해진대로 가야합니다.
      혹시 다음에 기회가 된다면 꼭 시퀀스 사용을 고려해보도록 하겠습니다.^^;

    • 머드초보 2009.12.20 13:55  댓글주소  수정/삭제

      아 그렇군요^^
      방문해주셔서 감사해요~ ^^