]> git.8kb.co.uk Git - pgpool-ii/pgpool-ii_2.2.5/blob - pcp/pcp_systemdb_info.c
2.2.5 HEAD
[pgpool-ii/pgpool-ii_2.2.5] / pcp / pcp_systemdb_info.c
1 /*
2  * $Header: /cvsroot/pgpool/pgpool-II/pcp/pcp_systemdb_info.c,v 1.3 2008/12/31 10:25:40 t-ishii Exp $
3  *
4  * pgpool: a language independent connection pool server for PostgreSQL 
5  * written by Tatsuo Ishii
6  *
7  * Copyright (c) 2003-2008      PgPool Global Development Group
8  *
9  * Permission to use, copy, modify, and distribute this software and
10  * its documentation for any purpose and without fee is hereby
11  * granted, provided that the above copyright notice appear in all
12  * copies and that both that copyright notice and this permission
13  * notice appear in supporting documentation, and that the name of the
14  * author not be used in advertising or publicity pertaining to
15  * distribution of the software without specific, written prior
16  * permission. The author makes no representations about the
17  * suitability of this software for any purpose.  It is provided "as
18  * is" without express or implied warranty.
19  *
20  * Client program to send "systemDB info" command.
21  */
22
23 #include <stdio.h>
24 #include <stdlib.h>
25 #include <string.h>
26 #include <unistd.h>
27
28 #include "pcp.h"
29
30 static void usage(void);
31 static void myexit(ErrorCode e);
32
33 int
34 main(int argc, char **argv)
35 {
36         long timeout;
37         char host[MAX_DB_HOST_NAMELEN];
38         int port;
39         char user[MAX_USER_PASSWD_LEN];
40         char pass[MAX_USER_PASSWD_LEN];
41         SystemDBInfo *systemdb_info;
42         int i, j;
43         int ch;
44
45         while ((ch = getopt(argc, argv, "hd")) != -1) {
46                 switch (ch) {
47                 case 'd':
48                         pcp_enable_debug();
49                         break;
50
51                 case 'h':
52                 case '?':
53                 default:
54                         usage();
55                         exit(0);
56                 }
57         }
58         argc -= optind;
59         argv += optind;
60
61         if (argc != 5)
62         {
63                 errorcode = INVALERR;
64                 pcp_errorstr(errorcode);
65                 myexit(errorcode);
66         }
67
68         timeout = atol(argv[0]);
69         if (timeout < 0) {
70                 errorcode = INVALERR;
71                 pcp_errorstr(errorcode);
72                 myexit(errorcode);
73         }
74
75         if (strlen(argv[1]) >= MAX_DB_HOST_NAMELEN)
76         {
77                 errorcode = INVALERR;
78                 pcp_errorstr(errorcode);
79                 myexit(errorcode);
80         }
81         strcpy(host, argv[1]);
82
83         port = atoi(argv[2]);
84         if (port <= 1024 || port > 65535)
85         {
86                 errorcode = INVALERR;
87                 pcp_errorstr(errorcode);
88                 myexit(errorcode);
89         }
90
91         if (strlen(argv[3]) >= MAX_USER_PASSWD_LEN)
92         {
93                 errorcode = INVALERR;
94                 pcp_errorstr(errorcode);
95                 myexit(errorcode);
96         }
97         strcpy(user, argv[3]);
98
99         if (strlen(argv[4]) >= MAX_USER_PASSWD_LEN)
100         {
101                 errorcode = INVALERR;
102                 pcp_errorstr(errorcode);
103                 myexit(errorcode);
104         }
105         strcpy(pass, argv[4]);
106
107         if (pcp_connect(host, port, user, pass))
108         {
109                 pcp_errorstr(errorcode);
110                 myexit(errorcode);
111         }
112
113         if ((systemdb_info = pcp_systemdb_info()) == NULL)
114         {
115                 pcp_errorstr(errorcode);
116                 pcp_disconnect();
117                 myexit(errorcode);
118         } else {
119                 printf("%s %d %s %s %s %s %d %d\n", 
120                            systemdb_info->hostname,
121                            systemdb_info->port,
122                            systemdb_info->user,
123                            systemdb_info->password[0] == '\0' ? "''" : systemdb_info->password,
124                            systemdb_info->schema_name,
125                            systemdb_info->database_name,
126                            systemdb_info->dist_def_num,
127                            systemdb_info->system_db_status);
128
129                 for (i = 0; i < systemdb_info->dist_def_num; i++)
130                 {
131                         DistDefInfo *ddi = &systemdb_info->dist_def_slot[i];
132
133                         printf("%s %s %s %s %d ",
134                                    ddi->dbname,
135                                    ddi->schema_name,
136                                    ddi->table_name,
137                                    ddi->dist_key_col_name,
138                                    ddi->col_num);
139
140                         for (j = 0; j < ddi->col_num; j++)
141                                 printf("%s ", ddi->col_list[j]);
142
143                         for (j = 0; j < ddi->col_num; j++)
144                                 printf("%s ", ddi->type_list[j]);
145                         
146                         printf("%s\n", ddi->dist_def_func);
147                 }
148                 
149                 free_systemdb_info(systemdb_info);
150         }
151
152         pcp_disconnect();
153
154         return 0;
155 }
156
157 static void
158 usage(void)
159 {
160         fprintf(stderr, "pcp_systemdb_info - display the pgpool-II systemDB information\n\n");
161         fprintf(stderr, "Usage: pcp_systemdb_info [-d] timeout hostname port# username password\n");
162         fprintf(stderr, "Usage: pcp_systemdb_info -h\n\n");
163         fprintf(stderr, "  -d       - enable debug message (optional)\n");
164         fprintf(stderr, "  timeout  - connection timeout value in seconds. command exits on timeout\n");
165         fprintf(stderr, "  hostname - pgpool-II hostname\n");
166         fprintf(stderr, "  port#    - pgpool-II port number\n");
167         fprintf(stderr, "  username - username for PCP authentication\n");
168         fprintf(stderr, "  password - password for PCP authentication\n");
169         fprintf(stderr, "  -h       - print this help\n");
170 }
171
172 static void
173 myexit(ErrorCode e)
174 {
175         if (e == INVALERR)
176         {
177                 usage();
178                 exit(e);
179         }
180
181         exit(e);
182 }