登录
首页精彩阅读通过SAS fastload Mysql table 到 Teradata
通过SAS fastload Mysql table 到 Teradata
2016-02-28
收藏


通过SAS fastload Mysql table 到 Teradata

我们在用SAS经常会会遇到一些问题,比如如何通过SAS fastload Mysql table 到 Teradata?下面就详细的说一下。

[c-sharp] view plain copy print?


  1. /*clear fastload tables*/  
  2. %let gdw_dir =( user="XXXXX" password="XXXXX" database="XXXXX" tdpid="XXXXX");  
  3. proc sql;  
  4.      connect to teradata as TD &gdw_dir;  
  5.      execute (drop table STG_MYSQL_lkp_verticals)   
  6.               by TD;  
  7.      execute (commit) by TD;  
  8. disconnect from TD;  
  9. quit;  
  10. proc sql;  
  11.      connect to teradata as TD &gdw_dir;  
  12.      execute (drop table append_err1)   
  13.               by TD;  
  14.      execute (commit) by TD;  
  15. disconnect from TD;  
  16. quit;  
  17. proc sql;  
  18.      connect to teradata as TD &gdw_dir;  
  19.      execute (drop table append_err2)   
  20.               by TD;  
  21.      execute (commit) by TD;  
  22. disconnect from TD;  
  23. quit;  
  24. proc sql;  
  25.      connect to teradata as TD &gdw_dir;  
  26.      execute   
  27.         (  
  28.              create table STG_MYSQL_lkp_verticals  
  29.              (  
  30.                   vertical varchar(10),  
  31.                   category_id integer,  
  32.                   category_name varchar(70),  
  33.                   short_name varchar(70)  
  34.               )primary index(vertical,category_id)  
  35.         )   
  36.               by TD;  
  37.      execute (commit) by TD;  
  38. disconnect from TD;  
  39. quit;  
  40. /*create source data table*/  
  41. libname bu_data  mysql user='XXXXX' password='XXXXX' database='XXXXX'       server='XXXXX' port=XXXX;  
  42. proc sql;  
  43.       create table work.lkp_verticals as  
  44.             select vertical, category_id, category_name, short_name  
  45.             from bu_data.lkp_verticals  
  46. ;  
  47. quit;  
  48. libname TDPET teradata  databASe=XXXXX  user="XXXXX" pASsword="XXXXX" TDPID="XXXXX";  
  49. proc append data=work.lkp_verticals base=TDPET.STG_MYSQL_lkp_verticals  
  50.      (bulkload=yes bl_log=append_err);  
  51. run;  

数据分析咨询请扫描二维码

最新资讯
更多
客服在线
立即咨询