【发布时间】:2020-04-01 04:11:40
【问题描述】:
场景:我有一个发布数据库,包含以下表格:
-
publication包含数据库中每本书的信息。 -
keyword列出所有标识出版物的预定义术语。 -
publication_keyword是一个匹配出版物和关键字的查找表。 -
new_publication_keyword是一个查找表,其中包含出版物和关键字之间的新匹配项。
我需要将new_publication_keyword 中的行添加到publication_keyword,避免添加已经存在的行。
这是在测试模式中创建场景的 DDL
SET search_path = test;
drop table publication_keyword;
drop table publication;
drop table keyword;
drop table new_publication_keyword;
CREATE TABLE publication (
id VARCHAR(24) NOT NULL,
title VARCHAR(1024),
CONSTRAINT publication_pkey PRIMARY KEY(id)
);
CREATE TABLE keyword (
id VARCHAR(12) NOT NULL,
label VARCHAR(180) NOT NULL,
CONSTRAINT keyword_list_pkey PRIMARY KEY(id)
);
CREATE TABLE publication_keyword (
publication_id VARCHAR(24) NOT NULL,
keyword_id VARCHAR(12) NOT NULL
);
CREATE INDEX publication_keyword_code_idx ON publication_keyword
USING btree (keyword_id COLLATE pg_catalog."default");
CREATE INDEX publication_keyword_pubid_idx ON publication_keyword
USING btree (publication_id COLLATE pg_catalog."default");
CREATE TABLE new_publication_keyword (
publication_id VARCHAR(24) NOT NULL,
keyword_id VARCHAR(12) NOT NULL
);
CREATE INDEX new_publication_keyword_code_idx ON new_publication_keyword
USING btree (keyword_id COLLATE pg_catalog."default");
CREATE INDEX new_publication_keyword_pubid_idx ON new_publication_keyword
USING btree (publication_id COLLATE pg_catalog."default");
insert into publication values ('EAN13CODE1001','Title 1');
insert into publication values ('EAN13CODE1002','Title 2');
insert into publication values ('EAN13CODE1003','Title 3');
insert into keyword values ('KWCODE0001','Keyword 1');
insert into keyword values ('KWCODE0002','Keyword 2');
insert into publication_keyword values ('EAN13CODE1001', 'KWCODE0001');
insert into publication_keyword values ('EAN13CODE1002', 'KWCODE0001');
insert into new_publication_keyword values ('EAN13CODE1001', 'KWCODE0001');
insert into new_publication_keyword values ('EAN13CODE1003', 'KWCODE0001');
insert into new_publication_keyword values ('EAN13CODE1003', 'KWCODE0002');
我想知道当每个表包含数百万行时使用哪种策略最好。目前,我正在使用LEFT OUTER JOIN 查询,排除所有现有行,但这是一个非常慢的解决方案:
insert into publication_keyword (publication_id, keyword_id)
select npw.publication_id, npw.keyword_id from new_publication_keyword npw left outer join
publication_keyword pw on npw.publication_id = pw.publication_id and npw.keyword_id = pw.keyword_id
where pw.publication_id is null
我想将INSERT 与ON CONFLICT 子句一起使用,但要使用它,我需要在publication_keyword 表上创建一个PRIMARY KEY,为这个新索引使用大量磁盘空间:
-- Not working with the current schema, need to add a PK on publication_keyword
insert into publication_keyword (publication_id, keyword_id)
select publication_id, keyword_id from new_publication_keyword
ON CONFLICT DO NOTHING;
那么,添加新行的最佳解决方案是什么?
【问题讨论】:
-
最佳解决方案是添加主(或唯一)键。如果这些值应该是唯一的,那么无论如何都应该在数据库中强制执行。
标签: sql postgresql performance merge upsert