插入冲突时什么都不做-读取csv并生成外键表

Question

我试图在csv文件中读取列艺术家，专辑，歌曲和标签。

我希望像这样填充artist_album_song表：

|artist_id|album_id|song_id|
|---------|--------|-------|
|   1     |     1  |     1 |
|   1     |     1  |     2 |
|   1     |     2  |     1 |
...
|  12     |     1  |     1 |
...

我已经设计并正在尝试填充以下表。问题是填充artist_album_song表中的外键，就像我在csv中读到的那样。

插入到这个表中的最佳方法是什么，它可以实现我在下面使用的INSERT语句中尝试做的事情（返回语法错误）？谢谢。

create table artists (
    artist_id SERIAL PRIMARY KEY,
    artist VARCHAR(100) NOT NULL UNIQUE
);

create table albums (
    album_id SERIAL PRIMARY KEY,
    album VARCHAR(100) NOT NULL UNIQUE
);

create table songs (
    song_id SERIAL PRIMARY KEY,
    song VARCHAR(250) NOT NULL UNIQUE
);

create table tags (
    tag_id SERIAL PRIMARY KEY,
    tag VARCHAR(100) NOT NULL UNIQUE
);

create table artists_albums_songs (
    artist_id INTEGER NOT NULL,
    album_id INTEGER NOT NULL,
    song_id INTEGER NOT NULL,
    FOREIGN KEY (artist_id) REFERENCES artists(artist_id),
    FOREIGN KEY (album_id) REFERENCES albums(album_id),
    FOREIGN KEY (song_id) REFERENCES songs(song_id),
    PRIMARY KEY (artist_id, album_id, song_id)
);

create table songs_tags (
    song_id INTEGER NOT NULL,
    tag_id INTEGER NOT NULL,
    FOREIGN KEY (song_id) REFERENCES songs(song_id),
    FOREIGN KEY (tag_id) REFERENCES tags(tag_id),
    PRIMARY KEY (song_id, tag_id)
);

在尝试了下面链接中各种不同的语句后，我仍然无法让它发挥作用。

我尝试了以下语句，但总是出错。第一个返回错误：

org.postgresql.util.PSQLException: ERROR: syntax error at or near "ON" Position: 161;

161是否指下面SQL语句中的第161个字符？

INSERT INTO artists_albums_songs
SELECT artist_id, album_id, song_id 
FROM artists a 
    JOIN albums b
        ON a.artist = ?
        AND b.album = ?
    JOIN songs c
        ON c.song = ?
    ON DUPLICATE (artist_id, album_id, song_id) DO NOTHING;

INSERT INTO artists_albums_songs
SELECT artist_id, album_id, song_id 
FROM artists a 
    JOIN albums b
        ON a.artist = ?
        AND b.album = ?
    JOIN songs c
        ON c.song = ?
    WHERE NOT EXISTS (
        SELECT * 
        FROM artists_albums_songs
        WHERE * = ?, ?, ?)

INSERT INTO artists_albums_songs
SELECT artist_id, album_id, song_id 
FROM artists a 
    JOIN albums b
        ON a.artist = ?
        AND b.album = ?
    JOIN songs c
        ON c.song = ?
    ON CONFLICT (song_id) IGNORE;

编辑：如果我删除上面3个INSERT语句的最后一行，它就可以工作，但是当它遇到一个重复的语句时，它会说：

org.postgresql.util.PSQLException: ERROR: duplicate key value violates unique constraint "artists_albums_songs_pkey"
  Detail: Key (artist_id, album_id, song_id)=(1, 1, 1) already exists.

在PostgreSQL中重复更新时插入？

使用插入。。。在冲突时不执行任何操作返回失败的行

如何在PostgreSQL中升级（合并、插入…重复更新）？

Answer 1

此行错误：

 ON DUPLICATE (artist_id, album_id, song_id) DO NOTHING;

Postgtresql在冲突上使用关键字https://www.postgresql.org/docs/current/static/sql-insert.html

Answer 2

编辑1：我刚刚意识到我可以用Java处理这些错误！因此，我的解决方案就是添加一个catch语句来处理重复的SQLException

private <T> void insertIntoArtistAlbumSong(T artist, T album, T song) throws SQLException {

    try {

        String artString = artist.toString();
        String albString = album.toString();
        String songString = song.toString();

        // Create SQL insert statement
        String stm =
                "INSERT INTO artists_albums_songs " +
                        "SELECT artist_id, album_id, song_id " +
                        "FROM artists a " +
                        "JOIN albums b " +
                        "ON a.artist = ? " +
                        "AND b.album = ? " +
                        "JOIN songs c " +
                        "ON c.song = ? ;";


        PreparedStatement pstmt = connection.prepareStatement(stm);

        // Set values in prepared statement
        pstmt.setString(1, artString);
        pstmt.setString(2, albString);
        pstmt.setString(3, songString);

        // Insert into table
        pstmt.executeUpdate();

    // ADDED THIS CATCH STATEMENT!
    } catch (SQLException e){
        System.out.println(e.getSQLState());
    }
}

好的，我找到了一个解决方案，但它只适用于填充表（这是我实际需要做的全部）。

>

删除原始artists_albums_songs[1]表

创建不带约束的新artists_albums_songs[2]表：

CREATE TABLE artists_albums_songs (
    artist_id INTEGER NOT NULL,
    album_id INTEGER NOT NULL,
    song_id INTEGER NOT NULL
);

然后，我用以下语句（通过JDBC）填充新表[2]：

INSERT INTO artists_albums_songs
SELECT artist_id, album_id, song_id 
FROM artists a 
    JOIN albums b
        ON a.artist = ?
        AND b.album = ?
    JOIN songs c
        ON c.song = ?;

创建一个带有约束的tmp[3]表（通过psql命令行）：

CREATE TABLE tmp (
    artist_id INTEGER NOT NULL,
    album_id INTEGER NOT NULL,
    song_id INTEGER NOT NULL,
    FOREIGN KEY (artist_id) REFERENCES artists(artist_id),
    FOREIGN KEY (album_id) REFERENCES albums(album_id),
    FOREIGN KEY (song_id) REFERENCES songs(song_id),
    PRIMARY KEY (artist_id, album_id, song_id)
);

仅将新的艺术家_专辑_歌曲[2]中不同的行插入tmp[3]（通过psql）：

INSERT INTO tmp SELECT DISTINCT * FROM artists_albums_songs
ORDER BY artist_id, album_id, song_id ASC;

删除新的artists_albums_songs[2]并将tmp[3]重命名为artists_albums_songs（通过psql）：

DROP TABLE artists_albums_songs;
ALTER TABLE tmp RENAME TO artists_albums_songs;