数据库单元和 JSON 列类型支持

Question

我想知道让DbUnit与MySQL的JSON(B(类型列一起工作的最佳方法是什么？我们确实在这里和那里都有这样的列，每当我尝试通过 XML 文件提供测试数据时@DatabaseSetup我都会得到 NoSuchColumnException，这会阻止我使用处理 JSON 的实体或存储库进行任何合理的集成测试：

org.dbunit.dataset.NoSuchColumnException: assistant_event.AEV_CONTEXT -  (Non-uppercase input column: aev_context) in ColumnNameToIndexes cache map. Note that the map's column names are NOT case sensitive.

我知道这是因为我的AEV_CONTEXT列没有得到识别，因为它是一个 JSON 列：

@Type(type = "json")
@Column(name = "aev_context", columnDefinition = "json")
private Context context;

但是，我在尝试解决它时遇到了困难。而且，更奇怪的是，我在这里的任何地方都找不到这样的解决方法！事实上，我不知道这是否更像是Hibernate或DbUnit的事情。

到目前为止，真的只有我有这个问题吗？任何建议将不胜感激！

哦，如果你想知道，这就是我获得对Hibernate的JSON支持的方式：

https://vladmihalcea.com/how-to-map-json-objects-using-generic-hibernate-types/

Answer 1

如果有人需要它，这是@Aleksi的PostgreSQL JSONB数据类型解决方案的Java版本：

import org.dbunit.dataset.datatype.AbstractDataType;
import org.dbunit.dataset.datatype.DataType;
import org.dbunit.dataset.datatype.DataTypeException;
import org.dbunit.dataset.datatype.TypeCastException;
import org.dbunit.ext.postgresql.PostgresqlDataTypeFactory;
import org.postgresql.util.PGobject;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
public class NewPostgresqlDataTypeFactory extends PostgresqlDataTypeFactory {
@Override
public DataType createDataType(int sqlType, String sqlTypeName) throws DataTypeException {
if (sqlTypeName.equals("jsonb")) {
return new JsonbDataType();
} else {
return super.createDataType(sqlType, sqlTypeName);
}
}
public static class JsonbDataType extends AbstractDataType {
public JsonbDataType() {
super("jsonb", Types.OTHER, String.class, false);
}
@Override
public Object typeCast(Object obj) throws TypeCastException {
return obj.toString();
}
@Override
public Object getSqlValue(int column, ResultSet resultSet) throws SQLException, TypeCastException {
return resultSet.getString(column);
}
@Override
public void setSqlValue(Object value,
int column,
PreparedStatement statement) throws SQLException, TypeCastException {
final PGobject jsonObj = new PGobject();
jsonObj.setType("json");
jsonObj.setValue(value == null ? null : value.toString());
statement.setObject(column, jsonObj);
}
}
}

Answer 2

一个潜在的解决方案是定义你自己的 DataTypeFactory 并使用它。我这样做是为了支持PostgreSQL JSONB数据类型，可以为MySQL制作类似的东西。

class NewPostgresqlDataTypeFactory : PostgresqlDataTypeFactory() {
override fun createDataType(sqlType: Int, sqlTypeName: String?): DataType {
return when (sqlTypeName) {
"jsonb" -> return JsonbDataType()
else -> super.createDataType(sqlType, sqlTypeName)
}
}
class JsonbDataType : AbstractDataType("jsonb", Types.OTHER, String::class.java, false) {
override fun typeCast(obj: Any?): Any {
return obj.toString()
}
override fun getSqlValue(column: Int, resultSet: ResultSet): Any {
return resultSet.getString(column)
}
override fun setSqlValue(value: Any?, column: Int, statement: PreparedStatement) {
val jsonObj = PGobject()
jsonObj.type = "json"
jsonObj.value = value?.toString()
statement.setObject(column, jsonObj)
}
}
}

Answer 3

除了@Ilya的答案之外，以下是H2 JSON数据类型的类似解决方案：

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import org.dbunit.dataset.datatype.AbstractDataType;
import org.dbunit.dataset.datatype.DataType;
import org.dbunit.dataset.datatype.DataTypeException;
import org.dbunit.ext.h2.H2DataTypeFactory;
import org.h2.value.Value;
import org.h2.value.ValueJson;
public class CustomH2DataTypeFactory extends H2DataTypeFactory {
@Override
public DataType createDataType(int sqlType, String sqlTypeName, String tableName, String columnName)
throws DataTypeException {
if (sqlType == 1111 && sqlTypeName.toLowerCase().startsWith("json")) {
return new JsonDataType();
} else {
return super.createDataType(sqlType, sqlTypeName, tableName, columnName);
}
}
public class JsonDataType extends AbstractDataType {
public JsonDataType() {
super("json", Types.OTHER, String.class, false);
}
@Override
public Object typeCast(Object value) {
return value.toString();
}
@Override
public Object getSqlValue(int column, ResultSet resultSet) throws SQLException {
return resultSet.getString(column);
}
@Override
public void setSqlValue(Object value, int column, PreparedStatement statement) throws SQLException {
Value object = ValueJson.fromJson(value.toString());
statement.setObject(column, object);
}
}
}