60 lines
1.6 KiB
Java
60 lines
1.6 KiB
Java
|
package com.ff.base.handler;
|
||
|
|
|
||
|
|
import com.alibaba.fastjson2.JSON;
|
||
|
|
import org.apache.ibatis.type.BaseTypeHandler;
|
||
|
|
import org.apache.ibatis.type.JdbcType;
|
||
|
|
|
||
|
|
import java.sql.CallableStatement;
|
||
|
|
import java.sql.PreparedStatement;
|
||
|
|
import java.sql.ResultSet;
|
||
|
|
import java.sql.SQLException;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* mybatis json字段转换
|
||
|
|
*
|
||
|
|
* @author cengy
|
||
|
|
*/
|
||
|
|
public class JsonHandler<T> extends BaseTypeHandler<T> {
|
||
|
|
private final Class<T> type;
|
||
|
|
|
||
|
|
|
||
|
|
public JsonHandler(Class<T> type) {
|
||
|
|
if (type == null) {
|
||
|
|
throw new IllegalArgumentException("Type argument cannot be null");
|
||
|
|
}
|
||
|
|
this.type = type;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override
|
||
|
|
public void setNonNullParameter(PreparedStatement ps, int i, T parameter, JdbcType jdbcType) throws SQLException {
|
||
|
|
ps.setString(i, JSON.toJSONString(parameter));
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override
|
||
|
|
public T getNullableResult(ResultSet rs, String columnName) throws SQLException {
|
||
|
|
String json = rs.getString(columnName);
|
||
|
|
if (json != null) {
|
||
|
|
return JSON.parseObject(json, type);
|
||
|
|
}
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override
|
||
|
|
public T getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
|
||
|
|
String json = rs.getString(columnIndex);
|
||
|
|
if (json != null) {
|
||
|
|
return JSON.parseObject(json, type);
|
||
|
|
}
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override
|
||
|
|
public T getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
|
||
|
|
String json = cs.getString(columnIndex);
|
||
|
|
if (json != null) {
|
||
|
|
return JSON.parseObject(json, type);
|
||
|
|
}
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
}
|