git.sur5r.net Git - openldap/blob - servers/slapd/back-sql/schema-map.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 "slap.h"
  18 #include "back-sql.h"
  19 #include "sql-wrap.h"
  20 #include "schema-map.h"
  21 #include "util.h"
  22
  23 int backsql_dummy(void *,void *);
  24
  25 int backsql_cmp_oc_name(backsql_oc_map_rec *m1,backsql_oc_map_rec *m2)
  26 {
  27  return strcasecmp(m1->name,m2->name);
  28 }
  29
  30 int backsql_cmp_oc_id(backsql_oc_map_rec *m1,backsql_oc_map_rec *m2)
  31 {
  32  if (m1->id < m2->id)
  33   return -1;
  34  if (m1->id > m2->id)
  35   return 1;
  36  return 0;
  37 }
  38
  39 int backsql_cmp_attr(backsql_at_map_rec *m1,backsql_at_map_rec *m2)
  40 {
  41  return strcasecmp(m1->name,m2->name);
  42 }
  43
  44 int backsql_load_schema_map(backsql_info *si,SQLHDBC dbh)
  45 {
  46  SQLHSTMT oc_sth,at_sth;
  47  RETCODE rc;
  48  BACKSQL_ROW_NTS oc_row,at_row;
  49  unsigned long oc_id;
  50  backsql_oc_map_rec *oc_map;
  51  backsql_at_map_rec *at_map;
  52  char *tmps;
  53  int tmpslen;
  54
  55  Debug(LDAP_DEBUG_TRACE,"==>load_schema_map()\n",0,0,0);
  56  rc=backsql_Prepare(dbh,&oc_sth,si->oc_query,0);
  57  if (rc != SQL_SUCCESS)
  58   {
  59    Debug(LDAP_DEBUG_TRACE,"load_schema_map(): error preparing oc_query: '%s'\n",si->oc_query,0,0);
  60    backsql_PrintErrors(si->db_env,dbh,oc_sth,rc);
  61    return -1;
  62   }
  63  rc=backsql_Prepare(dbh,&at_sth,si->at_query,0);
  64  if (rc != SQL_SUCCESS)
  65   {
  66    Debug(LDAP_DEBUG_TRACE,"load_schema_map(): error preparing at_query: '%s'\n",si->at_query,0,0);
  67    backsql_PrintErrors(si->db_env,dbh,at_sth,rc);
  68    return -1;
  69   }
  70  if ((rc=backsql_BindParamID(at_sth,1,&oc_id)) != SQL_SUCCESS)
  71   {
  72    Debug(LDAP_DEBUG_TRACE,"load_schema_map(): error binding param for at_query: \n",0,0,0);
  73    backsql_PrintErrors(si->db_env,dbh,at_sth,rc);
  74    return -1;
  75   }
  76  if ((rc=SQLExecute(oc_sth)) != SQL_SUCCESS)
  77   {
  78    Debug(LDAP_DEBUG_TRACE,"load_schema_map(): error executing oc_query: \n",0,0,0);
  79    backsql_PrintErrors(si->db_env,dbh,oc_sth,rc);
  80    return -1;
  81   }
  82  backsql_BindRowAsStrings(oc_sth,&oc_row);
  83  while ((rc=SQLFetch(oc_sth)) == SQL_SUCCESS || rc == SQL_SUCCESS_WITH_INFO)
  84   {
  85    oc_map=(backsql_oc_map_rec*)ch_calloc(1,sizeof(backsql_oc_map_rec));
  86    oc_map->id=atoi(oc_row.cols[0]);
  87    oc_map->name=ch_strdup(oc_row.cols[1]);
  88    oc_map->keytbl=ch_strdup(oc_row.cols[2]);
  89    oc_map->keycol=ch_strdup(oc_row.cols[3]);
  90    oc_map->create_proc=(oc_row.is_null[4]<0)?NULL:ch_strdup(oc_row.cols[4]);
  91    oc_map->delete_proc=(oc_row.is_null[5]<0)?NULL:ch_strdup(oc_row.cols[5]);
  92    oc_map->expect_return=atoi(oc_row.cols[6]);
  93
  94    oc_map->attrs=NULL;
  95    avl_insert(&si->oc_by_name,oc_map,(AVL_CMP)backsql_cmp_oc_name,backsql_dummy);
  96    avl_insert(&si->oc_by_id,oc_map,(AVL_CMP)backsql_cmp_oc_id,backsql_dummy);
  97    oc_id=oc_map->id;
  98    Debug(LDAP_DEBUG_TRACE,"load_schema_map(): objectclass '%s': keytbl='%s' keycol='%s' ",
  99            oc_map->name,oc_map->keytbl,oc_map->keycol);
 100    Debug(LDAP_DEBUG_TRACE,"create_proc='%s' delete_proc='%s' expect_return=%d; attributes:\n",
 101        oc_map->create_proc,oc_map->delete_proc,oc_map->expect_return);
 102    if ((rc=SQLExecute(at_sth)) != SQL_SUCCESS)
 103     {
 104      Debug(LDAP_DEBUG_TRACE,"load_schema_map(): error executing at_query: \n",0,0,0);
 105      backsql_PrintErrors(SQL_NULL_HENV,dbh,at_sth,rc);
 106      return -1;
 107     }
 108    backsql_BindRowAsStrings(at_sth,&at_row);
 109    while ((rc=SQLFetch(at_sth)) == SQL_SUCCESS || rc == SQL_SUCCESS_WITH_INFO)
 110     {
 111      Debug(LDAP_DEBUG_TRACE,"********'%s'\n",at_row.cols[0],0,0);
 112      Debug(LDAP_DEBUG_TRACE,"name='%s',sel_expr='%s' from='%s' ",at_row.cols[0],
 113              at_row.cols[1],at_row.cols[2]);
 114          Debug(LDAP_DEBUG_TRACE,"join_where='%s',add_proc='%s' modify_proc='%s' ",at_row.cols[3],
 115              at_row.cols[4],at_row.cols[5]);
 116          Debug(LDAP_DEBUG_TRACE,"delete_proc='%s'\n",at_row.cols[6],0,0);
 117      at_map=(backsql_at_map_rec*)ch_calloc(1,sizeof(backsql_at_map_rec));
 118      at_map->name=ch_strdup(at_row.cols[0]);
 119      at_map->sel_expr=ch_strdup(at_row.cols[1]);
 120          tmps=NULL;tmpslen=0;
 121          backsql_merge_from_clause(&tmps,&tmpslen,at_row.cols[2]);
 122      at_map->from_tbls=ch_strdup(tmps);
 123          ch_free(tmps);
 124          at_map->join_where=ch_strdup((at_row.is_null[3]<0)?"":at_row.cols[3]);
 125          at_map->add_proc=(at_row.is_null[4]<0)?NULL:ch_strdup(at_row.cols[4]);
 126          at_map->modify_proc=(at_row.is_null[5]<0)?NULL:ch_strdup(at_row.cols[5]);
 127          at_map->delete_proc=(at_row.is_null[6]<0)?NULL:ch_strdup(at_row.cols[6]);
 128          at_map->param_order=atoi(at_row.cols[7]);
 129          at_map->expect_return=atoi(at_row.cols[8]);
 130          tmps=NULL;tmpslen=0;
 131          tmps=backsql_strcat(tmps,&tmpslen,"SELECT ",at_map->sel_expr," AS ",at_map->name,
 132                         " FROM ",at_map->from_tbls,
 133                         " WHERE ",oc_map->keytbl,".",oc_map->keycol,"=?",NULL);
 134      if (at_map->join_where!=NULL && at_map->join_where[0]!='\0')
 135        tmps=backsql_strcat(tmps,&tmpslen," AND ",at_map->join_where,NULL);
 136          at_map->query=ch_strdup(tmps);
 137          ch_free(tmps);
 138          Debug(LDAP_DEBUG_TRACE,"load_schema_map(): preconstructed query '%s'\n",at_map->query,0,0);
 139      avl_insert(&oc_map->attrs,at_map,(AVL_CMP)backsql_cmp_attr,backsql_dummy);
 140     }
 141    backsql_FreeRow(&at_row);
 142    SQLFreeStmt(at_sth,SQL_CLOSE);
 143   }
 144  backsql_FreeRow(&oc_row);
 145  SQLFreeStmt(at_sth,SQL_DROP);
 146  SQLFreeStmt(oc_sth,SQL_DROP);
 147  si->schema_loaded=1;
 148  Debug(LDAP_DEBUG_TRACE,"<==load_schema_map()\n",0,0,0);
 149  return 1;
 150 }
 151
 152 backsql_oc_map_rec* backsql_oc_with_name(backsql_info *si,char* objclass)
 153 {
 154  backsql_oc_map_rec tmp,*res;
 155
 156 // Debug(LDAP_DEBUG_TRACE,"==>oc_with_name(): searching for objectclass with name='%s'\n",objclass,0,0);
 157  tmp.name=objclass;
 158  res=(backsql_oc_map_rec*)avl_find(si->oc_by_name,&tmp,(AVL_CMP)backsql_cmp_oc_name);
 159 // if (res!=NULL)
 160 //  Debug(LDAP_DEBUG_TRACE,"<==oc_with_name(): found name='%s', id=%d\n",res->name,res->id,0);
 161 // else
 162 //  Debug(LDAP_DEBUG_TRACE,"<==oc_with_name(): not found\n",0,0,0);
 163  return res;
 164 }
 165
 166 backsql_oc_map_rec* backsql_oc_with_id(backsql_info *si,unsigned long id)
 167 {
 168  backsql_oc_map_rec tmp,*res;
 169
 170 // Debug(LDAP_DEBUG_TRACE,"==>oc_with_id(): searching for objectclass with id='%d'\n",id,0,0);
 171  tmp.id=id;
 172  res=(backsql_oc_map_rec*)avl_find(si->oc_by_id,&tmp,(AVL_CMP)backsql_cmp_oc_id);
 173 // if (res!=NULL)
 174 //  Debug(LDAP_DEBUG_TRACE,"<==oc_with_name(): found name='%s', id=%d\n",res->name,res->id,0);
 175 // else
 176 //  Debug(LDAP_DEBUG_TRACE,"<==oc_with_name(): not found\n",0,0,0);
 177  return res;
 178 }
 179
 180 backsql_at_map_rec* backsql_at_with_name(backsql_oc_map_rec* objclass,char* attr)
 181 {
 182  backsql_at_map_rec tmp,*res;
 183
 184  //Debug(LDAP_DEBUG_TRACE,"==>at_with_name(): searching for attribute with name='%s' (for objectclass '%s')\n",
 185  //                attr,objclass->name,0);
 186  tmp.name=attr;
 187  res=(backsql_at_map_rec*)avl_find(objclass->attrs,&tmp,(AVL_CMP)backsql_cmp_attr);
 188  //if (res!=NULL)
 189   //Debug(LDAP_DEBUG_TRACE,"<==at_with_name(): found name='%s', sel_expr='%s'\n",
 190   //            res->name,res->sel_expr,0);
 191  //else
 192  // Debug(LDAP_DEBUG_TRACE,"<==at_with_name(): not found\n",0,0,0);
 193  return res;
 194 }
 195
 196 int backsql_free_attr(backsql_at_map_rec *at)
 197 {
 198  Debug(LDAP_DEBUG_TRACE,"==>free_attr(): '%s'\n",at->name,0,0);
 199  ch_free(at->name);
 200  ch_free(at->sel_expr);
 201  if (at->from_tbls!=NULL)
 202   ch_free(at->from_tbls);
 203  if (at->join_where!=NULL)
 204   ch_free(at->join_where);
 205  if (at->add_proc!=NULL)
 206   ch_free(at->add_proc);
 207  if (at->modify_proc!=NULL)
 208   ch_free(at->modify_proc);
 209  if (at->delete_proc!=NULL)
 210   ch_free(at->delete_proc);
 211  if (at->query)
 212   ch_free(at->query);
 213  ch_free(at);
 214  Debug(LDAP_DEBUG_TRACE,"<==free_attr()\n",0,0,0);
 215  return 1;
 216 }
 217
 218 int backsql_free_oc(backsql_oc_map_rec *oc)
 219 {
 220  Debug(LDAP_DEBUG_TRACE,"==>free_oc(): '%s'\n",oc->name,0,0);
 221  avl_free(oc->attrs,(AVL_FREE)backsql_free_attr);
 222  ch_free(oc->name);
 223  ch_free(oc->keytbl);
 224  ch_free(oc->keycol);
 225  if (oc->create_proc!=NULL)
 226   ch_free(oc->create_proc);
 227  if (oc->delete_proc!=NULL)
 228   ch_free(oc->delete_proc);
 229  ch_free(oc);
 230  Debug(LDAP_DEBUG_TRACE,"<==free_oc()\n",0,0,0);
 231  return 1;
 232 }
 233
 234 int backsql_destroy_schema_map(backsql_info *si)
 235 {
 236  Debug(LDAP_DEBUG_TRACE,"==>destroy_schema_map()\n",0,0,0);
 237  avl_free(si->oc_by_id,(AVL_FREE)backsql_free_oc);
 238  avl_free(si->oc_by_name,(AVL_FREE)backsql_dummy);
 239  Debug(LDAP_DEBUG_TRACE,"<==destroy_schema_map()\n",0,0,0);
 240  return 0;
 241 }
 242
 243 #endif /* SLAPD_SQL */