flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java [719:737]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
					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");
					}
				}
				output[i] = "" + value;
			} catch (Exception e) {
				throw new RuntimeException("", e);
			}
		}
		return output;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java [940:958]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
					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");
					}
				}
				output[i] = "" + value;
			} catch (Exception e) {
				throw new RuntimeException("", e);
			}
		}
		return output;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -