swing程序使用ScheduledExecutorService scheduExec = Executors.newScheduledThreadPool(7);线程池加载了7个线程任务,每个线程任务在在指定的时间重复执行,现在遇到的问题是,这些任务在在调用dao层的数据库插入方法是,总是出现冲突,特别是主键问题。本来方法是在插入数据库之前前进行删除的,现在调试发现随机性在这个方法中,删除语句和插入语句的上的值不相同,应该是其他线程执行过去时把值给改变了。以及再查询的时候,总是出现查出来的值还没来得急遍历,以及被删除了,这个也是线程的问题。请问线程同步的话,该怎么处置,改在什么地方出力,线程第一次用,不熟悉。请教各位高人.... 

解决方案 »

  1.   

    多线程操作数据库,如果是insert或delete操作,要加事务锁,将要操作的表锁住。
      

  2.   


    如何加哦?
    Class.forName("XXXXDriver");
    Connection c = DriverManager.getConnection(dbUrl, user, password);
    c.setAutoCommit(false);//关闭自动提交,启用事务
    ....//数据库操作
    c.commit();//提交事务
                            c.setAutoCommit(true);//还原自动提交//根据需要选择是否进行此操作
    更详细的例子,LZ可以搜索“java 数据库 事务”。
      

  3.   


    如何加哦?
    Class.forName("XXXXDriver");
    Connection c = DriverManager.getConnection(dbUrl, user, password);
    c.setAutoCommit(false);//关闭自动提交,启用事务
    ....//数据库操作
    c.commit();//提交事务
                            c.setAutoCommit(true);//还原自动提交//根据需要选择是否进行此操作
    更详细的例子,LZ可以搜索“java 数据库 事务”。这种方法原使用过,不行的,线程切换时把删除语句和插入语句中值都改变了,才照成这个情况,现在是如何控制线程这个问题哦。我在数据库操作方法叫同步块都无法控制,郁闷了
      

  4.   

    sql语句加for update 只能查询,不能更改和删除
      

  5.   


    如何加哦?
    Class.forName("XXXXDriver");
    Connection c = DriverManager.getConnection(dbUrl, user, password);
    c.setAutoCommit(false);//关闭自动提交,启用事务
    ....//数据库操作
    c.commit();//提交事务
                            c.setAutoCommit(true);//还原自动提交//根据需要选择是否进行此操作
    更详细的例子,LZ可以搜索“java 数据库 事务”。这种方法原使用过,不行的,线程切换时把删除语句和插入语句中值都改变了,才照成这个情况,现在是如何控制线程这个问题哦。我在数据库操作方法叫同步块都无法控制,郁闷了
    你的7个线程之间有先后顺序要求么?或者只是操作一下数据库就可以的么?
    如果没有先后顺序要求,建议设置一个公共控制key,哪个线程先启动了,先取得key,若key为false,则等待;若key为true将key设置为false,进行数据库操作,操作完了再将key设置为true。
    当然,这个key的取用,一定要加锁。
      

  6.   

    dao层如果是单例模式的话,可以用读写锁来搞定,百度一下java读写锁就行了,如果是多实例的话就麻烦点
      

  7.   


    如何加哦?
    Class.forName("XXXXDriver");
    Connection c = DriverManager.getConnection(dbUrl, user, password);
    c.setAutoCommit(false);//关闭自动提交,启用事务
    ....//数据库操作
    c.commit();//提交事务
                            c.setAutoCommit(true);//还原自动提交//根据需要选择是否进行此操作
    更详细的例子,LZ可以搜索“java 数据库 事务”。这种方法原使用过,不行的,线程切换时把删除语句和插入语句中值都改变了,才照成这个情况,现在是如何控制线程这个问题哦。我在数据库操作方法叫同步块都无法控制,郁闷了
    你的7个线程之间有先后顺序要求么?或者只是操作一下数据库就可以的么?
    如果没有先后顺序要求,建议设置一个公共控制key,哪个线程先启动了,先取得key,若key为false,则等待;若key为true将key设置为false,进行数据库操作,操作完了再将key设置为true。
    当然,这个key的取用,一定要加锁。
    收到你这个答案时已经解决了,解决方案差不多一样吧,还是谢了哈,分给你了。
      

  8.   


    如何加哦?
    Class.forName("XXXXDriver");
    Connection c = DriverManager.getConnection(dbUrl, user, password);
    c.setAutoCommit(false);//关闭自动提交,启用事务
    ....//数据库操作
    c.commit();//提交事务
                            c.setAutoCommit(true);//还原自动提交//根据需要选择是否进行此操作
    更详细的例子,LZ可以搜索“java 数据库 事务”。这种方法原使用过,不行的,线程切换时把删除语句和插入语句中值都改变了,才照成这个情况,现在是如何控制线程这个问题哦。我在数据库操作方法叫同步块都无法控制,郁闷了
    你的7个线程之间有先后顺序要求么?或者只是操作一下数据库就可以的么?
    如果没有先后顺序要求,建议设置一个公共控制key,哪个线程先启动了,先取得key,若key为false,则等待;若key为true将key设置为false,进行数据库操作,操作完了再将key设置为true。
    当然,这个key的取用,一定要加锁。
    收到你这个答案时已经解决了,解决方案差不多一样吧,还是谢了哈,分给你了。