proc fedsql sessref=mySession _method; create table casuser.myresults as select film.title, film_category.category_id from pg_db1."film" as film, pg_db2."film_category" as film_category /* ... suite de la requête ... */ quit;
/* Utilisation de l'option requireFullPassThrough pour forcer le test */ proc fedsql sessref=mySession _method cntl=(requireFullPassThrough); create table pg_db1.myresults as select * from pg_db1."customer" where put(create_date,ddmmyy10.)='14/02/2006'; /* Fonction SAS */ quit;
cas mysession; /* Définition de la connexion à Postgres */ caslib caspgr datasource=(srctype="postgres", database="DCON", server="...", ...) libref=caspgr; proc fedsql sessref=mysession; /* Création de la table résultante directement dans la RAM de CAS */ create table caspgr.revenues...
proc fedsql sessref=mysession; create table caspgr.StateSalesSummary as select customerstate, minquantity, maxquantity, sumquantity from connection to caspgr ( /* DEBUT DU SQL NATIF POSTGRES */ SELECT customerstate, min(quantity) as minquanti...
proc fedsql sessref=ma_session; create table cas.ma_table_cible as select * from CONNECTION TO nom_de_la_caslib ( /* Code SQL Natif (Postgres, Oracle, etc.) */ /* Invisible pour SAS */ ); quit;
proc fedsql sessref=mysession; create table cas.synthese_ventes as select region, total_ventes from connection to ma_lib_postgres ( /* Début du code natif PostgreSQL */ SELECT /* Extraction de la clé 'region' dans l'objet JSON */ d...
CAS mySession host="myServer.com" SESSOPTS=(CASLIB=casuser TIMEOUT=999 LOCALE="en_US"); /* Assignation d'une Caslib Hive standard (Session scope) */ caslib hivelib desc="HIVE Caslib" datasource=(SRCTYPE="HIVE",SERVER="myServerHadoop.com", HADOOPCONFIGDIR="/opt/sas/hadoop/client_...
CAS mySession host="myServer.com" SESSOPTS=(CASLIB=casuser TIMEOUT=999 LOCALE="en_US"); /* Assignation d'une Caslib Hive Globale */ caslib hivelib desc="HIVE Caslib" datasource=(SRCTYPE="HIVE",SERVER="myServerHadoop.com", HADOOPCONFIGDIR="/opt/sas/hadoop/client_conf/", HADO...
/* Compression activée pour cette table spécifique */ data WORK.A (compress=yes); set DB2.GRANDE_TABLE; run; /* OU activée globalement pour toute la session */ options compress=yes;