diff options
Diffstat (limited to 'fs/database.c')
| -rw-r--r-- | fs/database.c | 628 |
1 files changed, 0 insertions, 628 deletions
diff --git a/fs/database.c b/fs/database.c deleted file mode 100644 index 0ff12e433ee..00000000000 --- a/fs/database.c +++ /dev/null @@ -1,628 +0,0 @@ -/* Copyright (C) 2000 db AB & db Finland AB & TCX DataKonsult AB - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA - */ - -/* - * Database functions - * - * Using these functions we emulate filesystem behaviour on top of SQL - * database. - * Written by Tõnu Samuel <tonu@please.do.not.remove.this.spam.ee> - * - * FIXME: - * - Direct handling of database handlers without SQL parsing overhead - * - connection pool - * - configurable function name/file name mappings - */ - - -#include "libmysqlfs.h" -#include "mysqlcorbafs.h" -#include <unistd.h> -#include <string.h> -#include <my_sys.h> - -DYNAMIC_ARRAY field_array; - -/* - * ** dbConnect -- connects to the host and selects DB. - * ** Also checks whether the tablename is a valid table name. - * */ -int db_connect(char *host, char *user,char *passwd) -{ - DBUG_ENTER("db_connect"); - DBUG_PRINT("enter",("host: '%s', user: '%s', passwd: '%s'", host, user, passwd)); - - if (verbose) - { - fprintf(stderr, "# Connecting to %s...\n", host ? host : "localhost"); - } - mysql_init(&connection); - if (opt_compress) - mysql_options(&connection,MYSQL_OPT_COMPRESS,NullS); -#ifdef HAVE_OPENSSL - if (opt_use_ssl) - mysql_ssl_set(&connection, opt_ssl_key, opt_ssl_cert, opt_ssl_ca, - opt_ssl_capath); -#endif - if (!(sock= mysql_real_connect(&connection,host,user,passwd, - NULL,opt_mysql_port,opt_mysql_unix_port,0))) - { - DBerror(&connection, "when trying to connect"); - DBUG_RETURN(1); - } - DBUG_RETURN(0); -} /* dbConnect */ - - -/* - * ** dbDisconnect -- disconnects from the host. - * */ -void db_disconnect(char *host) -{ - DBUG_ENTER("db_disconnect"); - DBUG_PRINT("enter",("host: '%s'", host)); - if (verbose) - fprintf(stderr, "# Disconnecting from %s...\n", host ? host : "localhost"); - mysql_close(sock); - DBUG_VOID_RETURN; -} /* dbDisconnect */ - -#define OUTPUT(x) strcpy(buffptr,x); buffptr+=strlen(x); -#define OUTPUT_TOP(x) strcpy(topptr,x); topptr+=strlen(x); -#define OUTPUT_MIDDLE(x) strcpy(midptr,x); midptr+=strlen(x); -#define OUTPUT_BOTTOM(x) strcpy(botptr,x); botptr+=strlen(x); -#define OUTPUT_HEADER(x) strcpy(hdrptr,x); hdrptr+=strlen(x); - -void db_show_result(MYSQL* sock, char *b, struct format *f) -{ - MYSQL_ROW row; - MYSQL_RES *result; - MYSQL_FIELD *field; - char *buffptr; - char topseparator[BUFLEN]=""; - char middleseparator[BUFLEN]=""; - char bottomseparator[BUFLEN]=""; - char header[BUFLEN]=""; - char *topptr=topseparator; - char *midptr=middleseparator; - char *botptr=bottomseparator; - char *hdrptr=header; - uint i,count, length; - - DBUG_ENTER("db_show_result"); - DBUG_PRINT("enter",("b: '%s', f '%x'", b, f)); - - result=mysql_store_result(sock); - - buffptr=b; - OUTPUT(f->tablestart) - - OUTPUT_TOP(f->leftuppercorner); - OUTPUT_MIDDLE(f->leftcross); - OUTPUT_BOTTOM(f->leftdowncorner); - OUTPUT_HEADER(f->headerrowstart); - - - count=mysql_num_fields(result); -// while ((field = mysql_fetch_field(result))) - for(i=0 ; i < count ; ++i) - { - field = mysql_fetch_field(result); - length=(uint) strlen(field->name); - OUTPUT_HEADER(f->headercellstart); - - length=max(length,field->max_length); - if (length < 4 && !IS_NOT_NULL(field->flags)) - length=4; // Room for "NULL" - field->max_length=length; - - memset(topptr,'=',field->max_length); - memset(midptr,'-',field->max_length); - memset(botptr,'=',field->max_length); - - sprintf(hdrptr,"%-*s",field->max_length,field->name); - //num_flag[off]= IS_NUM(field->type); - - topptr+=field->max_length; - midptr+=field->max_length; - botptr+=field->max_length; - hdrptr+=field->max_length; - - if(i<count-1) { - OUTPUT_TOP(f->topcross); - OUTPUT_MIDDLE(f->middlecross); - OUTPUT_BOTTOM(f->bottomcross); - OUTPUT_HEADER(f->headercellseparator); - } - } - OUTPUT_TOP(f->rightuppercorner); - OUTPUT_MIDDLE(f->rightcross); - OUTPUT_BOTTOM(f->rightdowncorner); - - OUTPUT_HEADER(f->headercellend); - OUTPUT_HEADER(f->headerrowend); - - OUTPUT(topseparator); - OUTPUT(header); - OUTPUT(middleseparator); - while(row=mysql_fetch_row(result)) { - mysql_field_seek(result,0); - - OUTPUT(f->contentrowstart); - for(i=0 ; i < mysql_field_count(sock); ++i) { - field = mysql_fetch_field(result); - OUTPUT(f->contentcellstart); - sprintf(buffptr,"%-*s",field->max_length,row[i]); - buffptr+=field->max_length; - - if(i==mysql_field_count(sock)) - { - OUTPUT(f->contentcellend); - } else { - OUTPUT(f->contentcellseparator); - } - } - OUTPUT(f->contentrowend); - } - OUTPUT(bottomseparator); - OUTPUT(f->tableend); - - mysql_free_result(result); - DBUG_VOID_RETURN; -} - - -int db_function(char *b,const char *server, const char *database,const char *table,const char *field, const char *value, const char* path, struct func_st *function) -{ - char buff[BUFLEN]; - int i; - DBUG_ENTER("db_function"); - DBUG_PRINT("enter",("buffer: '%s', database: '%s', table: '%s', field: '%s', path: '%s'", b, database, table, field,path)); - - if(*database) { - if (mysql_select_db(sock,database)) - { - printf("error when changing database to'%s'\n",database); - DBUG_RETURN(-1); - } - } - - sprintf(buff,"%s",function->function); - search_and_replace("$database",database,buff); - search_and_replace("$table",table,buff); - search_and_replace("$field",field,buff); - search_and_replace("$value",value,buff); - DBUG_PRINT("info",("path: '%s'",path)); - DBUG_PRINT("info",("sum: '%d'",(database[0] ? strlen(database)+1 : 0) +(table[0] ? strlen(table)+1 : 0) +(field[0] ? strlen(field)+1 : 0) +(value[0] ? strlen(value)+1 : 0) +1)); - search_and_replace("$*",path+ - (server[0] ? strlen(server)+1 : 0) + - (database[0] ? strlen(database)+1 : 0) + - (table[0] ? strlen(table)+1 : 0) + - (field[0] ? strlen(field)+1 : 0) + - (value[0] ? strlen(value)+1 : 0) + - function->length + - 1,buff); - DBUG_PRINT("info",("Executing constructed function query: '%s'", buff)); - if (mysql_query(sock, buff)) - { - printf("error when executing '%s'\n",buff); - sprintf(b,"ERROR %d: %s",mysql_error(sock),mysql_error(sock)); - DBUG_VOID_RETURN; - } - - db_show_result(sock, b, &Human); - DBUG_PRINT("info",("Returning: %s", b)); - DBUG_RETURN(1); -} - -int db_show_field(char *b,const char *database,const char *table, const char *field,const char *value, const char *param) -{ - MYSQL_RES *result; - MYSQL_ROW row; - char buff[BUFLEN]; - int i=0; - my_string *ptr; - DBUG_ENTER("db_show_field"); - DBUG_PRINT("enter",("buffer: '%s', database: '%s', table: '%s', field: '%s' value: '%s'", b, database, table, field, value)); - - /* We cant output fields when one of these variables is missing */ - if (!(database[0] && table[0] && field[0])) - DBUG_RETURN(-1); - - my_init_dynamic_array(&field_array, sizeof(buff), 4096, 1024); - - if (mysql_select_db(sock,database)) - { - printf("error when changing database to'%s'\n",database); - delete_dynamic(&field_array); - DBUG_RETURN(-1); - } - - if(param) { - sprintf(buff,"%s",param); - } else { - sprintf(buff,"select %s from %s where %s='%s' LIMIT 1",field,table,field,value); - } - if (mysql_query(sock, buff)) - { - printf("error when executing '%s'\n",buff); - delete_dynamic(&field_array); - DBUG_RETURN(-1); - } - - - db_show_result(sock,b,&Human); -/* if(result=mysql_use_result(sock)) { - while(row=mysql_fetch_row(result)) - { - strcpy(&b[i][BUFLEN],row[0]); - DBUG_PRINT("info",("field %s at %x", &b[i*BUFLEN],&b[i*BUFLEN])); -// ptr = (*dynamic_element(&field_array,i,row[0])); - i++; - } - } -// fix_filenames((char *)b); - mysql_free_result(result); - */ - delete_dynamic(&field_array); - DBUG_RETURN(i); - -} -int db_show_fields(char *b,const char *database,const char *table) -{ - MYSQL_RES *result; - MYSQL_ROW row; - MYSQL_FIELD *field; - char buff[BUFLEN]; - int i=0; - - DBUG_ENTER("show_fields"); - DBUG_PRINT("enter",("buffer: '%s', database: '%s', table: '%s'", b, database, table)); - if (mysql_select_db(sock,database)) - { - printf("error when changing database to'%s'\n",database); - DBUG_RETURN(-1); - } - if(result=mysql_list_fields(sock,buff,NULL)) { - - while(row=mysql_fetch_row(result)) - { - strcpy(&b[i*BUFLEN],row[0]); - DBUG_PRINT("info",("field %s at %x", &b[i*BUFLEN],&b[i*BUFLEN])); - i++; - } - } - mysql_free_result(result); - DBUG_RETURN(i); -} - -int db_show_primary_keys(char *b,const char *database, const char *table) -{ - MYSQL_RES *result; - MYSQL_ROW row; - char buff[BUFLEN]; - char buff2[BUFLEN]; - unsigned int i; - - DBUG_ENTER("db_show_primary_keys"); - DBUG_PRINT("enter",("buffer: '%s', database: '%s', table: '%s'", b, database, table)); - if (mysql_select_db(sock,database)) - { - printf("error when changing database to '%s'\n",database); - DBUG_RETURN(-1); - } - sprintf(buff,"show keys from %s",table); - if (mysql_query(sock, buff)) - { - printf("error when executing '%s'\n",buff); - DBUG_RETURN(0); - } - buff2[0]='\0'; - if(result=mysql_use_result(sock)) { - while(row=mysql_fetch_row(result)) { - if(!strcasecmp(row[2],"PRIMARY")) { - strcat(buff2,row[4]); - strcat(buff2,",\"_\","); - } - } - buff2[strlen(buff2)-5]='\0'; - if(!buff2[0]) - DBUG_RETURN(-1); // No PRIMARY keys in table - DBUG_PRINT("info",("Keys: %s<- \n", buff2)); - } else - DBUG_RETURN(-1); // No keys in table - - sprintf(buff,"SELECT CONCAT(%s) AS X FROM %s LIMIT 256",buff2,table); - if (mysql_query(sock, buff)) - { - printf("error when executing '%s'\n",buff); - DBUG_RETURN(0); - } - i=0; - if(result=mysql_use_result(sock)) { - while(row=mysql_fetch_row(result)) - { - strcpy(&b[i*BUFLEN],row[0]); - fix_filenames(&b[i*BUFLEN]); - DBUG_PRINT("info",("primarykey %s at %x, %i", &b[i*BUFLEN],&b[i*BUFLEN],i)); - if(i++ >= MAXDIRS) - break; - } - } - mysql_free_result(result); - DBUG_RETURN(i); -} - - -int db_show_keys(char *b,const char *database, const char *table) -{ - MYSQL_RES *result; - MYSQL_ROW row; - char buff[BUFLEN]; - int i=0; - - DBUG_ENTER("show_keys"); - DBUG_PRINT("enter",("buffer: '%s', database: '%s', table: '%s'", b, database, table)); - if (mysql_select_db(sock,database)) - { - printf("error when changing database to'%s'\n",database); - DBUG_RETURN(-1); - } - sprintf(buff,"show keys from %s",table); - if (mysql_query(sock, buff)) - { - printf("error when executing '%s'\n",buff); - DBUG_RETURN(0); - } - if(result=mysql_use_result(sock)) { - while(row=mysql_fetch_row(result)) - { - strcpy(&b[i*BUFLEN],row[0]); - DBUG_PRINT("info",("Key %s at %x", &b[i*BUFLEN],&b[i*BUFLEN])); - i++; - } - } - mysql_free_result(result); - DBUG_RETURN(i); -} - - -int db_show_tables(char *b,const char *database) -{ - MYSQL_RES *result; - MYSQL_ROW row; - char buff[BUFLEN]; - int i=0; - - DBUG_ENTER("db_show_tables"); - DBUG_PRINT("enter",("buffer: '%s', database: '%s'", b, database)); - if (mysql_select_db(sock,database)) - { - printf("error when changing database to '%s'\n",database); - DBUG_RETURN(-1); - } - - if(result=mysql_list_tables(sock,NULL)) { - while(row=mysql_fetch_row(result)) - { - strcpy(&b[i*BUFLEN],row[0]); - DBUG_PRINT("info",("table %s at %x", &b[i*BUFLEN],&b[i*BUFLEN])); - i++; - } - } - mysql_free_result(result); - DBUG_RETURN(i); -} - -/* - * Finds all servers we are connected to - * and stores them in array supplied. - * returns count of servers - */ -int -db_show_servers(char *b,int size) -{ - char* bufptr; - char* buff[BUFLEN*2]; - DBUG_ENTER("db_show_servers"); - DBUG_PRINT("enter",("buffer: '%s', size: '%d'", b, size)); - bufptr=mysql_get_host_info(sock); - // FIXME: Actually we need to escape prohibited symbols in filenames - fix_filenames(bufptr); - strcpy(b,bufptr); - DBUG_RETURN(1); -} - -/* - * Finds all databases in server - * and stores them in array supplied. - * returns count of databases - */ -int -db_show_databases(char *b,int size) -{ - MYSQL_RES *result; - MYSQL_ROW row; - char buff[BUFLEN]; - int i=0; - - DBUG_ENTER("db_show_databases"); - DBUG_PRINT("enter",("buffer: '%s', size: '%d'", b, size)); - result=mysql_list_dbs(sock,NULL); - while(row=mysql_fetch_row(result)) - { - strcpy(&b[i*BUFLEN],row[0]); - DBUG_PRINT("info",("database %s at %x", &b[i*BUFLEN],&b[i*BUFLEN])); - i++; - } - mysql_free_result(result); - DBUG_RETURN(i); -} - -void db_load_formats() -{ - - /* In future we should read these variables - * from configuration file/database here */ - - /* HTML output */ - HTML.tablestart="<table>\n"; - - HTML.headerrowstart="<tr>"; - HTML.headercellstart="<th>"; - HTML.headercellseparator="</th><th>"; - HTML.headercellend="</th>"; - HTML.headerrowend="</tr>\n"; - HTML.headerformat=0; - - HTML.leftuppercorner=""; - HTML.rightuppercorner=""; - HTML.leftdowncorner=""; - HTML.rightdowncorner=""; - HTML.topcross=""; - HTML.middlecross=""; - HTML.bottomcross=""; - HTML.leftcross=""; - HTML.rightcross=""; - HTML.bottomcross=""; - - HTML.contentrowstart="<tr>"; - HTML.contentcellstart="<td>"; - HTML.contentcellseparator="</td><td>"; - HTML.contentcellend="</td>"; - HTML.contentrowend="</tr>\n"; - HTML.headerformat=0; - - HTML.footerrowstart=""; - HTML.footercellstart=""; - HTML.footercellseparator=""; - HTML.footercellend=""; - HTML.footerrowend="\n"; - HTML.footerformat=0; - - HTML.tableend="</table>\n"; - -/* Nice to look mysql client like output */ - - Human.tablestart="\n"; - - Human.headerrowstart="| "; - Human.headercellstart=""; - Human.headercellseparator=" | "; - Human.headercellend=" |"; - Human.headerrowend="\n"; - Human.headerformat=1; - - Human.leftuppercorner="/="; - Human.rightuppercorner="=\\\n"; - Human.leftdowncorner="\\="; - Human.rightdowncorner="=/\n"; - Human.leftcross="+-"; - Human.rightcross="-+\n"; - Human.topcross="=T="; - Human.middlecross="-+-"; - Human.bottomcross="=`="; - - Human.contentrowstart="| "; - Human.contentcellstart=""; - Human.contentcellseparator=" | "; - Human.contentcellend=" |"; - Human.contentrowend="\n"; - Human.contentformat=1; - - Human.footerrowstart=""; - Human.footercellstart=""; - Human.footercellseparator=""; - Human.footercellend=""; - Human.footerrowend="\n"; - Human.footerformat=1; - - Human.tableend="\n"; - -/* Comma-separated format. For machine reading */ - - /* XML */ - -/* - tee_fprintf(PAGER,"<?xml version=\"1.0\"?>\n\n<resultset statement=\"%s\">", statement); - (void) tee_fputs("\n <row>\n", PAGER); - data=(char*) my_malloc(lengths[i]*5+1, MYF(MY_WME)); - tee_fprintf(PAGER, "\t<%s>", (fields[i].name ? - (fields[i].name[0] ? fields[i].name : - " ") : "NULL")); - xmlencode(data, cur[i]); - tee_fprintf(PAGER, "</%s>\n", (fields[i].name ? - (fields[i].name[0] ? fields[i].name : - " ") : "NULL")); - </row>\n" </resultset>\n*/ -} - -gptr db_load_functions() -{ - char *functions[]={ - "database",".tables","SHOW TABLES","0", - "table",".status","SHOW TABLE STATUS FROM $table","0", - "table",".count","SELECT COUNT(*) FROM $table","0", - "table",".table","SELECT * FROM $table","0", - "table",".check","CHECK TABLE $table","0", - "table",".repair","REPAIR TABLE $table","0", - "key",".min","SELECT MIN($key) FROM $table","0", - "key",".max","SELECT MAX($key) FROM $table","0", - "key",".avg","SELECT AVG($key) FROM $table","0", - "server",".uptime","SHOW STATUS like 'Uptime'","0", - "server",".version","SELECT VERSION()","0", - "server",".execute","$*","1", - "root",".connect","CONNECT $*","0", - NULL,NULL,NULL,NULL - }; - char buff[BUFLEN]; - int i=0; - struct func_st func; - DBUG_ENTER("db_load_functions"); - my_init_dynamic_array(&functions_array, sizeof(struct func_st), 4096, 1024); - while(functions[i]) { - strcpy(func.type_s, functions[i]); /* Type in string: "table"` */ - strcpy(func.filename, functions[i+1]); /* Name like it appears on FS: "count" */ - strcpy(func.function, functions[i+2]); /* Query: "SELECT COUNT(*) FROM `%table`" */ - func.continuous= atoi(functions[i+3]); /* Query: "If command can be continued" */ - - if(!strcasecmp(func.type_s,"server")) - func.type=SERVER_FUNCTION; - else if(!strcasecmp(func.type_s,"table")) - func.type=TABLE_FUNCTION; - else if(!strcasecmp(func.type_s,"key")) - func.type=KEY_FUNCTION; - else if(!strcasecmp(func.type_s,"database")) - func.type=DATABASE_FUNCTION; - else if(!strcasecmp(func.type_s,"field")) - func.type=FIELD_FUNCTION; - else if(!strcasecmp(func.type_s,"root")) - func.type=ROOT_FUNCTION; - else func.type=NONE_FUNCTION; - - func.length=strlen(func.filename); /* Filename length */ - DBUG_PRINT("info",("func.type_s: %s",func.type_s)); - DBUG_PRINT("info",("func.filename: %s",func.filename)); - DBUG_PRINT("info",("func.function: %s",func.function)); - DBUG_PRINT("info",("func.type: %d",func.type)); - DBUG_PRINT("info",("func.continuous: %d",func.continuous)); - DBUG_PRINT("info",("i: %d",i)); - insert_dynamic(&functions_array,(gptr)&func); - i+=4; - } - DBUG_RETURN((gptr)&functions_array); -} |