git.sur5r.net Git - openldap/blob - servers/slapd/back-sql/util.c

   1 /*
   2  *       Copyright 1999, Dmitry Kovalev <mit@openldap.org>, All rights reserved.
   3  *
   4  *       Redistribution and use in source and binary forms are permitted only
   5  *       as authorized by the OpenLDAP Public License.  A copy of this
   6  *       license is available at http://www.OpenLDAP.org/license.html or
   7  *       in file LICENSE in the top-level directory of the distribution.
   8  */
   9
  10 #include "portable.h"
  11
  12 #ifdef SLAPD_SQL
  13
  14 #include <stdio.h>
  15 #include <sys/types.h>
  16 #include <string.h>
  17 #include <stdarg.h>
  18 #include "slap.h"
  19 #include "back-sql.h"
  20 #include "schema-map.h"
  21 #include "util.h"
  22
  23
  24 char backsql_def_oc_query[]="SELECT id,name,keytbl,keycol,create_proc,delete_proc,expect_return FROM ldap_oc_mappings";
  25 char backsql_def_at_query[]="SELECT name,sel_expr,from_tbls,join_where,add_proc,
  26 delete_proc,param_order,expect_return,sel_expr_u FROM ldap_attr_mappings WHERE oc_map_id=?";
  27 char backsql_def_delentry_query[]="DELETE FROM ldap_entries WHERE id=?";
  28 char backsql_def_insentry_query[]="INSERT INTO ldap_entries (dn,oc_map_id,parent,keyval) VALUES (?,?,?,?)";
  29 char backsql_def_subtree_cond[]="ldap_entries.dn LIKE CONCAT('%',?)";
  30 char backsql_id_query[]="SELECT id,keyval,oc_map_id FROM ldap_entries WHERE ";
  31
  32 // TimesTen
  33 char backsql_check_dn_ru_query[] = "SELECT dn_ru from ldap_entries";
  34
  35 char* backsql_strcat(char* dest,int *buflen, ...)
  36 {
  37  va_list strs;
  38  int cdlen,cslen,grow;
  39  char *cstr;
  40
  41  //Debug(LDAP_DEBUG_TRACE,"==>my_strcat()\n");
  42  va_start(strs,buflen);
  43  if (dest==NULL || *buflen<=0)
  44   {
  45    dest=(char*)ch_calloc(BACKSQL_STR_GROW,sizeof(char));
  46    *buflen=BACKSQL_STR_GROW;
  47   }
  48  cdlen=strlen(dest)+1;
  49  while ((cstr=va_arg(strs,char*)) != NULL)
  50   {
  51    cslen=strlen(cstr);
  52    grow=BACKSQL_MAX(BACKSQL_STR_GROW,cslen);
  53    if (*buflen-cdlen < cslen)
  54     {
  55      //Debug(LDAP_DEBUG_TRACE,"my_strcat(): buflen=%d, cdlen=%d, cslen=%d -- reallocating dest\n",
  56      //                     *buflen,cdlen,cslen);
  57      dest=(char*)ch_realloc(dest,(*buflen)+grow*sizeof(char));
  58      if (dest == NULL)
  59       {
  60        Debug(LDAP_DEBUG_ANY,"my_strcat(): could not reallocate string buffer.\n",0,0,0);
  61       }
  62      *buflen+=grow;
  63      //Debug(LDAP_DEBUG_TRACE,"my_strcat(): new buflen=%d, dest=%p\n",*buflen,dest,0);
  64     }
  65    strcat(dest,cstr);
  66    cdlen+=cslen;
  67   }
  68  va_end(strs);
  69  //Debug(LDAP_DEBUG_TRACE,"<==my_strcat() (dest='%s')\n",dest,0,0);
  70  return dest;
  71 }
  72
  73 int backsql_entry_addattr(Entry *e,char *at_name,char *at_val,unsigned int at_val_len)
  74 {
  75  Attribute *c_at=e->e_attrs;
  76  struct berval* add_val[2];
  77  struct berval cval;
  78  AttributeDescription *ad;
  79  int rc;
  80  const char *text;
  81
  82  Debug(LDAP_DEBUG_TRACE,"backsql_entry_addattr(): at_name='%s', at_val='%s'\n",at_name,at_val,0);
  83  cval.bv_val=at_val;
  84  cval.bv_len=at_val_len;
  85  add_val[0]=&cval;
  86  add_val[1]=NULL;
  87
  88  ad=NULL;
  89  rc = slap_str2ad( at_name, &ad, &text );
  90  if( rc != LDAP_SUCCESS )
  91   {
  92    Debug(LDAP_DEBUG_TRACE,"backsql_entry_addattr(): failed to find AttributeDescription for '%s'\n",at_name,0,0);
  93    return 0;
  94   }
  95
  96  rc = attr_merge(e,ad,add_val);
  97  ad_free( ad, 1 );
  98
  99  if( rc != 0 )
 100   {
 101    Debug(LDAP_DEBUG_TRACE,"backsql_entry_addattr(): failed to merge value '%s' for attribute '%s'\n",at_val,at_name,0);
 102    return 0;
 103   }
 104
 105  Debug(LDAP_DEBUG_TRACE,"<==backsql_query_addattr()\n",0,0,0);
 106  return 1;
 107 }
 108
 109 char* backsql_get_table_spec(char **p)
 110 {
 111  char *s,*q;
 112  char *res=NULL;
 113  int res_len=0;
 114
 115  s=*p;
 116  while(**p && **p!=',') (*p)++;
 117  if (**p)
 118   *(*p)++='\0';
 119
 120 #define BACKSQL_NEXT_WORD  {while (*s && isspace(*s)) s++; if (!*s) return res; q=s; while (*q && !isspace(*q)) q++; if (*q) *q++='\0';}
 121  BACKSQL_NEXT_WORD;
 122  res=backsql_strcat(res,&res_len,s,NULL);//table name
 123  s=q;
 124
 125  BACKSQL_NEXT_WORD;
 126  if (!strcasecmp(s,"as"))
 127  {
 128   s=q;
 129   BACKSQL_NEXT_WORD;
 130  }
 131  //res=backsql_strcat(res,&res_len," AS ",s,NULL);//table alias
 132  //oracle doesn't understand AS :(
 133  res=backsql_strcat(res,&res_len," ",s,NULL);//table alias
 134  return res;
 135 }
 136
 137 int backsql_merge_from_clause(char **dest_from,int *dest_len,char *src_from)
 138 {
 139  char *s,*p,*srcc,*pos,e;
 140
 141  //Debug(LDAP_DEBUG_TRACE,"==>backsql_merge_from_clause(): dest_from='%s',src_from='%s'\n",
 142  //                             dest_from,src_from,0);
 143  srcc=ch_strdup(src_from);
 144  p=srcc;
 145  while(*p)
 146  {
 147   s=backsql_get_table_spec(&p);
 148  // Debug(LDAP_DEBUG_TRACE,"backsql_merge_from_clause(): p='%s' s='%s'\n",p,s,0);
 149   if (*dest_from==NULL)
 150    *dest_from=backsql_strcat(*dest_from,dest_len,s,NULL);
 151   else
 152         if((pos=strstr(*dest_from,s))==NULL)
 153      *dest_from=backsql_strcat(*dest_from,dest_len,",",s,NULL);
 154     else if((e=pos[strlen(s)])!='\0' && e!=',')
 155       *dest_from=backsql_strcat(*dest_from,dest_len,",",s,NULL);
 156   if (s)
 157         ch_free(s);
 158  }
 159 // Debug(LDAP_DEBUG_TRACE,"<==backsql_merge_from_clause()\n",0,0,0);
 160  free(srcc);
 161  return 1;
 162 }
 163
 164 #endif /* SLAPD_SQL */