flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java [691:729]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
				} else {
					if(colType.equals(String.class)) {
						value = toField(value);
					}
					else if(colType.equals(Byte.class)) {
						value = "" + ((Byte) value).intValue();
					}
					else if(colType.equals(byte[].class)) {
						value = "'" + new String((byte[]) value) + "'";
					}
					else if(colType.equals(Short.class)){
						value = Long.parseLong("" + value);
					}
					else if(colType.equals(Integer.class)){
						value = Long.parseLong("" + value);
					}
					else if(colType.equals(Long.class)){
						value = Long.parseLong("" + value);
					}
					else if(colType.equals(Float.class)){
						value = Double.parseDouble("" + value);
					}
					else if(colType.equals(Double.class)){
						value = Double.parseDouble("" + value);
					}
					else if(colType.equals(Boolean.class)){
						value = (Boolean)value == true ? "'true'" : "'false'";
					}
					else if (Timestamp.class.equals(colType)) {
						value = "'" + DateUtil.timeStamp2String((Timestamp)value, timeZone, reserveMs) + "'";
					} else if (Date.class.equals(colType)) {
						value = "'" + DateUtil.date2String((java.sql.Date)value, timeZone) + "'";
					} else if (Time.class.equals(colType)) {
						value = "'" + DateUtil.time2String((Time)value, timeZone) + "'";
					} else if (BigDecimal.class.equals(colType)) {
						value = Double.parseDouble("" + value);
					}
					else{
						throw new IllegalArgumentException("invalid parm");
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java [832:870]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
				} else {
						if(colType.equals(String.class)) {
							value = toField(value);
						}
						else if(colType.equals(Byte.class)) {
							value = "" + ((Byte) value).intValue();
						}
						else if(colType.equals(byte[].class)) {
							value = "'" + new String((byte[]) value) + "'";
						}
						else if(colType.equals(Short.class)){
							value = Long.parseLong("" + value);
						}
						else if(colType.equals(Integer.class)){
							value = Long.parseLong("" + value);
						}
						else if(colType.equals(Long.class)){
							value = Long.parseLong("" + value);
						}
						else if(colType.equals(Float.class)){
							value = Double.parseDouble("" + value);
						}
						else if(colType.equals(Double.class)){
							value = Double.parseDouble("" + value);
						}
						else if(colType.equals(Boolean.class)){
							value = (Boolean)value == true ? "'true'" : "'false'";
						}
						else if (Timestamp.class.equals(colType)) {
							value = "'" + DateUtil.timeStamp2String((Timestamp)value, timeZone, reserveMs) + "'";
						} else if (Date.class.equals(colType)) {
							value = "'" + DateUtil.date2String((java.sql.Date)value, timeZone) + "'";
						} else if (Time.class.equals(colType)) {
							value = "'" + DateUtil.time2String((Time)value, timeZone) + "'";
						} else if (BigDecimal.class.equals(colType)) {
							value = Double.parseDouble("" + value);
						}
						else{
						    throw new IllegalArgumentException("invalid parm");
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -