使用DBMS_LOCK控制程序并发
2014-08-25 23:24
197 查看
在调用并发的程序时,假设两个人同时提交了某一个并发请求,并且传入了同样的参数,假设在程序中使用了对状态的控制,例如在刚进入main函数的时候马上就将状态update了,那么其中某一个人就会查不到该条数据最后请求没有执行。
也可以使用另外一种方法,使用lock,将提交的并发锁住,其他提交的只能排队。
-- lockl_lockname VARCHAR2(100);
l_lockhandle VARCHAR2(200);
l_lock_output NUMBER;
l_locked BOOLEAN := FALSE; //阻止并发导入同一批数据
l_lockname := G_PKG_NAME||'_RESERVE';
//lockname类似一把锁,它定义了一个唯一的名字,当并发请求执行main函数的时候,lockname会自己得到,
//如果在执行中的并发程序与其重名那么并发就不能执行。这里可以灵活应用,
//例如传入的参数为Header_id,而我们允许不同的HeaderId同时执行但是不允许相同的HeaderId同时执行,
//那么可以使l_lockname := G_PKG_NAME||p_header_id,那么就可以锁住相同的HeaderId。
dbms_lock.allocate_unique( lockname => l_lockname, lockhandle => l_lockhandle);
-- release when session out, request time out 1分钟
l_lock_output := dbms_lock.request(l_lockhandle, 6, 60, FALSE);
IF l_lock_output <> 0 THEN
xxfnd_api.set_message( p_app_name => xxfnd_api.g_app_name, p_msg_name => 'XXFND_CONC_LOCKED_ERR', p_token1 => 'EVENT', p_token1_value => 'Reserve Batch', p_token2 => 'DATA', p_token2_value => '');
RAISE fnd_api.g_exc_error;
END IF;
l_locked := TRUE;
/**要特别注意的是一定要lockname释放掉,否则这个并发就永远别想执行**/
//需要释放lockname的地方除了程序正常的结束部分还有异常处理部分,都要使用
IF l_locked THEN
l_lock_output := dbms_lock.release(l_lockhandle);
END IF;
也可以使用另外一种方法,使用lock,将提交的并发锁住,其他提交的只能排队。
-- lockl_lockname VARCHAR2(100);
l_lockhandle VARCHAR2(200);
l_lock_output NUMBER;
l_locked BOOLEAN := FALSE; //阻止并发导入同一批数据
l_lockname := G_PKG_NAME||'_RESERVE';
//lockname类似一把锁,它定义了一个唯一的名字,当并发请求执行main函数的时候,lockname会自己得到,
//如果在执行中的并发程序与其重名那么并发就不能执行。这里可以灵活应用,
//例如传入的参数为Header_id,而我们允许不同的HeaderId同时执行但是不允许相同的HeaderId同时执行,
//那么可以使l_lockname := G_PKG_NAME||p_header_id,那么就可以锁住相同的HeaderId。
dbms_lock.allocate_unique( lockname => l_lockname, lockhandle => l_lockhandle);
-- release when session out, request time out 1分钟
l_lock_output := dbms_lock.request(l_lockhandle, 6, 60, FALSE);
IF l_lock_output <> 0 THEN
xxfnd_api.set_message( p_app_name => xxfnd_api.g_app_name, p_msg_name => 'XXFND_CONC_LOCKED_ERR', p_token1 => 'EVENT', p_token1_value => 'Reserve Batch', p_token2 => 'DATA', p_token2_value => '');
RAISE fnd_api.g_exc_error;
END IF;
l_locked := TRUE;
/**要特别注意的是一定要lockname释放掉,否则这个并发就永远别想执行**/
//需要释放lockname的地方除了程序正常的结束部分还有异常处理部分,都要使用
IF l_locked THEN
l_lock_output := dbms_lock.release(l_lockhandle);
END IF;
相关文章推荐
- 使用DBMS_LOCK控制程序并发
- 使用DBMS_LOCK控制程序并发
- 使用DBMS_LOCK控制程序并发
- 使用DBMS_LOCK控制程序并发
- 使用DBMS_LOCK控制程序并发
- java并发控制:ReentrantLock Condition使用详解
- Java高并发程序-Chapter3 JDK并发包(第十二讲)同步控制之 ReadWriteLock
- java并发控制:ReentrantLock Condition使用详解
- Java高并发程序-Chapter3 JDK并发包(第十六讲)同步控制之LockSupport
- java线程并发控制:ReentrantLock Condition使用详解
- Android并发编程之如何使用ReentrantReadWriteLock替代synchronized来提高程序的效率
- Java高并发程序-Chapter3 JDK并发包(第九讲)同步控制之 ReentrantLock 重用锁
- hibernate之控制并发访问(乐观并发控制之外获得额外的隔离性保证--使用LockMode.UPGRADE的实例)
- Transaction And Lock--使用资源锁来控制并发
- java并发控制:ReentrantLock Condition使用详解
- Java高并发程序-Chapter3 JDK并发包(第十七讲)同步控制之ReentrantLock 的实现
- Android并发编程之如何使用ReentrantReadWriteLock替代synchronized来提高程序的效率
- 使用VB.NET编写控制excel的程序
- 使用Visual Studio 2008编写出采用户帐户控制UAC的程序
- 程序测试程序(配合游戏及学习控制管理器使用)