CREATE TABLE product2 (
  id INT,
  prod_nm STRING,
 primary key(id)  NOT ENFORCED --  '??????????????'
) 
WITH (
    'connector' = 'jdbc',
    'url' = 
'jdbc:mysql://10.12.5.37:3306/rs_report?useUnicode=true&characterEncoding=UTF-8',
    'table-name' = 'sink',
    'driver' = 'com.mysql.jdbc.Driver',
    'username' = 'dps',
    'password' = 'dps1234'
);                                                                              
                                                                                
                                                                                
                                                




CREATE TABLE `sink2` (
  `local_dtm` varchar(100) DEFAULT NULL,
  `curr_dtm` varchar(100) DEFAULT NULL,
  `local_dtm_no_zone` varchar(100) DEFAULT NULL,
  `curr_dtm_no_zone` varchar(100) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8


drop table if exists sk;
CREATE TABLE sk (                                                               
                                                                                
                                                                                
                                                                                
                                                                                
                                                                                
                                                                                
                                                                                
                                                                                
                                                                                
                                                                                
                                                                                
                                                                                
                                                                                
                                                                                
                                                                                
                                                                                
                                                                                
                                                                                
                                
 local_dtm TIMESTAMP,
 curr_dtm TIMESTAMP,
 local_dtm_no_zone   TIMESTAMP WITHOUT TIME ZONE,
 curr_dtm_no_zone   TIMESTAMP WITHOUT TIME ZONE
) 
WITH (
    'connector' = 'jdbc',
    'url' = 
'jdbc:mysql://10.12.5.37:3306/rs_report?useUnicode=true&characterEncoding=UTF-8',
    'table-name' = 'sink2',
    'driver' = 'com.mysql.jdbc.Driver',
    'username' = 'dps',
    'password' = 'dps1234'
);


insert into sk values(localtimestamp,current_timestamp,localtimestamp           
,current_timestamp);


????????????2020-09-09 15:25:55.416             
????????????
local_dtm                           | curr_dtm                            | 
local_dtm_no_zone          | curr_dtm_no_zone           |
------------------------            | ------------------------            | 
------------------------           | ------------------------            |
2020-09-09 02:25:55.416  | 2020-09-08 18:25:55.416 | 2020-09-09 02:25:55.416 | 
2020-09-08 18:25:55.416 |                                                





------------------ ???????? ------------------
??????: "Leonard Xu"<[email protected]&gt;; 
????????: 2020??9??9??(??????) ????9:51
??????: "user-zh"<[email protected]&gt;; 
????: Re: localtimestamp??current_timestamp????mysql????????



Hi,

&gt;&nbsp;????????mysql&nbsp;??dtm????????????&nbsp;??????????????????????8??????????????????????????21????

??????????????21????????????????????????????????????????????????

Best
Leonard

回复