- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我有一个存储过程:
CREATE OR REPLACE PROCEDURE public.lock_users(j_id "varchar",order_id "varchar",order_detail_id "varchar",insert_qry varchar(65535),rec_per_order "varchar")
LANGUAGE plpgsql
AS $$
declare
lc_stmt varchar(65535);
BEGIN
lc_stmt = 'INSERT INTO test.USER_LOCK
SELECT '''||$1||''', '''||$2||''', '''||$3||''', user_id,cast(TIMEOFDAY() as timestamp) FROM ('||insert_qry|| 'AND USER_ID NOT IN (SELECT USER_ID FROM test.USER_LOCK)) WHERE ORDER_CNT <='||rec_per_order||'))';
EXECUTE ''||lc_stmt||'';
END
$$
;
从上述过程中生成的一个示例查询是:
INSERT INTO test.USER_LOCK
SELECT '657d7563-6de4-4dc9-ac74-3c23adf7a4e9', 'DSS-12345', 'DSS-74523-4-7569',
USER_ID,cast(TIMEOFDAY() as timestamp)
FROM (
SELECT USER_ID FROM (
SELECT * FROM (
SELECT XA.USER_ID, XA.EMAIL_ID,YA.COMPANY_NAME
rank() OVER (PARTITION BY XA.account_id ORDER BY XA.account_id) ORDER_CNT
FROM test.contacts_20 XA
LEFT JOIN test.accounts_20 YA
ON XA.ACCOUNT_ID = YA.ACCOUNT_ID
AND XA.COUNTRY = YA.COUNTRY
WHERE XA.IS_CONTACT_SUPPRESSED = 0
AND UPPER(XA.TELE_SUPPRESSION_LOB) != UPPER('DSS')
AND XA.TELE_SUPPRESSION_LOB != 'BOTH'
AND XA.IS_TELE_VERIFIED = 1
AND XA.IS_TELE_SUPPRESSED = 0
AND UPPER(PHONE_LINE) = 'DIRECT'
AND XA.COUNTRY IN (
SELECT INCLUSION_VALUE FROM user_inc_list
WHERE JOB_ID = '657d7563-6de4-4dc9-ac74-3c23adf7a4e9'
AND UPPER(INCLUSION_TYPE) = 'COUNTRY')
AND XA.COUNTRY NOT IN (
SELECT EXCLUSION_VALUE FROM user_exc_list
WHERE JOB_ID = '657d7563-6de4-4dc9-ac74-3c23adf7a4e9'
AND UPPER(EXCLUSION_TYPE) = 'COUNTRY')
AND XA.USER_ID NOT IN (
SELECT USER_ID FROM test.user_lead_20
WHERE (CURRENT_DATE - creation_date::date) <= 60 AND UPPER(LOB) != 'DSS' AND AGENCY_ID != '1456')
AND XA.USER_ID NOT IN (
SELECT USER_ID FROM test.user_lead_20
WHERE (CURRENT_DATE - creation_date::date) <= 60 AND UPPER(LOB) != 'DSS' AND SPONSOR_ID != '8659')
AND USER_ID NOT IN (
select USER_ID
from user_e_history
where sf_campaign_id = 'DSS-12345' AND (CURRENT_DATE - creation_date::date) >= 7 AND channel = 'TELE')
AND USER_ID NOT IN (
select USER_ID from user_e_history
where creation_date::date = CURRENT_DATE AND channel = 'TELE' )
AND USER_ID NOT IN (
select USER_ID from test.user_lead_20
where sf_campaign_id = 'DSS-12345' GROUP BY USER_ID,"DOMAIN" HAVING COUNT(*) >= 3 )
AND USER_ID NOT IN (
select USER_ID from test.user_lead_20
where AGENCY_ID = 1456 and (CURRENT_DATE - creation_date::date) <= 180 )
AND XA.E_domain NOT LIKE '%.gov'
AND USER_ID NOT IN (
SELECT USER_ID FROM test.USER_LOCK)) WHERE ORDER_CNT <=20));
当我并行执行这个存储过程时,它给我这个错误:
SQL Error [500310] [XX000]: [Amazon](500310) Invalid operation: 1023
Details:
Serializable isolation violation on table - 132075, transactions forming the cycle are: 2040186, 2040187 (pid:14687);
当我更改我的存储过程而不是传递参数和创建固定插入查询时,它起作用了。
这是有效的存储过程:
CREATE OR REPLACE PROCEDURE public.new_procedure(type_value "varchar")
LANGUAGE plpgsql
AS $$
declare
lc_stmt varchar;
BEGIN
lc_stmt = 'INSERT into temp_table
select ct_id,email_id,first_name,last_name from users where active_type = '''||$1||''' ';
EXECUTE ''||lc_stmt||'';
END
$$
;
我无法理解此问题的原因和解决方案。请帮忙。
最佳答案
动态过程中的插入查询查找不在 user_lock 表中的 user_id 并插入结果。两个动态版本的结果集中似乎有共同的user_id。
所以假设当你的第一个版本被执行时,它可能会添加一个 user_id 到 user_lock 表,同样的 user_id 也可能在结果集中被第二个版本插入到 user_lock 表中。
因此,根据哪个版本先运行,这两个版本的结果集将与串行执行的结果集不同,即它们不是“可序列化隔离的”。
并且您在测试示例中没有遇到错误,因为它是一种独立的插入(用户和 temp_table)。
尝试 LOCK可能会解决这个问题。
关于sql - Redshift - 并发写入 - 如果查询是动态创建的,则插入不起作用,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60510969/
我们可以直接将一张表从一个 Redshift 集群复制到另一个 Redshift 集群吗? 我知道可以使用 s3 作为临时存储来实现表复制(即从第一个集群卸载到 s3,然后从 s3 复制到另一个集群)
我在 AWS Redshift 集群中执行了以下操作以从 S3 读取 Parquet 文件。 create external schema s3_external_schema from data c
我在 AWS Redshift 集群中执行了以下操作以从 S3 读取 Parquet 文件。 create external schema s3_external_schema from data c
在 Amazon Redshift 中创建数据表时,您可以指定各种 encodings,例如 MOSTLY32 或 BYTEDICT 或 LZO。这些是在磁盘上存储列值时使用的压缩。 我想知道我选择的
我在 s3 中有一个压缩文件。我想将它插入到 RedShift 数据库中。我的研究发现做到这一点的唯一方法是启动一个 ec2 实例。将文件移到那里,解压缩,然后将其发送回 S3。然后将其插入到我的 R
为了在 Multi-Tenancy 维度 DW 中处理特定对象的自定义字段,我创建了 Redshift 不太喜欢的超宽非规范化维度表(数百列,列的硬编码限制);)。 user1|attr1|attr2
Redshift 文档将时间序列表确定为最佳实践: http://docs.aws.amazon.com/redshift/latest/dg/c_best-practices-time-series
我正在使用 redshift 的 COPY 命令从 S3 复制 json 数据。 表定义如下: CREATE TABLE my_raw ( id BIGINT IDENTITY(1,1), ... .
如何获取导出的键(数据库元数据)。即使 redshift 不支持外键和主键,我也可以在系统表中看到它们。这里的问题是在系统表中,外键的多列作为数组存在于一列中(尽管redshift不支持数组)。是否可
我正在寻找一种创建 Redshift 查询的方法,该查询将从每天生成的表中检索数据。我们集群中的表具有以下形式: event_table_2016_06_14 event_table_2016_06_
在 Redshift 中,当我们将结果导入 TABLEAU 时,我们试图为从查询返回的列提供更有意义的别名,问题是 RedShift 将所有字母转换为小写字母,即从“事件日期” ” 然后它返回“事件日
据我了解,Redshift 是为性能而不是可用性而构建的。文档 https://aws.amazon.com/redshift/faqs/建议一旦任何一个节点宕机,整个集群都会宕机,直到该节点恢复。在
我试图找出与中止查询相关的原因/错误,其中可以从 STL_query 表中找到中止的查询。我为此使用了 STL_errors,但发现错误上下文与 process id 相关,而不是特定的查询 id。有
我们正在使用 AWS Redshift DB 并希望创建一个在线复制(这样也可以完全更新更改)? 原因是我们希望为我们的一个部门提供一个单独的环境来运行他们自己的查询,因为他们可能会“发疯”并做一些
我在使用 DataGrip 的 Redshift 集群上运行查询需要超过 10 个小时才能运行,不幸的是,这些查询经常失败。唉,DataGrip 与数据库的连接保持的时间不够长,我无法看到查询失败的错
我正在对 redshift 中的一些查询进行基准测试,以便我可以对我对表所做的更改进行一些智能说明,例如添加编码和运行 vacuum。我可以查询stl_query带有 LIKE 子句的表来查找我感兴趣
删除表后,redshift 是否回收可用磁盘空间,或者我们是否需要运行 vaccum。 最佳答案 drop table 释放空间。 如果您正在对表的行进行删除操作,那么您应该触发 vaccumm de
有没有办法在 Amazon Redshift 中计算具有固定窗口大小的加权移动平均值?更详细地说,给定一个带有日期列和值列的表,对于每个日期计算指定大小窗口的加权平均值,并在辅助表中指定权重。 到目前
我注意到第一次在 RedShift 上运行查询需要 3-10 秒。当我再次运行相同的查询时,即使在 WHERE 条件中使用不同的参数,它也会运行得很快(0.2 秒)。 我正在谈论的查询在一个约 1M
我明白 the COPY command非常有效地导入大量数据。但是使用 the INSERT command 将数据从一个表复制到另一个表是慢的。有没有更有效的方法将数据从一个表复制到另一个表?或者
我是一名优秀的程序员,十分优秀!