Vous trouverez, sur cette page, quelques PROC SQL SAS, en explicit SQL Pass-Through, prete à l'emploi. Ces extraits de code SAS sont utiles pour obtenir un certain nombre d'informations sur votre base de données , lorsque vous travaillez avec SAS/ACCESS interface to Netezza.
Sessions utilisateurs
Vous pouvez ajouter des conditions à la requete :
Dans l'exemple ci-dessus, je liste les sessions actives pour l'utilisateur système "sasdemo" et utilisant "sql-odbc". Sasdemo est l'utilisateur exécutant le workspace SAS.
L'id de la sessionInstance de connexion active entre un client et le serveur CAS (Cloud Analytic Services), isolant les ressources, les bibliothèques et les traitements d'un utilisateur au sein de SAS Viya. courante
Liste des tables systèmes Netezza et description
La même proc sql pour les vues (requete sur la table système netezza _v_view )
Exemple avec la vue _V_VIEW_STORAGE_STAT
Ce qui donne :
1
2
3
4
2
3
4
%let netezza_server='server';
%let netezza_database='base';
%let netezza_user='login';
%let netezza_password='mot_de_passe';
%let netezza_database='base';
%let netezza_user='login';
%let netezza_password='mot_de_passe';
1
2
3
4
5
6
7
8
9
10
2
3
4
5
6
7
8
9
10
proc sql;
connect to netezza(
SERVER=netezza_server
database=netezza_database
USER=netezza_user
PASSWORD=netezza_password);
create table _t_sessctx as
select * from connection to netezza
(select * from _t_sessctx;);
quit;
connect to netezza(
SERVER=netezza_server
database=netezza_database
USER=netezza_user
PASSWORD=netezza_password);
create table _t_sessctx as
select * from connection to netezza
(select * from _t_sessctx;);
quit;
Vous pouvez ajouter des conditions à la requete :
1
2
2
select * from _t_sessctx WHERE session_state_name='active'
AND client_type_name='sql-odbc' AND client_os_username='sasdemo';
AND client_type_name='sql-odbc' AND client_os_username='sasdemo';
1
select current_sid;
1
2
3
4
5
6
7
8
9
10
11
12
2
3
4
5
6
7
8
9
10
11
12
proc sql;
connect to netezza(SERVER=netezza_server
database=netezza_database
USER=netezza_user
PASSWORD=netezza_password);
create table table_system as
select * from connection to netezza
(SELECT sr.objname, v.virdescr, v.virprevname, v.virstatus
FROM _v_sys_relation sr
INNER JOIN _t_virtual v
ON sr.objid = v.virrelid);
quit;
connect to netezza(SERVER=netezza_server
database=netezza_database
USER=netezza_user
PASSWORD=netezza_password);
create table table_system as
select * from connection to netezza
(SELECT sr.objname, v.virdescr, v.virprevname, v.virstatus
FROM _v_sys_relation sr
INNER JOIN _t_virtual v
ON sr.objid = v.virrelid);
quit;
Avoir une estimation du nombre de ligne d'une table Netezza
Il s'agit d'une estimation basée sur les tables systèmes Netezza.1
2
3
4
5
6
7
2
3
4
5
6
7
proc sql;
connect to netezza(SERVER=netezza_server
database=netezza_database
USER=netezza_user
PASSWORD=netezza_password);
SELECT TABLENAME, RELTUPLES FROM NTZ_ECD._V_TABLE where objtype = 'TABLE' ORDER BY RELTUPLES;
quit;
connect to netezza(SERVER=netezza_server
database=netezza_database
USER=netezza_user
PASSWORD=netezza_password);
SELECT TABLENAME, RELTUPLES FROM NTZ_ECD._V_TABLE where objtype = 'TABLE' ORDER BY RELTUPLES;
quit;
Décrire les métadonnéesInformations décrivant les données, les utilisateurs et les ressources dans SAS Viya. Elles assurent la traçabilité, la sécurité et la gouvernance au sein de l'architecture distribuée. d'une table/vue Netezza ( describe d'une table/vue Netezza)
Il n'y a pas d'option descirbe pour décrire les métadonnéesInformations décrivant les données, les utilisateurs et les ressources dans SAS Viya. Elles assurent la traçabilité, la sécurité et la gouvernance au sein de l'architecture distribuée. de colonne dans Netezza. Il est toutefois possible d'utiliser le code SAS ci-dessous :1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
proc sql;
connect to netezza(
SERVER=netezza_server
database=netezza_database
USER=netezza_user
PASSWORD=netezza_password);
create table ntz_table as
select * from connection to netezza
(SELECT
tablename,
attname AS COL_NAME,
b.FORMAT_TYPE AS COL_TYPE,
attnum AS COL_NUM
FROM _v_table a
JOIN _v_relation_column b
ON a.objid = b.objid
WHERE a.tablename = 'NOM_DE_LA_TABLE'
ORDER BY attnum;);
quit;
connect to netezza(
SERVER=netezza_server
database=netezza_database
USER=netezza_user
PASSWORD=netezza_password);
create table ntz_table as
select * from connection to netezza
(SELECT
tablename,
attname AS COL_NAME,
b.FORMAT_TYPE AS COL_TYPE,
attnum AS COL_NUM
FROM _v_table a
JOIN _v_relation_column b
ON a.objid = b.objid
WHERE a.tablename = 'NOM_DE_LA_TABLE'
ORDER BY attnum;);
quit;
La même proc sql pour les vues (requete sur la table système netezza _v_view )
Exemple avec la vue _V_VIEW_STORAGE_STAT
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
proc sql;
connect to netezza(
SERVER=netezza_server
database=netezza_database
USER=netezza_user
PASSWORD=netezza_password);
create table ntz_view as
select * from connection to netezza
(SELECT
*
FROM _v_view a
JOIN _v_relation_column b
ON a.objid = b.objid
WHERE a.VIEWNAME = '_V_VIEW_STORAGE_STAT'
ORDER BY attnum;);
quit;
connect to netezza(
SERVER=netezza_server
database=netezza_database
USER=netezza_user
PASSWORD=netezza_password);
create table ntz_view as
select * from connection to netezza
(SELECT
*
FROM _v_view a
JOIN _v_relation_column b
ON a.objid = b.objid
WHERE a.VIEWNAME = '_V_VIEW_STORAGE_STAT'
ORDER BY attnum;);
quit;
Vérifier les sessions / requêtes actives Netezza
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
proc sql;
connect to netezza(
SERVER=netezza_server
database=netezza_database
USER=netezza_user
PASSWORD=netezza_password);
create table _t_sessctx as
select * from connection to netezza
(select q.qs_sessionid,
q.qs_planid,
q.qs_clientid,
s.dbname,
s.username,
s.TYPE SESSION_TYPE,
s.STATUS SESSION_STATUS,
s.PRIORITY SESSION_PRIORITY,
q.qs_cliipaddr,
q.QS_STATE,
substr(q.qs_sql,1,200),
case
when q.qs_state = 1 then 'pending'
when q.qs_state = 2 then 'queued'
when q.qs_state = 3 then 'running'
when q.qs_state = 4 then 'aborted'
when q.qs_state = 5 then 'done'
else 'unknown'
end QS_STATE_DESCRIPTION,
q.qs_tsubmit+t.tzoffset qs_tsubmit,
q.qs_tstart+t.tzoffset tzoffset,
case when q.qs_tstart = t.EPOCH then 0 else abstime 'now' - q.qs_tstart end running_duration,
q.qs_pritxt,
q.qs_estcost,
q.qs_estdisk,
q.qs_estmem,
q.qs_snippets,
q.qs_cursnipt,
q.qs_resrows,
q.qs_resbytes
from _v_qrystat q,
_v_session s,
_vt_pg_time_offset t
where q.qs_sessionid = s.id);
quit;
connect to netezza(
SERVER=netezza_server
database=netezza_database
USER=netezza_user
PASSWORD=netezza_password);
create table _t_sessctx as
select * from connection to netezza
(select q.qs_sessionid,
q.qs_planid,
q.qs_clientid,
s.dbname,
s.username,
s.TYPE SESSION_TYPE,
s.STATUS SESSION_STATUS,
s.PRIORITY SESSION_PRIORITY,
q.qs_cliipaddr,
q.QS_STATE,
substr(q.qs_sql,1,200),
case
when q.qs_state = 1 then 'pending'
when q.qs_state = 2 then 'queued'
when q.qs_state = 3 then 'running'
when q.qs_state = 4 then 'aborted'
when q.qs_state = 5 then 'done'
else 'unknown'
end QS_STATE_DESCRIPTION,
q.qs_tsubmit+t.tzoffset qs_tsubmit,
q.qs_tstart+t.tzoffset tzoffset,
case when q.qs_tstart = t.EPOCH then 0 else abstime 'now' - q.qs_tstart end running_duration,
q.qs_pritxt,
q.qs_estcost,
q.qs_estdisk,
q.qs_estmem,
q.qs_snippets,
q.qs_cursnipt,
q.qs_resrows,
q.qs_resbytes
from _v_qrystat q,
_v_session s,
_vt_pg_time_offset t
where q.qs_sessionid = s.id);
quit;
