Liquibase 从 csv 加载数据

Question

我想用 csv 文件中的数据加载我的 PostgreSql table 的整个列，但是当我这样做时我得到一个异常，说我的 table 的主键不应该为空.看起来 Liquibase 正在创建新行来插入数据。有没有办法在现有行中加载数据？

DatabaseChangeLog dbChangeLog = new DatabaseChangeLog();
Liquibase liquibase = new Liquibase(dbChangeLog, new FileSystemResourceAccessor(), database);
ChangeSet loadChangeSet = new ChangeSet(id + "", "nasri", false, false, "", "", "", liquibase.getDatabaseChangeLog());

LoadDataChange loadDataChange = new LoadDataChange();
loadDataChange.setTableName(key);
loadDataChange.setChangeSet(loadChangeSet);
loadDataChange.setResourceAccessor(new FileSystemResourceAccessor());

String path = context.getBundle().getVersion() + "." + key + "." + columnKey + "." + targetFieldKey + ".csv";
loadDataChange.setFile(path);

loadDataChange.setSchemaName("public");

LoadDataColumnConfig columnConfig = new LoadDataColumnConfig();
columnConfig.setName(targetFieldKey);
columnConfig.setType("String");
loadDataChange.addColumn(columnConfig);
loadChangeSet.addChange(loadDataChange);
liquibase.getDatabaseChangeLog().addChangeSet(loadChangeSet);
liquibase.update("");

Answer 1

有一个 class 叫做：LoadUpdateDataChange

描述说：

Loads or updates data from a CSV file into an existing table. Differs from loadData by issuing a SQL batch that checks for the existence of a record. If found, the record is UPDATEd, else the record is INSERTed. Also, generates DELETE statements for a rollback.

看起来它应该可以满足您的需求（虽然我自己没有使用过）。

Answer 2

要更新记录，LoadUpdateDataChange 对我不起作用。它总是尝试插入新的 records.It 不会更新现有记录。

如果要更新现有记录，您应该像下面这样使用。

<update tableName="someTable">

   <column name="update_column_name" value="updated value" />

   <where> primaryKey = condition</where>

</update>

Liquibase 从 csv 加载数据

Liquibase loading data from csv

java

database

liquibase