异构数据库数据与结构同步工具 dbswitch工具提供源端数据库向目的端数据库的批量迁移同步功能，支持数据的全量和增量方式同步

package com.gitee.dbswitch.common.util; import cn.hutool.core.codec.Base64; import cn.hutool.json.JSONUtil; import java.io.ByteArrayOutputStream; import java.io.ObjectOutputStream; import java.lang.reflect.Method; import java.math.BigDecimal; import java.math.BigInteger; import java.sql.SQLException; import java.sql.Timestamp; import java.sql.Types; import java.time.Instant; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.LocalTime; import java.time.ZoneId; import java.util.Collection; import java.util.Map; import java.util.function.Function; import lombok.experimental.UtilityClass; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; @Slf4j @UtilityClass public final class ObjectCastUtils { /** * 将任意类型转换为java.lang.Byte类型 * * @param in 任意类型的对象实例 * @return java.lang.Byte类型 */ public static Byte castToByte(final Object in) { if (in instanceof Number) { return ((Number) in).byteValue(); } else if (in instanceof java.util.Date) { return Long.valueOf(((java.util.Date) in).getTime()).byteValue(); } else if (in instanceof String) { try { return Byte.parseByte(in.toString()); } catch (NumberFormatException e) { throw new RuntimeException( String.format("无法将java.lang.String类型转换为java.lang.Byte类型:%s", e.getMessage())); } } else if (in instanceof Character) { try { return Byte.parseByte(in.toString()); } catch (NumberFormatException e) { throw new RuntimeException( String.format("无法将java.lang.Character类型转换为java.lang.Byte类型:%s", e.getMessage())); } } else if (in instanceof java.sql.Clob) { try { return Byte.parseByte(clob2Str((java.sql.Clob) in)); } catch (NumberFormatException e) { throw new RuntimeException( String.format("无法将java.sql.Clob类型转换为java.lang.Byte类型:%s", e.getMessage())); } } else if (in instanceof Boolean) { return (Boolean) in ? (byte) 1 : (byte) 0; } return null; } public static byte[] castToByteArray(final Object in) { if (in instanceof byte[]) { return (byte[]) in; } else if (in instanceof java.util.Date) { return in.toString().getBytes(); } else if (in instanceof java.sql.Blob) { return blob2Bytes((java.sql.Blob) in); } else if (in instanceof java.lang.String || in instanceof java.lang.Character) { return in.toString().getBytes(); } else if (in instanceof java.sql.Clob) { return clob2Str((java.sql.Clob) in).getBytes(); } else { try (ByteArrayOutputStream bos = new ByteArrayOutputStream(); ObjectOutputStream oos = new ObjectOutputStream(bos)) { oos.writeObject(in); oos.flush(); return bos.toByteArray(); } catch (Exception e) { log.error("Field value convert from {} to byte[] failed:", in.getClass().getName(), e); throw new RuntimeException(e); } } } /** * 将任意类型转换为java.lang.Short类型 * * @param in 任意类型的对象实例 * @return java.lang.Short类型 */ public static Short castToShort(final Object in) { if (in instanceof Number) { return ((Number) in).shortValue(); } else if (in instanceof Byte) { return (short) (((byte) in) & 0xff); } else if (in instanceof java.util.Date) { return (short) ((java.util.Date) in).getTime(); } else if (in instanceof java.util.Calendar) { return (short) ((java.util.Calendar) in).getTime().getTime(); } else if (in instanceof LocalDateTime) { return (short) java.sql.Timestamp.valueOf((LocalDateTime) in).getTime(); } else if (in instanceof java.time.OffsetDateTime) { return (short) java.sql.Timestamp.valueOf(((java.time.OffsetDateTime) in).toLocalDateTime()) .getTime(); } else if (in instanceof String || in instanceof Character) { try { String s = in.toString().trim(); if (s.equalsIgnoreCase("true")) { return Short.valueOf((short) 1); } else if (s.equalsIgnoreCase("false")) { return Short.valueOf((short) 0); } else { return Short.parseShort(s); } } catch (NumberFormatException e) { throw new RuntimeException( String.format("无法将java.lang.String类型转换为java.lang.Short类型:%s", e.getMessage())); } } else if (in instanceof java.sql.Clob) { try { String s = clob2Str((java.sql.Clob) in).trim(); if (s.equalsIgnoreCase("true")) { return Short.valueOf((short) 1); } else if (s.equalsIgnoreCase("false")) { return Short.valueOf((short) 0); } else { return Short.parseShort(s); } } catch (NumberFormatException e) { throw new RuntimeException( String.format("无法将java.sql.Clob类型转换为java.lang.Short类型:%s", e.getMessage())); } } else if (in instanceof Boolean) { return (Boolean) in ? (short) 1 : (short) 0; } return null; } /** * 将任意类型转换为java.lang.Integer类型 * * @param in 任意类型的对象实例 * @return java.lang.Integer类型 */ public static Integer castToInteger(final Object in) { if (in instanceof Number) { return ((Number) in).intValue(); } else if (in instanceof Byte) { return (((byte) in) & 0xff); } else if (in instanceof java.util.Date) { return (int) ((java.util.Date) in).getTime(); } else if (in instanceof java.util.Calendar) { return (int) ((java.util.Calendar) in).getTime().getTime(); } else if (in instanceof LocalDateTime) { return (int) java.sql.Timestamp.valueOf((LocalDateTime) in).getTime(); } else if (in instanceof java.time.OffsetDateTime) { return (int) java.sql.Timestamp.valueOf(((java.time.OffsetDateTime) in).toLocalDateTime()) .getTime(); } else if (in instanceof String || in instanceof Character) { try { String s = in.toString().trim(); if (s.equalsIgnoreCase("true")) { return Integer.valueOf(1); } else if (s.equalsIgnoreCase("false")) { return Integer.valueOf(0); } else { return Integer.parseInt(s); } } catch (NumberFormatException e) { throw new RuntimeException( String.format("无法将java.lang.String类型转换为java.lang.Integer类型:%s", e.getMessage())); } } else if (in instanceof java.sql.Clob) { try { String s = clob2Str((java.sql.Clob) in).trim(); if (s.equalsIgnoreCase("true")) { return Integer.valueOf(1); } else if (s.equalsIgnoreCase("false")) { return Integer.valueOf(0); } else { return Integer.parseInt(s); } } catch (NumberFormatException e) { throw new RuntimeException( String.format("无法将java.sql.Clob类型转换为java.lang.Integer类型:%s", e.getMessage())); } } else if (in instanceof Boolean) { return (Boolean) in ? (int) 1 : (int) 0; } return null; } /** * 将任意类型转换为java.lang.Long类型 * * @param in 任意类型的对象实例 * @return java.lang.Long类型 */ public static Long castToLong(final Object in) { if (in instanceof Number) { return ((Number) in).longValue(); } else if (in instanceof Byte) { return (long) (((byte) in) & 0xff); } else if (in instanceof java.util.Date) { return ((java.util.Date) in).getTime(); } else if (in instanceof java.util.Calendar) { return ((java.util.Calendar) in).getTime().getTime(); } else if (in instanceof LocalDateTime) { return java.sql.Timestamp.valueOf((LocalDateTime) in).getTime(); } else if (in instanceof java.time.OffsetDateT