sql - 我的中频条件在哪里？-6ren

sql - 我的中频条件在哪里？

转载作者：行者123 更新时间：2023-12-01 12:37:49

Oracle数据库11g企业版11.2.0.3.0版-64位生产

我最近加入了一个项目，我的主要工作是清除大量积压的缺陷。这些缺陷之一是不必要的记录重复。我已追究罪魁祸首是...

缺少对相应列的唯一约束
表

在一个遗留点中，PL / SQL中难以捉摸的Heisenbug
执行INSERT的例程。

企业可以在开发和测试环境数据库中强制实施建议的唯一约束。但是由于各种原因，在生产数据库中强制执行唯一约束是不可接受的。因此，我还建议引入一些辅助例程作为解决方案，这些例程旨在在INSERT点充当“Big Burly Bouncers”。这些拟议的“关守”例程旨在通过“记住”已插入的内容以编程方式防止重复，然后仅在上述“内存”中无法解释具有当前ID的记录时才允许插入。

我已经对这些例程进行了单元测试。我已经对它们进行了独立的单元测试(每个都单独测试)。我已经用«prevent_duplicates()»调用了«already_exists()»例程对它们进行了单元测试。我已经在纯PL / SQL和Java( using Spring's StoredProcedure abstraction)中对这两个模块进行了测试。我还在纯PL / SQL中对原始的“旧版”例程进行了单元测试，该例程被重构为调用“prevent_duplicates()”，而后者又调用了“already_exists()”。在我的每一个单元测试中，所有例程都能成功完成我所期望的工作。

但是，只有从Web应用程序远程调用例程时，重复项才能通过«prevent_duplicates()»中的IF检查。我在帖子底部粘贴了一个堆栈跟踪代码段。

所以也许我的问题集中在我的期望上。也许我太接近问题了，因此我可能会做出一些天真的假设，即乍看之下(以及更懂行的PL / SQLers)……

FUNCTION already_exists (
 p_main_thing IN lorem_ipsum.main_id%TYPE, -- NUMBER(10)
 p_type IN lorem_ipsum.entity_type%TYPE, -- VARCHAR(256) 
 p_location IN lorem_ipsum.another_id%TYPE, -- NUMBER(10)
 p_start IN lorem_ipsum.start_using%TYPE, -- DATE
 p_stop IN lorem_ipsum.stop_using%TYPE -- DATE NULLABLE
 ) RETURN NUMBER AS
  m_counter NUMBER := 0;
BEGIN

SELECT count(eg.pk_id) INTO m_counter
    FROM lorem_ipsum eg
    WHERE eg.main_id = p_main_thing
    AND eg.entity_type  = p_type
    AND eg.another_id  = p_location
    AND eg.start_using = p_start
    AND NVL(eg.stop_using, TRUNC(SYSDATE-1000000)) = NVL(p_stop, TRUNC(SYSDATE-    1000000));
    commit;
    IF m_counter > 0 THEN
      RETURN 1; -- TRUE
    ELSE
      RETURN 0; -- FALSE
    END IF; 

END already_exists;


================================================================================
PROCEDURE prevent_duplicates(
 p_main_thing IN lorem_ipsum.main_id%TYPE,
 p_type IN lorem_ipsum.entity_type%TYPE, 
 p_location IN lorem_ipsum.another_id%TYPE, 
 p_start IN lorem_ipsum.start_using%TYPE, 
 p_stop IN lorem_ipsum.stop_using%TYPE,
 p_new_pk_id OUT lorem_ipsum.pk_id%TYPE, -- NUMBER(10)
 p_memory IN OUT NOCOPY short_term_memory ) -- TYPE short_term_memory IS TABLE OF BOOLEAN INDEX BY PLS_INTEGER;
 IS

 m_new_pk_id lorem_ipsum.pk_id%TYPE;

 BEGIN

 IF ( already_exists(p_main_thing, p_type, p_location, p_start, p_stop ) = 0 ) THEN
   IF ( NOT p_memory.EXISTS( p_main_thing ) ) THEN
        m_new_pk_id := pk_id_seq.nextval; -- allowed in 11g ; but not in 10g or lower
        insert into lorem_ipsum (pk_id, entity_type, another_id, start_using,     stop_using, main_id) values (m_new_pk_id, p_type, p_location, p_start, p_stop,     p_main_thing);
        commit;
        p_memory(p_main_thing) := TRUE;
        -- return the new pk_id to the caller
        p_new_pk_id := m_new_pk_id;
  END IF;
 END IF;

-- EXCEPTION
-- ... trap ORA-00001/raise user-defined exception -20999

END prevent_duplicates;

...
org.hibernate.Session hibernate = ...
...
hibernate.beginTransaction();
String orginalLegacyRoutine = "{call myapp.original_legacy_routine("+parentId+",   666)}";
hibernate.createSQLQuery(orginalLegacyRoutine).executeUpdate();
hibernate.getTransaction().commit();
...
hibernate.close
...

...这些是我在上述例程中整理的一些假设...

我假设如果在同一个Oracle事务中完成SELECT
前面的INSERT是在几秒钟前执行的，SELECT
本来可以成功打败以前插入的
记录-如果SELECT的WHERE子句和INSERT的子句中的值
values子句完全相同。

我假设«prevent_duplicates()»两个IF语句与
关联数组-已插入的记录的ID被“存储”。

我假设他们之间应该已经确定了
已经被插入。

我假设INSERT永远不会被调用两次
相同的值。

我假设«prevent_duplicates()»IF测试阻止了这种情况。但事实并非如此。

我假设SELECT和INSERT都在
与调用例程相同的事务，因为原始的“旧式”例程是在事务边界内从Java调用的(请参见上面的代码块)

另外，我正在开发和测试环境数据库上复制重复缺陷，在该数据库中，我是通过调用Web应用程序执行例程的唯一的用户。的确，我在傍晚和周末都在办公室里独自一人，试图解决这个问题。因此，由于这个原因(以及我对Oracle promise 的READ一致性的假设)，我看不到它如何与并发相关。但是，我要承认，我对Oracle隔离级别的记忆有些模糊。尽我的最大记忆，我以为自己被覆盖了。

所以我需要帮助弄清楚我所做的错误假设。请？先感谢您。

P.S. 我无法使用调试器来逐步完成PL / SQL，因为由于安全策略以及我正在工作的商店没有执行任何操作而禁用了远程调试。

...
INFO   | jvm 15   | 2015/01/16 20:00:51 | Jan 16, 2015 8:00:51 PM org.apache.catalina.core.ApplicationContext log
INFO   | jvm 15   | 2015/01/16 20:00:51 | SEVERE: Exception while dispatching incoming RPC call
INFO   | jvm 15   | 2015/01/16 20:00:51 | com.google.gwt.user.server.rpc.UnexpectedException: Service method 'public abstract     dba.stackexchange.com.questions.ask.MyApp dba.stackexchange.com.questions.ask.MyAppRPC.addLoremIpsum(dba.stackexchange.com.questions.ask.LoremIpsum,java.lang.String)' threw an unexpected exception: org.hibernate.QueryTimeoutException: could not execute native bulk manipulation query
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at com.google.gwt.user.server.rpc.RPC.encodeResponseForFailure(RPC.java:389)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at com.google.gwt.user.server.rpc.RPC.invokeAndEncodeResponse(RPC.java:579)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at com.google.gwt.user.server.rpc.RemoteServiceServlet.processCall(RemoteServiceServlet.java:208)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at com.google.gwt.user.server.rpc.RemoteServiceServlet.processPost(RemoteServiceServlet.java:248)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at com.google.gwt.user.server.rpc.AbstractRemoteServiceServlet.doPost(AbstractRemoteServiceServlet.java:62)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at javax.servlet.http.HttpServlet.service(HttpServlet.java:637)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at javax.servlet.http.HttpServlet.service(HttpServlet.java:717)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:290)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:233)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:191)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:127)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at com.googlecode.psiprobe.Tomcat60AgentValve.invoke(Tomcat60AgentValve.java:30)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:102)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:555)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:109)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:298)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.apache.jk.server.JkCoyoteHandler.invoke(JkCoyoteHandler.java:190)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.apache.jk.common.HandlerRequest.invoke(HandlerRequest.java:291)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.apache.jk.common.ChannelSocket.invoke(ChannelSocket.java:769)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.apache.jk.common.ChannelSocket.processConnection(ChannelSocket.java:698)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.apache.jk.common.ChannelSocket$SocketConnection.runIt(ChannelSocket.java:891)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.apache.tomcat.util.threads.ThreadPool$ControlRunnable.run(ThreadPool.java:690)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at java.lang.Thread.run(Thread.java:679)
INFO   | jvm 15   | 2015/01/16 20:00:51 | Caused by: org.hibernate.QueryTimeoutException: could not execute native bulk manipulation query
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.hibernate.exception.SQLStateConverter.convert(SQLStateConverter.java:124)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.hibernate.exception.JDBCExceptionHelper.convert(JDBCExceptionHelper.java:66)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.hibernate.engine.query.NativeSQLQueryPlan.performExecuteUpdate(NativeSQLQueryPlan.java:219)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.hibernate.impl.SessionImpl.executeNativeUpdate(SessionImpl.java:1310)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.hibernate.impl.SQLQueryImpl.executeUpdate(SQLQueryImpl.java:396)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at dba.stackexchange.com.questions.ask.MyAppRPCImpl.addLoremIpsum(Unknown Source)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at java.lang.reflect.Method.invoke(Method.java:616)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at com.google.gwt.user.server.rpc.RPC.invokeAndEncodeResponse(RPC.java:561)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   ... 22 more
INFO   | jvm 15   | 2015/01/16 20:00:51 | Caused by: java.sql.SQLException: ORA-20999: An attempt to insert lorem_ipsum.pk_id: 47396 violated DEDUPE_UNIQUE constraint with: main_id := 6459 , entity_type := FOO, another_id := 858, start_using := 04-JUL-08, stop_using :=
INFO   | jvm 15   | 2015/01/16 20:00:51 | ORA-06512: at "SCOTT.MYAPP", line 504
INFO   | jvm 15   | 2015/01/16 20:00:51 | ORA-06512: at "SCOTT.MYAPP", line 741
INFO   | jvm 15   | 2015/01/16 20:00:51 | ORA-06512: at "SCOTT.MYAPP", line 538
INFO   | jvm 15   | 2015/01/16 20:00:51 | ORA-06512: at line 1
INFO   | jvm 15   | 2015/01/16 20:00:51 | 
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at oracle.jdbc.driver.T4CTTIoer.processError(T4CTTIoer.java:445)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at oracle.jdbc.driver.T4CTTIoer.processError(T4CTTIoer.java:396)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at oracle.jdbc.driver.T4C8Oall.processError(T4C8Oall.java:879)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:450)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:192)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:531)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:207)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at oracle.jdbc.driver.T4CPreparedStatement.executeForRows(T4CPreparedStatement.java:1044)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1329)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3584)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at oracle.jdbc.driver.OraclePreparedStatement.executeUpdate(OraclePreparedStatement.java:3665)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at oracle.jdbc.driver.OraclePreparedStatementWrapper.executeUpdate(OraclePreparedStatementWrapper.java:1352)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at com.mchange.v2.c3p0.impl.NewProxyPreparedStatement.executeUpdate(NewProxyPreparedStatement.java:105)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   at org.hibernate.engine.query.NativeSQLQueryPlan.performExecuteUpdate(NativeSQLQueryPlan.java:210)
INFO   | jvm 15   | 2015/01/16 20:00:51 |   ... 30 more
...

最佳答案

您已经测试并确信自己(据我所知正确)，您编写的内容适用于单个会话。因此，问题一定来自并发会话中的并发调用，就像您可能是从使用多个连接的多线程Web应用程序中得到的那样。

逻辑上的漏洞在于，如果从两个会话中调用该例程，则您仍然有竞争条件。一小段时间，您可以介于检查和插入之间，例如:

Session A                     Session B
----------------------------  ----------------------------
calls prevent_duplicates()
                              calls prevent_duplicates()
calls already_exists()
gets zero (false)
                              calls already_exists()
                              gets zero (false)
checks p_memory.exists()
gets false
                              checks p_memory.exists()
                              gets false
performs insert
commits
                              performs insert
                              gets constraint violation

其他与您遇到的问题没有直接关系的观察结果...

您的 p_memory检查实际上并未在此处添加任何内容，因为其内容始终是特定于会话的；如果插入是在另一个会话中完成的，则您将看不到它，并且由于插入将在插入集合中时提交，因此即使是跨会话也不会告诉您任何其他信息。

似乎您正在尝试静默阻止尝试插入重复项。如果允许您使用唯一约束-并且我假设这是出于某种原因而不允许在现场发布的约束，并且您所显示的是在其中可以找到漏洞的约束的dev / test版本-您可以跳过 already_exists和 p_memory检查，而只是捕获并忽略(或记录)ORA-00001。关于捕捉和忽略与插入前检查的好处还有另外的争论，这将使话题变得更加离题。

但是没有唯一约束，您必须通过锁定整个表或所有会话可以看到并尝试锁定的某些其他唯一令牌来手动序列化插入，这很可能会影响性能。您将以一种不太有效的方式重新实现唯一性。

甚至更离题，您也无法进一步了解或修复原始的Heisenbug，您只是在潜在的副作用方面对其进行了更好的处理，或者在潜在的副作用方面对其进行了忽略。如果我了解您在做什么，那就是。您似乎正在试图隐藏一个缺陷-正在插入重复项-而不是修复它。您正在尝试使用一种也可能会遇到多会话问题的方法来解决可能与多会话有关的未知问题，而这种方法可能不那么频繁。

关于sql - 我的中频条件在哪里？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/28003492/

文章推荐： c++11 - 具有 c++11 支持的 CUDA NSight 7.0 - 在哪里设置？

文章推荐： java - 您的项目包含错误，请在运行之前修复它们 :Eclipse

文章推荐： c - 符号保留在本地，未正确导出

mySQL IF 条件 THEN 条件
我正在努力处理查询的 WHERE 部分。查询本身包含一个基于两个表中都存在的 ID 的 LEFT JOIN。但是，我要求 where 语句仅返回其中一列中存在的最大单个结果。目前我返回连接中的所有值，
python - 我的代码有一个 if-else 条件，但我认为代码没有检查 if 条件，而是直接进入 else 条件
我有这个代码来改变文件系统的大小。问题是，即使满足 if 条件，它也不会进入 if 条件，而我根本没有检查 if 条件。它直接进入 else 条件。运行代码后的结果 post-install-ray
excel - SUMIF(条件，值)、SUMPROD(条件，值)和 SUM(条件*值)之间的区别
假设我有一个包含 2 列的 Excel 表格:单元格 A1 到 A10 中的日期和 B1 到 B10 中的值。我想对五月日期的所有值求和。我有3种可能性: {=SUM((MONTH(A1:A10)=
LINQ:选择 <条件> 或 <条件>
伪代码: SELECT * FROM 'table' WHERE ('date' row.date 或，我们在Stack Overflow上找到一个类似的问题： https://stackove
mysql - Yii 条件 - 修改以包含 OR 条件
我有下面这行代码做一个简单的查询 if ($this->fulfilled) $criteria->addCondition('fulfilled ' . (($this->fulfilled
PHP 条件 vs MySQL 条件
如果在数据库中找到用户输入的键，我将尝试显示“表”中的数据。目前我已将其设置为让数据库检查 key 是否存在，如下所示: //Select all from table if a key entry
我们是否可以通过改变 if 条件，在执行完 else 条件后返回执行 if 条件？
关闭。此题需要details or clarity 。目前不接受答案。想要改进这个问题吗？通过 editing this post 添加详细信息并澄清问题. 已关闭 5 年前。 Improve th
mysql - 是否可以先加入 if 条件，然后再加入 Else 条件
在MYSQL中可以吗一共有三个表任务(task_id、task_status、...) tasks_assigned_to(ta_id、task_id、user_id) task_suggeste
mysql - 首先按(条件)排序，然后按(条件)排序
我想先根据用户的状态然后根据用户名来排序我的 sql 请求。该状态由 user_type 列设置: 1=活跃，2=不活跃，3=创始人。我会使用此请求来执行此操作，但它不起作用，因为我想在“活跃”成员
c# - 嵌套的 if 条件 vs 多个分离的 if 条件，每个条件都有 return 语句
下面两个函数中最专业的代码风格是什么？如果函数变得更复杂和更大，例如有 20 个检查怎么办？注意:每次检查后我都需要做一些事情，所以我不能将所有内容连接到一个 if 语句中，例如: if (veh
sql-server - OrderBy().FirstOrDefault(<条件>) 与Where(<条件>).OrderBy().FirstOrDefault()
我在 C# 项目中使用 EntityFramework 6.1.3 和 SQL Server。我有两个查询，基本上应该执行相同的操作。 1. Exams.GroupBy(x=>x.SubjectID)
postgresql - CASE WHEN 条件 1 AND 条件 2 then x else y postgreSQL
我试图在 case when 语句中放入两个条件，但我在 postgresql 中遇到语法错误 case when condition 1 and condition 2 then X else Y
php - 在 LEFT JOIN table1 ON 条件 1 OR 条件 2 中使用 OR 会导致不必要的问题吗？
我正在构建一个连接多个表的查询，一个表 prodRecipe 将包含某些行的数据，但不是全部，但是 tmp_inv1 将包含所有行的计数信息。问题是，tmp_inv1.count 取决于某个项目是否在
SQL INDEX 不用于 WHERE ABS(x-y) < k 条件，但用于 y - k < x < y + k 条件
我有一个涉及 couples of rows which have a less-than-2-hours time-difference 的查询(~0.08333 天): SELECT mt1.*,
Perl OR 条件
我有一个包含许多这样的 OR 条件的代码(工作正常)来检查其中一个值是否为空，然后我们抛出一条错误消息(所有这些都必须填写) } elsif ( !$params{'account'}
SQL 条件 where
我有一个名为 spGetOrders 的存储过程，它接受一些参数:@startdate 和 @enddate。这将查询“订单”表。表中的一列称为“ClosedDate”。如果订单尚未关闭，则此列将保留
LINQ - if 条件
在代码中，注释部分是我需要解决的问题...有没有办法在 LINQ 中编写这样的查询？我需要这个，因为我需要根据状态进行排序。 var result = ( from contact in d
SQL:条件 AND in where
我正在尝试创建一个允许省略参数的存储过程，但如果提供了参数，则进行 AND 操作: CREATE PROCEDURE MyProcedure @LastName Varchar(30)
正则表达式 IF 条件
我正在寻找一种方法来过滤我的主机文件中的新 IP 地址。我创建了一个脚本，每次我用来自矩阵企业管理器的数据调用它时都会更新我的主机文件。它工作正常。但是我必须找到一个解决方案，只允许更新 10.XX.
jQuery 条件
所以我正在做一种 slider ，当它完全向下时隐藏向下按钮，反之亦然，当向上按钮隐藏时，我遇到了问题。 var amount = $('slide').attr('number'); $('span

行者123

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

sql - 我的中频条件在哪里？