package jnpf.dmsDatabase; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.ibatis.type.BaseTypeHandler; import org.apache.ibatis.type.JdbcType; import java.sql.*; /** Explicitly selected by version-property result mappings, never a global JSON handler. */ public class DmsJsonNodeTypeHandler extends BaseTypeHandler { private static final ObjectMapper JSON = new ObjectMapper(); @Override public void setNonNullParameter(PreparedStatement s, int i, JsonNode value, JdbcType type) throws SQLException { s.setObject(i, value.toString(), Types.OTHER); } @Override public JsonNode getNullableResult(ResultSet rs, String column) throws SQLException { return read(rs.getString(column)); } @Override public JsonNode getNullableResult(ResultSet rs, int column) throws SQLException { return read(rs.getString(column)); } @Override public JsonNode getNullableResult(CallableStatement s, int column) throws SQLException { return read(s.getString(column)); } private JsonNode read(String value) throws SQLException { if (value == null) return null; try { return JSON.readTree(value); } catch (java.io.IOException e) { throw new SQLException("Invalid version extended properties", e); } } }