opensql.c

Go to the documentation of this file.

#include "str.h"
#include "slurp.h"
#include "scan.h"
#include "stralloc.h"
#include "errtxt.h"
#include "subscribe.h"
#include <mysql.h>
 
#define WHO "opensql"

 
static stralloc myp = {0};
static stralloc ers = {0};
static stralloc fn = {0};
static stralloc ourdb = {0};
static const char *ourtable = (char *) 0;
 
MYSQL *mysql = 0;

 
const char *opensql(const char *dbname,const char **table)
{
  const char *host = (char *) 0;
  unsigned long port = 0L;
  const char *db = (char*)"ezmlm";        /* default */
  const char *user = (char *) 0;
  const char *pw = (char *) 0;
  unsigned int j;
  char *cp;
 
  if (!stralloc_copys(&fn,dbname)) return ERR_NOMEM;
  if (fn.len == ourdb.len && !str_diffn(ourdb.s,fn.s,fn.len)) {
    if (table) {
      if (*table) ourtable = *table;
      else *table = ourtable;
    }
    return 0;
  }
  if (!stralloc_cats(&fn,"/sql")) return ERR_NOMEM;
  if (!stralloc_0(&fn)) return ERR_NOMEM;        /* host:port:db:table:user:pw:name */
 
  myp.len = 0;
  switch (openreadclose(fn.s,&myp,128)) {
    case -1: if (!stralloc_copys(&ers,ERR_READ)) return ERR_NOMEM;
             if (!stralloc_cat(&ers,&fn)) return ERR_NOMEM;
             if (!stralloc_0(&ers)) return ERR_NOMEM;
             return ers.s;
    case  0: return "";
  }
 
  if (!stralloc_copy(&ourdb,&fn)) return ERR_NOMEM;
  if (!stralloc_append(&myp,"\n")) return ERR_NOMEM;
  
  for (j=0; j < myp.len; ++j) {
    if (myp.s[j] == '\n') { myp.s[j] = '\0'; break; }
  }                                              /* get connection parameters */
  if (!stralloc_0(&myp)) return ERR_NOMEM;
 
  host = myp.s;                                  /* parameter parsing ;-) */
  if (myp.s[j = str_chr(myp.s,':')]) {
    cp = myp.s + j++;
    *(cp++) = '\0';
    scan_ulong(cp,&port);
    if (myp.s[j += str_chr(myp.s+j,':')]) {
      j++;
      user = myp.s + j;
      if (myp.s[j += str_chr(myp.s+j,':')]) {
        pw = myp.s + j;
        myp.s[j++] = '\0';
        if (myp.s[j += str_chr(myp.s+j,':')]) {
          db = myp.s + j;
          myp.s[j++] = '\0';
          if (myp.s[j += str_chr(myp.s+j,':')]) {
            ourtable = myp.s + j;
            myp.s[j++] = '\0';
          }
        }
      }
    }
  }
  if (host && !*host) host = (char *) 0;
  if (user && !*user) user = (char *) 0;
  if (pw && !*pw) pw = (char *) 0;
  if (db && !*db) db = (char *) 0;
  if (ourtable && !*ourtable) ourtable = (char *) 0;
 
  if (table) {
    if (*table) ourtable = *table;
    else *table = ourtable;
    if (!*table) return ERR_NO_TABLE;
  }
 
  if (!mysql) {
    if (!(mysql = mysql_init((MYSQL *) 0)))
     return ERR_NOMEM;                                     /* init */
    if (!(mysql_real_connect(mysql, host, user, pw, db,
    (unsigned int) port, 0, CLIENT_COMPRESS)))             /* conn */
        return mysql_error(mysql);
  }
 
  return (char *) 0;
}

 
void closesql(void)
{
  if (mysql)
    mysql_close(mysql);
  mysql = 0;                                               /* destroy pointer */
  ourdb.len = 0;                                           /* destroy cache */
 
  return;
}