r12427: Move SAMR CreateUser2 to transactions, and re-add support for
[samba.git] / source / rpc_server / samr / dcesrv_samr.c
index 9934a502dec043dc825910d74d18415cac311bea..42be226022a3c7bbea193a135ca754ec2598f3bc 100644 (file)
@@ -60,12 +60,13 @@ static NTSTATUS samr_Connect(struct dcesrv_call_state *dce_call, TALLOC_CTX *mem
        }
 
        /* make sure the sam database is accessible */
-       c_state->sam_ctx = samdb_connect(c_state);
+       c_state->sam_ctx = samdb_connect(c_state, dce_call->conn->auth_state.session_info); 
        if (c_state->sam_ctx == NULL) {
                talloc_free(c_state);
                return NT_STATUS_INVALID_SYSTEM_SERVICE;
        }
 
+
        handle = dcesrv_handle_new(dce_call->context, SAMR_HANDLE_CONNECT);
        if (!handle) {
                talloc_free(c_state);
@@ -160,9 +161,13 @@ static NTSTATUS samr_LookupDomain(struct dcesrv_call_state *dce_call, TALLOC_CTX
 {
        struct samr_connect_state *c_state;
        struct dcesrv_handle *h;
-       struct dom_sid2 *sid;
-       const char *sidstr;
-               
+       struct dom_sid *sid;
+       const char * const dom_attrs[] = { "objectSid", NULL};
+       const char * const ref_attrs[] = { "ncName", NULL};
+       struct ldb_message **dom_msgs;
+       struct ldb_message **ref_msgs;
+       int ret;
+
        r->out.sid = NULL;
 
        DCESRV_PULL_HANDLE(h, r->in.connect_handle, SAMR_HANDLE_CONNECT);
@@ -173,19 +178,34 @@ static NTSTATUS samr_LookupDomain(struct dcesrv_call_state *dce_call, TALLOC_CTX
                return NT_STATUS_INVALID_PARAMETER;
        }
 
-       sidstr = samdb_search_string(c_state->sam_ctx,
-                                    mem_ctx, NULL, "objectSid",
-                                    "(&(name=%s)(objectclass=domain))",
-                                    r->in.domain_name->string);
-       if (sidstr == NULL) {
-               return NT_STATUS_NO_SUCH_DOMAIN;
+       if (strcasecmp(r->in.domain_name->string, "BUILTIN") == 0) {
+               ret = gendb_search(c_state->sam_ctx,
+                                  mem_ctx, NULL, &dom_msgs, dom_attrs,
+                                  "(objectClass=builtinDomain)");
+       } else {
+               ret = gendb_search(c_state->sam_ctx,
+                                  mem_ctx, NULL, &ref_msgs, ref_attrs,
+                                  "(&(&(nETBIOSName=%s)(objectclass=crossRef))(ncName=*))", 
+                                  ldb_binary_encode_string(mem_ctx, r->in.domain_name->string));
+               if (ret != 1) {
+                       return NT_STATUS_NO_SUCH_DOMAIN;
+               }
+               
+               ret = gendb_search_dn(c_state->sam_ctx, mem_ctx, 
+                                     samdb_result_dn(mem_ctx,
+                                                     ref_msgs[0], "ncName", NULL), 
+                                     &dom_msgs, dom_attrs);
        }
 
-       sid = dom_sid_parse_talloc(mem_ctx, sidstr);
+       if (ret != 1) {
+               return NT_STATUS_NO_SUCH_DOMAIN;
+       }
+       
+       sid = samdb_result_dom_sid(mem_ctx, dom_msgs[0],
+                                  "objectSid");
+               
        if (sid == NULL) {
-               DEBUG(0,("samdb: Invalid sid '%s' for domain %s\n",
-                        sidstr, r->in.domain_name->string));
-               return NT_STATUS_INTERNAL_DB_CORRUPTION;
+               return NT_STATUS_NO_SUCH_DOMAIN;
        }
 
        r->out.sid = sid;
@@ -205,8 +225,11 @@ static NTSTATUS samr_EnumDomains(struct dcesrv_call_state *dce_call, TALLOC_CTX
        struct samr_connect_state *c_state;
        struct dcesrv_handle *h;
        struct samr_SamArray *array;
-       const char **domains;
        int count, i, start_i;
+       const char * const dom_attrs[] = { "cn", NULL};
+       const char * const ref_attrs[] = { "nETBIOSName", NULL};
+       struct ldb_message **dom_msgs;
+       struct ldb_message **ref_msgs;
 
        *r->out.resume_handle = 0;
        r->out.sam = NULL;
@@ -216,9 +239,9 @@ static NTSTATUS samr_EnumDomains(struct dcesrv_call_state *dce_call, TALLOC_CTX
 
        c_state = h->data;
 
-       count = samdb_search_string_multiple(c_state->sam_ctx,
-                                            mem_ctx, NULL, &domains, 
-                                            "name", "(objectclass=domain)");
+       count = gendb_search(c_state->sam_ctx,
+                          mem_ctx, NULL, &dom_msgs, dom_attrs,
+                          "(objectClass=domain)");
        if (count == -1) {
                DEBUG(0,("samdb: no domains found in EnumDomains\n"));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
@@ -247,8 +270,18 @@ static NTSTATUS samr_EnumDomains(struct dcesrv_call_state *dce_call, TALLOC_CTX
        }
 
        for (i=0;i<count-start_i;i++) {
+               int ret;
                array->entries[i].idx = start_i + i;
-               array->entries[i].name.string = domains[start_i+i];
+               /* try and find the domain */
+               ret = gendb_search(c_state->sam_ctx, mem_ctx, NULL, 
+                                  &ref_msgs, ref_attrs, 
+                                  "(&(objectClass=crossRef)(ncName=%s))", 
+                                  ldb_dn_linearize(mem_ctx, dom_msgs[i]->dn));
+               if (ret == 1) {
+                       array->entries[i].name.string = samdb_result_string(ref_msgs[0], "nETBIOSName", NULL);
+               } else {
+                       array->entries[i].name.string = samdb_result_string(dom_msgs[i], "cn", NULL);
+               }
        }
 
        r->out.sam = array;
@@ -266,11 +299,13 @@ static NTSTATUS samr_OpenDomain(struct dcesrv_call_state *dce_call, TALLOC_CTX *
                                struct samr_OpenDomain *r)
 {
        struct dcesrv_handle *h_conn, *h_domain;
-       const char *sidstr, *domain_name;
+       const char *domain_name;
        struct samr_connect_state *c_state;
        struct samr_domain_state *d_state;
-       const char * const attrs[2] = { "name", NULL};
-       struct ldb_message **msgs;
+       const char * const dom_attrs[] = { "cn", NULL};
+       const char * const ref_attrs[] = { "nETBIOSName", NULL};
+       struct ldb_message **dom_msgs;
+       struct ldb_message **ref_msgs;
        int ret;
 
        ZERO_STRUCTP(r->out.domain_handle);
@@ -283,22 +318,31 @@ static NTSTATUS samr_OpenDomain(struct dcesrv_call_state *dce_call, TALLOC_CTX *
                return NT_STATUS_INVALID_PARAMETER;
        }
 
-       sidstr = dom_sid_string(mem_ctx, r->in.sid);
-       if (sidstr == NULL) {
-               return NT_STATUS_INVALID_PARAMETER;
-       }
-
        ret = gendb_search(c_state->sam_ctx,
-                          mem_ctx, NULL, &msgs, attrs,
-                          "(&(objectSid=%s)(objectclass=domain))", 
-                          sidstr);
+                          mem_ctx, NULL, &dom_msgs, dom_attrs,
+                          "(&(objectSid=%s)(&(objectclass=domain)))",
+                          ldap_encode_ndr_dom_sid(mem_ctx, r->in.sid));
        if (ret != 1) {
-               return NT_STATUS_NO_SUCH_DOMAIN;
-       }
-
-       domain_name = ldb_msg_find_string(msgs[0], "name", NULL);
-       if (domain_name == NULL) {
-               return NT_STATUS_NO_SUCH_DOMAIN;
+               return NT_STATUS_INTERNAL_DB_CORRUPTION;
+       } else {
+               ret = gendb_search(c_state->sam_ctx,
+                                  mem_ctx, NULL, &ref_msgs, ref_attrs,
+                                  "(&(&(nETBIOSName=*)(objectclass=crossRef))(ncName=%s))", 
+                                  ldb_dn_linearize(mem_ctx, dom_msgs[0]->dn));
+               if (ret == 0) {
+                       domain_name = ldb_msg_find_string(dom_msgs[0], "cn", NULL);
+                       if (domain_name == NULL) {
+                               return NT_STATUS_NO_SUCH_DOMAIN;
+                       }
+               } else if (ret == 1) {
+               
+                       domain_name = ldb_msg_find_string(ref_msgs[0], "nETBIOSName", NULL);
+                       if (domain_name == NULL) {
+                               return NT_STATUS_NO_SUCH_DOMAIN;
+                       }
+               } else {
+                       return NT_STATUS_NO_SUCH_DOMAIN;
+               }
        }
 
        d_state = talloc(c_state, struct samr_domain_state);
@@ -308,9 +352,9 @@ static NTSTATUS samr_OpenDomain(struct dcesrv_call_state *dce_call, TALLOC_CTX *
 
        d_state->connect_state = talloc_reference(d_state, c_state);
        d_state->sam_ctx = c_state->sam_ctx;
-       d_state->domain_sid = talloc_strdup(d_state, sidstr);
+       d_state->domain_sid = dom_sid_dup(d_state, r->in.sid);
        d_state->domain_name = talloc_strdup(d_state, domain_name);
-       d_state->domain_dn = talloc_strdup(d_state, msgs[0]->dn);
+       d_state->domain_dn = ldb_dn_copy(d_state, dom_msgs[0]->dn);
        if (!d_state->domain_sid || !d_state->domain_name || !d_state->domain_dn) {
                talloc_free(d_state);
                return NT_STATUS_NO_MEMORY;             
@@ -343,8 +387,8 @@ static NTSTATUS samr_info_DomInfo1(struct samr_domain_state *state,
        int ret;
        struct ldb_message **res;
 
-       ret = gendb_search(state->sam_ctx, mem_ctx, NULL, &res, attrs, 
-                          "dn=%s", state->domain_dn);
+       ret = gendb_search_dn(state->sam_ctx, mem_ctx,
+                             state->domain_dn , &res, attrs);
        if (ret != 1) {
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
@@ -369,21 +413,23 @@ static NTSTATUS samr_info_DomInfo1(struct samr_domain_state *state,
 static NTSTATUS samr_info_DomInfo2(struct samr_domain_state *state, TALLOC_CTX *mem_ctx,
                                   struct samr_DomInfo2 *info)
 {
-       const char * const attrs[] = { "comment", "name", NULL };
+       const char * const dom_attrs[] = { "comment", NULL };
        int ret;
-       struct ldb_message **res;
-
-       ret = gendb_search(state->sam_ctx, mem_ctx, NULL, &res, attrs, 
-                          "dn=%s", state->domain_dn);
+       struct ldb_message **dom_msgs;
+       const char *domain_name;
+       
+       ret = gendb_search_dn(state->sam_ctx, mem_ctx,
+                             state->domain_dn, &dom_msgs, dom_attrs);
        if (ret != 1) {
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
+       domain_name = state->domain_name;
        /* where is this supposed to come from? is it settable? */
        info->force_logoff_time = 0x8000000000000000LL;
 
-       info->comment.string = samdb_result_string(res[0], "comment", NULL);
-       info->domain_name.string  = samdb_result_string(res[0], "name", NULL);
+       info->comment.string = samdb_result_string(dom_msgs[0], "comment", NULL);
+       info->domain_name.string  = domain_name;
 
        info->primary.string = lp_netbios_name();
        info->sequence_num = 0;
@@ -470,7 +516,7 @@ static NTSTATUS samr_CreateDomainGroup(struct dcesrv_call_state *dce_call, TALLO
        const char *name;
        struct ldb_message *msg;
        struct dom_sid *sid;
-       const char *groupname, *sidstr;
+       const char *groupname;
        struct dcesrv_handle *g_handle;
        int ret;
 
@@ -491,7 +537,7 @@ static NTSTATUS samr_CreateDomainGroup(struct dcesrv_call_state *dce_call, TALLO
        name = samdb_search_string(d_state->sam_ctx, mem_ctx, NULL, 
                                   "sAMAccountName",
                                   "(&(sAMAccountName=%s)(objectclass=group))",
-                                  groupname);
+                                  ldb_binary_encode_string(mem_ctx, groupname));
        if (name != NULL) {
                return NT_STATUS_GROUP_EXISTS;
        }
@@ -502,8 +548,8 @@ static NTSTATUS samr_CreateDomainGroup(struct dcesrv_call_state *dce_call, TALLO
        }
 
        /* add core elements to the ldb_message for the user */
-       msg->dn = talloc_asprintf(mem_ctx, "CN=%s,CN=Users,%s", groupname,
-                                 d_state->domain_dn);
+       msg->dn = ldb_dn_string_compose(mem_ctx, d_state->domain_dn,
+                                       "CN=%s, CN=Users", groupname);
        if (!msg->dn) {
                return NT_STATUS_NO_MEMORY;
        }
@@ -513,7 +559,8 @@ static NTSTATUS samr_CreateDomainGroup(struct dcesrv_call_state *dce_call, TALLO
        /* create the group */
        ret = samdb_add(d_state->sam_ctx, mem_ctx, msg);
        if (ret != 0) {
-               DEBUG(0,("Failed to create group record %s\n", msg->dn));
+               DEBUG(0,("Failed to create group record %s\n",
+                        ldb_dn_linearize(mem_ctx, msg->dn)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
@@ -526,12 +573,10 @@ static NTSTATUS samr_CreateDomainGroup(struct dcesrv_call_state *dce_call, TALLO
        a_state->domain_state = talloc_reference(a_state, d_state);
        a_state->account_dn = talloc_steal(a_state, msg->dn);
 
-       /* retrieve the sidstring for the group just created */
-       sidstr = samdb_search_string(d_state->sam_ctx, a_state, NULL, 
-                                  "objectSid",
-                                  "dn=%s",
-                                  msg->dn);
-       if (sidstr == NULL) {
+       /* retrieve the sid for the group just created */
+       sid = samdb_search_dom_sid(d_state->sam_ctx, a_state,
+                                  msg->dn, "objectSid", NULL);
+       if (sid == NULL) {
                return NT_STATUS_UNSUCCESSFUL;
        }
 
@@ -549,11 +594,6 @@ static NTSTATUS samr_CreateDomainGroup(struct dcesrv_call_state *dce_call, TALLO
        g_handle->data = talloc_steal(g_handle, a_state);
 
        *r->out.group_handle = g_handle->wire_handle;
-
-       sid = dom_sid_parse_talloc(mem_ctx, sidstr);
-       if (!sid)
-               return NT_STATUS_UNSUCCESSFUL;
-
        *r->out.rid = sid->sub_auths[sid->num_auths-1];
 
        return NT_STATUS_OK;
@@ -580,7 +620,6 @@ static NTSTATUS samr_EnumDomainGroups(struct dcesrv_call_state *dce_call, TALLOC
        int ldb_cnt, count, i, first;
        struct samr_SamEntry *entries;
        const char * const attrs[3] = { "objectSid", "sAMAccountName", NULL };
-       struct dom_sid *domain_sid;
 
        *r->out.resume_handle = 0;
        r->out.sam = NULL;
@@ -590,15 +629,11 @@ static NTSTATUS samr_EnumDomainGroups(struct dcesrv_call_state *dce_call, TALLOC
 
        d_state = h->data;
 
-       domain_sid = dom_sid_parse_talloc(mem_ctx, d_state->domain_sid);
-       if (domain_sid == NULL)
-               return NT_STATUS_NO_MEMORY;
-       
        /* search for all domain groups in this domain. This could possibly be
           cached and resumed based on resume_key */
        ldb_cnt = samdb_search_domain(d_state->sam_ctx, mem_ctx,
                                      d_state->domain_dn, &res, attrs,
-                                     domain_sid,
+                                     d_state->domain_sid,
                                      "(&(grouptype=%s)(objectclass=group))",
                                      ldb_hexstr(mem_ctx,
                                                 GTYPE_SECURITY_GLOBAL_GROUP));
@@ -682,10 +717,22 @@ static NTSTATUS samr_CreateUser2(struct dcesrv_call_state *dce_call, TALLOC_CTX
        const char *name;
        struct ldb_message *msg;
        struct dom_sid *sid;
-       const char *account_name, *sidstr;
+       const char *account_name;
        struct dcesrv_handle *u_handle;
        int ret;
-       const char *container, *class=NULL;
+       const char *container, *obj_class=NULL;
+       char *cn_name;
+       int cn_name_len;
+
+       const char *attrs[] = {
+               "objectSid", 
+               "userAccountControl",
+               NULL
+       };
+
+       uint32_t user_account_control;
+
+       struct ldb_message **msgs;
 
        ZERO_STRUCTP(r->out.user_handle);
        *r->out.access_granted = 0;
@@ -701,56 +748,85 @@ static NTSTATUS samr_CreateUser2(struct dcesrv_call_state *dce_call, TALLOC_CTX
                return NT_STATUS_INVALID_PARAMETER;
        }
 
+       ret = ldb_transaction_start(d_state->sam_ctx);
+       if (ret != 0) {
+               DEBUG(0,("Failed to start a transaction for user creation\n"));
+               return NT_STATUS_INTERNAL_DB_CORRUPTION;
+       }
+
        /* check if the user already exists */
        name = samdb_search_string(d_state->sam_ctx, mem_ctx, NULL, 
                                   "sAMAccountName", 
-                                  "(&(sAMAccountName=%s)(objectclass=user))", account_name);
+                                  "(&(sAMAccountName=%s)(objectclass=user))", 
+                                  ldb_binary_encode_string(mem_ctx, account_name));
        if (name != NULL) {
+               ldb_transaction_cancel(d_state->sam_ctx);
                return NT_STATUS_USER_EXISTS;
        }
 
        msg = ldb_msg_new(mem_ctx);
        if (msg == NULL) {
+               ldb_transaction_cancel(d_state->sam_ctx);
                return NT_STATUS_NO_MEMORY;
        }
 
+       cn_name   = talloc_strdup(mem_ctx, account_name);
+       NT_STATUS_HAVE_NO_MEMORY(cn_name);
+       cn_name_len = strlen(cn_name);
+
        /* This must be one of these values *only* */
        if (r->in.acct_flags == ACB_NORMAL) {
                container = "Users";
-               class = "user";
+               obj_class = "user";
 
        } else if (r->in.acct_flags == ACB_WSTRUST) {
+               if (cn_name[cn_name_len - 1] != '$') {
+                       return NT_STATUS_FOOBAR;
+               }
+               cn_name[cn_name_len - 1] = '\0';
                container = "Computers";
-               class = "computer";
+               obj_class = "computer";
 
        } else if (r->in.acct_flags == ACB_SVRTRUST) {
+               if (cn_name[cn_name_len - 1] != '$') {
+                       return NT_STATUS_FOOBAR;                
+               }
+               cn_name[cn_name_len - 1] = '\0';
                container = "Domain Controllers";
-               class = "computer";
+               obj_class = "computer";
 
        } else if (r->in.acct_flags == ACB_DOMTRUST) {
                container = "Users";
-               class = "computer";
+               obj_class = "user";
 
        } else {
+               ldb_transaction_cancel(d_state->sam_ctx);
                return NT_STATUS_INVALID_PARAMETER;
        }
 
        /* add core elements to the ldb_message for the user */
-       msg->dn = talloc_asprintf(mem_ctx, "CN=%s,CN=%s,%s", account_name, container, d_state->domain_dn);
+       msg->dn = ldb_dn_build_child(mem_ctx, "CN", cn_name, ldb_dn_build_child(mem_ctx, "CN", container, d_state->domain_dn));
        if (!msg->dn) {
+               ldb_transaction_cancel(d_state->sam_ctx);
                return NT_STATUS_NO_MEMORY;             
        }
        samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "sAMAccountName", account_name);
-       samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "objectClass", class);
+       samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "objectClass", obj_class);
+       
+       /* Start a transaction, so we can query and do a subsequent atomic modify */
+       
        /* create the user */
        ret = samdb_add(d_state->sam_ctx, mem_ctx, msg);
        if (ret != 0) {
-               DEBUG(0,("Failed to create user record %s\n", msg->dn));
+               ldb_transaction_cancel(d_state->sam_ctx);
+               DEBUG(0,("Failed to create user record %s\n",
+                        ldb_dn_linearize(mem_ctx, msg->dn)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
        a_state = talloc(d_state, struct samr_account_state);
        if (!a_state) {
+               ldb_transaction_cancel(d_state->sam_ctx);
                return NT_STATUS_NO_MEMORY;
        }
        a_state->sam_ctx = d_state->sam_ctx;
@@ -758,16 +834,60 @@ static NTSTATUS samr_CreateUser2(struct dcesrv_call_state *dce_call, TALLOC_CTX
        a_state->domain_state = talloc_reference(a_state, d_state);
        a_state->account_dn = talloc_steal(a_state, msg->dn);
 
-       /* retrieve the sidstring for the group just created */
-       sidstr = samdb_search_string(d_state->sam_ctx, a_state, NULL, 
-                                  "objectSid",
-                                  "dn=%s",
-                                  msg->dn);
-       if (sidstr == NULL) {
+       /* retrieve the sid and account control bits for the user just created */
+       ret = gendb_search_dn(d_state->sam_ctx, a_state,
+                             msg->dn, &msgs, attrs);
+
+       if (ret != 1) {
+               ldb_transaction_cancel(d_state->sam_ctx);
+               DEBUG(0,("Apparently we failed to create an account record, as %s now doesn't exist\n",
+                        ldb_dn_linearize(mem_ctx, msg->dn)));
+               return NT_STATUS_INTERNAL_DB_CORRUPTION;
+       }
+       sid = samdb_result_dom_sid(mem_ctx, msgs[0], "objectSid");
+       if (sid == NULL) {
+               return NT_STATUS_INTERNAL_DB_CORRUPTION;
+       }
+
+       user_account_control = samdb_result_uint(msgs[0], "userAccountControl", 0);
+       user_account_control = (user_account_control & ~(UF_NORMAL_ACCOUNT|UF_INTERDOMAIN_TRUST_ACCOUNT|UF_WORKSTATION_TRUST_ACCOUNT|UF_SERVER_TRUST_ACCOUNT));
+       user_account_control |= samdb_acb2uf(r->in.acct_flags);
+
+       talloc_free(msg);
+       msg = ldb_msg_new(mem_ctx);
+       if (msg == NULL) {
+               ldb_transaction_cancel(d_state->sam_ctx);
+               return NT_STATUS_NO_MEMORY;
+       }
+
+       msg->dn = a_state->account_dn;
+
+       if (samdb_msg_add_uint(a_state->sam_ctx, mem_ctx, msg, 
+                              "userAccountControl", 
+                              user_account_control) != 0) { 
+               ldb_transaction_cancel(d_state->sam_ctx);
+               return NT_STATUS_NO_MEMORY; 
+       }
+
+       /* modify the samdb record */
+       ret = samdb_replace(a_state->sam_ctx, mem_ctx, msg);
+       if (ret != 0) {
+               DEBUG(0,("Failed to modify account record %s to set userAccountControl\n",
+                        ldb_dn_linearize(mem_ctx, msg->dn)));
+               ldb_transaction_cancel(d_state->sam_ctx);
+
+               /* we really need samdb.c to return NTSTATUS */
                return NT_STATUS_UNSUCCESSFUL;
        }
 
-       a_state->account_name = talloc_strdup(a_state, account_name);
+       ldb_transaction_commit(d_state->sam_ctx);
+       if (ret != 0) {
+               DEBUG(0,("Failed to commit transaction to add and modify account record %s\n",
+                        ldb_dn_linearize(mem_ctx, msg->dn)));
+               return NT_STATUS_INTERNAL_DB_CORRUPTION;
+       }
+
+       a_state->account_name = talloc_steal(a_state, account_name);
        if (!a_state->account_name) {
                return NT_STATUS_NO_MEMORY;
        }
@@ -783,10 +903,6 @@ static NTSTATUS samr_CreateUser2(struct dcesrv_call_state *dce_call, TALLOC_CTX
        *r->out.user_handle = u_handle->wire_handle;
        *r->out.access_granted = 0xf07ff; /* TODO: fix access mask calculations */
 
-       sid = dom_sid_parse_talloc(mem_ctx, sidstr);
-       if (!sid)
-               return NT_STATUS_UNSUCCESSFUL;
-
        *r->out.rid = sid->sub_auths[sid->num_auths-1];
 
        return NT_STATUS_OK;
@@ -902,7 +1018,7 @@ static NTSTATUS samr_CreateDomAlias(struct dcesrv_call_state *dce_call, TALLOC_C
        struct samr_domain_state *d_state;
        struct samr_account_state *a_state;
        struct dcesrv_handle *h;
-       const char *alias_name, *name, *sidstr;
+       const char *alias_name, *name;
        struct ldb_message *msg;
        struct dom_sid *sid;
        struct dcesrv_handle *a_handle;
@@ -924,8 +1040,8 @@ static NTSTATUS samr_CreateDomAlias(struct dcesrv_call_state *dce_call, TALLOC_C
        /* Check if alias already exists */
        name = samdb_search_string(d_state->sam_ctx, mem_ctx, NULL,
                                   "sAMAccountName",
-                                  "(&pAMAccountName=%s)(objectclass=group))",
-                                  alias_name);
+                                  "(sAMAccountName=%s)(objectclass=group))",
+                                  ldb_binary_encode_string(mem_ctx, alias_name));
 
        if (name != NULL) {
                return NT_STATUS_ALIAS_EXISTS;
@@ -937,8 +1053,8 @@ static NTSTATUS samr_CreateDomAlias(struct dcesrv_call_state *dce_call, TALLOC_C
        }
 
        /* add core elements to the ldb_message for the alias */
-       msg->dn = talloc_asprintf(mem_ctx, "CN=%s,CN=Users,%s", alias_name,
-                                d_state->domain_dn);
+       msg->dn = ldb_dn_string_compose(mem_ctx, d_state->domain_dn,
+                                       "CN=%s, CN=Users", alias_name);
        if (!msg->dn) {
                return NT_STATUS_NO_MEMORY;
        }
@@ -950,7 +1066,8 @@ static NTSTATUS samr_CreateDomAlias(struct dcesrv_call_state *dce_call, TALLOC_C
        /* create the alias */
        ret = samdb_add(d_state->sam_ctx, mem_ctx, msg);
        if (ret != 0) {
-               DEBUG(0,("Failed to create alias record %s\n", msg->dn));
+               DEBUG(0,("Failed to create alias record %s\n",
+                        ldb_dn_linearize(mem_ctx, msg->dn)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
@@ -964,14 +1081,9 @@ static NTSTATUS samr_CreateDomAlias(struct dcesrv_call_state *dce_call, TALLOC_C
        a_state->domain_state = talloc_reference(a_state, d_state);
        a_state->account_dn = talloc_steal(a_state, msg->dn);
 
-       /* retrieve the sidstring for the group just created */
-       sidstr = samdb_search_string(d_state->sam_ctx, a_state, NULL, 
-                                  "objectSid",
-                                  "dn=%s",
-                                  msg->dn);
-       if (sidstr == NULL) {
-               return NT_STATUS_UNSUCCESSFUL;
-       }
+       /* retrieve the sid for the alias just created */
+       sid = samdb_search_dom_sid(d_state->sam_ctx, a_state,
+                                  msg->dn, "objectSid", NULL);
 
        a_state->account_name = talloc_strdup(a_state, alias_name);
        if (!a_state->account_name) {
@@ -987,10 +1099,6 @@ static NTSTATUS samr_CreateDomAlias(struct dcesrv_call_state *dce_call, TALLOC_C
 
        *r->out.alias_handle = a_handle->wire_handle;
 
-       sid = dom_sid_parse_talloc(mem_ctx, sidstr);
-       if (!sid)
-               return NT_STATUS_UNSUCCESSFUL;
-
        *r->out.rid = sid->sub_auths[sid->num_auths-1];
 
        return NT_STATUS_OK;
@@ -1009,7 +1117,6 @@ static NTSTATUS samr_EnumDomainAliases(struct dcesrv_call_state *dce_call, TALLO
        int ldb_cnt, count, i, first;
        struct samr_SamEntry *entries;
        const char * const attrs[3] = { "objectSid", "sAMAccountName", NULL };
-       struct dom_sid *domain_sid;
 
        *r->out.resume_handle = 0;
        r->out.sam = NULL;
@@ -1019,15 +1126,12 @@ static NTSTATUS samr_EnumDomainAliases(struct dcesrv_call_state *dce_call, TALLO
 
        d_state = h->data;
 
-       domain_sid = dom_sid_parse_talloc(mem_ctx, d_state->domain_sid);
-       if (domain_sid == NULL)
-               return NT_STATUS_NO_MEMORY;
-       
        /* search for all domain groups in this domain. This could possibly be
           cached and resumed based on resume_key */
        ldb_cnt = samdb_search_domain(d_state->sam_ctx, mem_ctx,
                                      d_state->domain_dn,
-                                     &res, attrs, domain_sid,
+                                     &res, attrs, 
+                                     d_state->domain_sid,
                                      "(&(|(grouptype=%s)(grouptype=%s)))"
                                      "(objectclass=group))",
                                      ldb_hexstr(mem_ctx,
@@ -1108,7 +1212,6 @@ static NTSTATUS samr_GetAliasMembership(struct dcesrv_call_state *dce_call, TALL
        struct dcesrv_handle *h;
        struct samr_domain_state *d_state;
        struct ldb_message **res;
-       struct dom_sid *domain_sid;
        int i, count = 0;
 
        DCESRV_PULL_HANDLE(h, r->in.domain_handle, SAMR_HANDLE_DOMAIN);
@@ -1130,17 +1233,14 @@ static NTSTATUS samr_GetAliasMembership(struct dcesrv_call_state *dce_call, TALL
                        return NT_STATUS_NO_MEMORY;
 
                for (i=0; i<r->in.sids->num_sids; i++) {
-                       const char *sidstr, *memberdn;
+                       const char *memberdn;
 
-                       sidstr = dom_sid_string(mem_ctx,
-                                               r->in.sids->sids[i].sid);
-                       if (sidstr == NULL)
-                               return NT_STATUS_NO_MEMORY;
-
-                       memberdn = samdb_search_string(d_state->sam_ctx,
-                                                      mem_ctx, NULL, "dn",
-                                                      "(objectSid=%s)",
-                                                      sidstr);
+                       memberdn = 
+                               samdb_search_string(d_state->sam_ctx,
+                                                   mem_ctx, NULL, "distinguishedName",
+                                                   "(objectSid=%s)",
+                                                   ldap_encode_ndr_dom_sid(mem_ctx, 
+                                                                           r->in.sids->sids[i].sid));
 
                        if (memberdn == NULL)
                                continue;
@@ -1151,14 +1251,9 @@ static NTSTATUS samr_GetAliasMembership(struct dcesrv_call_state *dce_call, TALL
                                return NT_STATUS_NO_MEMORY;
                }
 
-               domain_sid = dom_sid_parse_talloc(mem_ctx,
-                                                 d_state->domain_sid);
-               if (domain_sid == NULL)
-                       return NT_STATUS_NO_MEMORY;
-
                count = samdb_search_domain(d_state->sam_ctx, mem_ctx,
                                            d_state->domain_dn, &res, attrs,
-                                           domain_sid, "%s))", filter);
+                                           d_state->domain_sid, "%s))", filter);
                if (count < 0)
                        return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
@@ -1221,32 +1316,26 @@ static NTSTATUS samr_LookupNames(struct dcesrv_call_state *dce_call, TALLOC_CTX
 
        for (i=0;i<r->in.num_names;i++) {
                struct ldb_message **res;
-               struct dom_sid2 *sid;
-               const char *sidstr;
+               struct dom_sid *sid;
                uint32_t atype, rtype;
 
                r->out.rids.ids[i] = 0;
                r->out.types.ids[i] = SID_NAME_UNKNOWN;
 
                count = gendb_search(d_state->sam_ctx, mem_ctx, d_state->domain_dn, &res, attrs, 
-                                    "sAMAccountName=%s", r->in.names[i].string);
+                                    "sAMAccountName=%s", 
+                                    ldb_binary_encode_string(mem_ctx, r->in.names[i].string));
                if (count != 1) {
                        status = STATUS_SOME_UNMAPPED;
                        continue;
                }
 
-               sidstr = samdb_result_string(res[0], "objectSid", NULL);
-               if (sidstr == NULL) {
-                       status = STATUS_SOME_UNMAPPED;
-                       continue;
-               }
-               
-               sid = dom_sid_parse_talloc(mem_ctx, sidstr);
+               sid = samdb_result_dom_sid(mem_ctx, res[0], "objectSid");
                if (sid == NULL) {
                        status = STATUS_SOME_UNMAPPED;
                        continue;
                }
-
+               
                atype = samdb_result_uint(res[0], "sAMAccountType", 0);
                if (atype == 0) {
                        status = STATUS_SOME_UNMAPPED;
@@ -1279,7 +1368,7 @@ static NTSTATUS samr_LookupRids(struct dcesrv_call_state *dce_call, TALLOC_CTX *
        struct samr_domain_state *d_state;
        int i, total;
        NTSTATUS status = NT_STATUS_OK;
-       struct samr_String *names;
+       struct lsa_String *names;
        uint32_t *ids;
 
        ZERO_STRUCT(r->out.names);
@@ -1292,7 +1381,7 @@ static NTSTATUS samr_LookupRids(struct dcesrv_call_state *dce_call, TALLOC_CTX *
        if (r->in.num_rids == 0)
                return NT_STATUS_OK;
 
-       names = talloc_array(mem_ctx, struct samr_String, r->in.num_rids);
+       names = talloc_array(mem_ctx, struct lsa_String, r->in.num_rids);
        ids = talloc_array(mem_ctx, uint32_t, r->in.num_rids);
 
        if ((names == NULL) || (ids == NULL))
@@ -1306,13 +1395,21 @@ static NTSTATUS samr_LookupRids(struct dcesrv_call_state *dce_call, TALLOC_CTX *
                const char * const attrs[] = {  "sAMAccountType",
                                                "sAMAccountName", NULL };
                uint32_t atype;
+               struct dom_sid *sid;
 
                ids[i] = SID_NAME_UNKNOWN;
 
+               sid = dom_sid_add_rid(mem_ctx, d_state->domain_sid, r->in.rids[i]);
+               if (sid == NULL) {
+                       names[i].string = NULL;
+                       status = STATUS_SOME_UNMAPPED;
+                       continue;
+               }
+               
                count = gendb_search(d_state->sam_ctx, mem_ctx,
                                     d_state->domain_dn, &res, attrs,
-                                    "(objectSid=%s-%u)", d_state->domain_sid,
-                                    r->in.rids[i]);
+                                    "(objectSid=%s)", 
+                                    ldap_encode_ndr_dom_sid(mem_ctx, sid));
                if (count != 1) {
                        names[i].string = NULL;
                        status = STATUS_SOME_UNMAPPED;
@@ -1355,7 +1452,8 @@ static NTSTATUS samr_OpenGroup(struct dcesrv_call_state *dce_call, TALLOC_CTX *m
        struct samr_domain_state *d_state;
        struct samr_account_state *a_state;
        struct dcesrv_handle *h;
-       const char *groupname, *sidstr;
+       const char *groupname;
+       struct dom_sid *sid;
        struct ldb_message **msgs;
        struct dcesrv_handle *g_handle;
        const char * const attrs[2] = { "sAMAccountName", NULL };
@@ -1368,8 +1466,8 @@ static NTSTATUS samr_OpenGroup(struct dcesrv_call_state *dce_call, TALLOC_CTX *m
        d_state = h->data;
 
        /* form the group SID */
-       sidstr = talloc_asprintf(mem_ctx, "%s-%u", d_state->domain_sid, r->in.rid);
-       if (!sidstr) {
+       sid = dom_sid_add_rid(mem_ctx, d_state->domain_sid, r->in.rid);
+       if (!sid) {
                return NT_STATUS_NO_MEMORY;
        }
 
@@ -1378,19 +1476,22 @@ static NTSTATUS samr_OpenGroup(struct dcesrv_call_state *dce_call, TALLOC_CTX *m
                           mem_ctx, d_state->domain_dn, &msgs, attrs,
                           "(&(objectSid=%s)(objectclass=group)"
                           "(grouptype=%s))",
-                          sidstr, ldb_hexstr(mem_ctx,
-                                             GTYPE_SECURITY_GLOBAL_GROUP));
+                          ldap_encode_ndr_dom_sid(mem_ctx, sid),
+                          ldb_hexstr(mem_ctx,
+                                     GTYPE_SECURITY_GLOBAL_GROUP));
        if (ret == 0) {
                return NT_STATUS_NO_SUCH_GROUP;
        }
        if (ret != 1) {
-               DEBUG(0,("Found %d records matching sid %s\n", ret, sidstr));
+               DEBUG(0,("Found %d records matching sid %s\n", 
+                        ret, dom_sid_string(mem_ctx, sid)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
        groupname = samdb_result_string(msgs[0], "sAMAccountName", NULL);
        if (groupname == NULL) {
-               DEBUG(0,("sAMAccountName field missing for sid %s\n", sidstr));
+               DEBUG(0,("sAMAccountName field missing for sid %s\n", 
+                        dom_sid_string(mem_ctx, sid)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
@@ -1402,7 +1503,7 @@ static NTSTATUS samr_OpenGroup(struct dcesrv_call_state *dce_call, TALLOC_CTX *m
        a_state->access_mask = r->in.access_mask;
        a_state->domain_state = talloc_reference(a_state, d_state);
        a_state->account_dn = talloc_steal(a_state, msgs[0]->dn);
-       a_state->account_sid = talloc_steal(a_state, sidstr);
+       a_state->account_sid = talloc_steal(a_state, sid);
        a_state->account_name = talloc_strdup(a_state, groupname);
        if (!a_state->account_name) {
                return NT_STATUS_NO_MEMORY;
@@ -1490,8 +1591,8 @@ static NTSTATUS samr_QueryGroupInfo(struct dcesrv_call_state *dce_call, TALLOC_C
        a_state = h->data;
 
        /* pull all the group attributes */
-       ret = gendb_search(a_state->sam_ctx, mem_ctx, NULL, &res, attrs,
-                          "dn=%s", a_state->account_dn);
+       ret = gendb_search_dn(a_state->sam_ctx, mem_ctx,
+                             a_state->account_dn, &res, attrs);
        if (ret != 1) {
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
@@ -1550,7 +1651,7 @@ static NTSTATUS samr_SetGroupInfo(struct dcesrv_call_state *dce_call, TALLOC_CTX
                return NT_STATUS_NO_MEMORY;
        }       
 
-       msg->dn = talloc_strdup(mem_ctx, a_state->account_dn);
+       msg->dn = ldb_dn_copy(mem_ctx, a_state->account_dn);
        if (!msg->dn) {
                return NT_STATUS_NO_MEMORY;
        }
@@ -1592,10 +1693,10 @@ static NTSTATUS samr_AddGroupMember(struct dcesrv_call_state *dce_call, TALLOC_C
        struct samr_account_state *a_state;
        struct samr_domain_state *d_state;
        struct ldb_message *mod;
-       char *membersidstr;
+       struct dom_sid *membersid;
        const char *memberdn;
        struct ldb_message **msgs;
-       const char * const attrs[2] = { "dn", NULL };
+       const char * const attrs[2] = { "distinguishedName", NULL };
        int ret;
 
        DCESRV_PULL_HANDLE(h, r->in.group_handle, SAMR_HANDLE_GROUP);
@@ -1603,16 +1704,15 @@ static NTSTATUS samr_AddGroupMember(struct dcesrv_call_state *dce_call, TALLOC_C
        a_state = h->data;
        d_state = a_state->domain_state;
 
-       membersidstr = talloc_asprintf(mem_ctx, "%s-%u", d_state->domain_sid,
-                                      r->in.rid);
-       if (membersidstr == NULL)
+       membersid = dom_sid_add_rid(mem_ctx, d_state->domain_sid, r->in.rid);
+       if (membersid == NULL)
                return NT_STATUS_NO_MEMORY;
 
        /* In native mode, AD can also nest domain groups. Not sure yet
         * whether this is also available via RPC. */
        ret = gendb_search(d_state->sam_ctx, mem_ctx, d_state->domain_dn,
                           &msgs, attrs, "(&(objectSid=%s)(objectclass=user))",
-                          membersidstr);
+                          ldap_encode_ndr_dom_sid(mem_ctx, membersid));
 
        if (ret == 0)
                return NT_STATUS_NO_SUCH_USER;
@@ -1620,7 +1720,7 @@ static NTSTATUS samr_AddGroupMember(struct dcesrv_call_state *dce_call, TALLOC_C
        if (ret > 1)
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
 
-       memberdn = samdb_result_string(msgs[0], "dn", NULL);
+       memberdn = samdb_result_string(msgs[0], "distinguishedName", NULL);
 
        if (memberdn == NULL)
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
@@ -1680,10 +1780,10 @@ static NTSTATUS samr_DeleteGroupMember(struct dcesrv_call_state *dce_call, TALLO
        struct samr_account_state *a_state;
        struct samr_domain_state *d_state;
        struct ldb_message *mod;
-       char *membersidstr;
+       struct dom_sid *membersid;
        const char *memberdn;
        struct ldb_message **msgs;
-       const char * const attrs[2] = { "dn", NULL };
+       const char * const attrs[2] = { "distinguishedName", NULL };
        int ret;
 
        DCESRV_PULL_HANDLE(h, r->in.group_handle, SAMR_HANDLE_GROUP);
@@ -1691,16 +1791,15 @@ static NTSTATUS samr_DeleteGroupMember(struct dcesrv_call_state *dce_call, TALLO
        a_state = h->data;
        d_state = a_state->domain_state;
 
-       membersidstr = talloc_asprintf(mem_ctx, "%s-%u", d_state->domain_sid,
-                                      r->in.rid);
-       if (membersidstr == NULL)
+       membersid = dom_sid_add_rid(mem_ctx, d_state->domain_sid, r->in.rid);
+       if (membersid == NULL)
                return NT_STATUS_NO_MEMORY;
 
        /* In native mode, AD can also nest domain groups. Not sure yet
         * whether this is also available via RPC. */
        ret = gendb_search(d_state->sam_ctx, mem_ctx, d_state->domain_dn,
                           &msgs, attrs, "(&(objectSid=%s)(objectclass=user))",
-                          membersidstr);
+                          ldap_encode_ndr_dom_sid(mem_ctx, membersid));
 
        if (ret == 0)
                return NT_STATUS_NO_SUCH_USER;
@@ -1708,7 +1807,7 @@ static NTSTATUS samr_DeleteGroupMember(struct dcesrv_call_state *dce_call, TALLO
        if (ret > 1)
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
 
-       memberdn = samdb_result_string(msgs[0], "dn", NULL);
+       memberdn = samdb_result_string(msgs[0], "distinguishedName", NULL);
 
        if (memberdn == NULL)
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
@@ -1735,7 +1834,7 @@ static NTSTATUS samr_DeleteGroupMember(struct dcesrv_call_state *dce_call, TALLO
   samr_QueryGroupMember 
 */
 static NTSTATUS samr_QueryGroupMember(struct dcesrv_call_state *dce_call, TALLOC_CTX *mem_ctx,
-                      struct samr_QueryGroupMember *r)
+                                     struct samr_QueryGroupMember *r)
 {
        struct dcesrv_handle *h;
        struct samr_account_state *a_state;
@@ -1750,8 +1849,8 @@ static NTSTATUS samr_QueryGroupMember(struct dcesrv_call_state *dce_call, TALLOC
        a_state = h->data;
 
        /* pull the member attribute */
-       ret = gendb_search(a_state->sam_ctx, mem_ctx, NULL, &res, attrs,
-                          "dn=%s", a_state->account_dn);
+       ret = gendb_search_dn(a_state->sam_ctx, mem_ctx,
+                             a_state->account_dn, &res, attrs);
 
        if (ret != 1) {
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
@@ -1784,9 +1883,9 @@ static NTSTATUS samr_QueryGroupMember(struct dcesrv_call_state *dce_call, TALLOC
                for (i=0; i<el->num_values; i++) {
                        struct ldb_message **res2;
                        const char * const attrs2[2] = { "objectSid", NULL };
-                       ret = gendb_search(a_state->sam_ctx, mem_ctx, NULL,
-                                          &res2, attrs2, "dn=%s",
-                                          (char *)el->values[i].data);
+                       ret = gendb_search_dn(a_state->sam_ctx, mem_ctx,
+                                          ldb_dn_explode(mem_ctx, el->values[i].data),
+                                          &res2, attrs2);
                        if (ret != 1)
                                return NT_STATUS_INTERNAL_DB_CORRUPTION;
 
@@ -1826,7 +1925,8 @@ static NTSTATUS samr_OpenAlias(struct dcesrv_call_state *dce_call, TALLOC_CTX *m
        struct samr_domain_state *d_state;
        struct samr_account_state *a_state;
        struct dcesrv_handle *h;
-       const char *alias_name, *sidstr;
+       const char *alias_name;
+       struct dom_sid *sid;
        struct ldb_message **msgs;
        struct dcesrv_handle *g_handle;
        const char * const attrs[2] = { "sAMAccountName", NULL };
@@ -1839,9 +1939,8 @@ static NTSTATUS samr_OpenAlias(struct dcesrv_call_state *dce_call, TALLOC_CTX *m
        d_state = h->data;
 
        /* form the alias SID */
-       sidstr = talloc_asprintf(mem_ctx, "%s-%u", d_state->domain_sid,
-                                r->in.rid);
-       if (sidstr == NULL)
+       sid = dom_sid_add_rid(mem_ctx, d_state->domain_sid, r->in.rid);
+       if (sid == NULL)
                return NT_STATUS_NO_MEMORY;
 
        /* search for the group record */
@@ -1849,7 +1948,7 @@ static NTSTATUS samr_OpenAlias(struct dcesrv_call_state *dce_call, TALLOC_CTX *m
                           mem_ctx, d_state->domain_dn, &msgs, attrs,
                           "(&(objectSid=%s)(objectclass=group)"
                           "(|(grouptype=%s)(grouptype=%s)))",
-                          sidstr,
+                          ldap_encode_ndr_dom_sid(mem_ctx, sid),
                           ldb_hexstr(mem_ctx,
                                      GTYPE_SECURITY_BUILTIN_LOCAL_GROUP),
                           ldb_hexstr(mem_ctx,
@@ -1858,13 +1957,15 @@ static NTSTATUS samr_OpenAlias(struct dcesrv_call_state *dce_call, TALLOC_CTX *m
                return NT_STATUS_NO_SUCH_ALIAS;
        }
        if (ret != 1) {
-               DEBUG(0,("Found %d records matching sid %s\n", ret, sidstr));
+               DEBUG(0,("Found %d records matching sid %s\n", 
+                        ret, dom_sid_string(mem_ctx, sid)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
        alias_name = samdb_result_string(msgs[0], "sAMAccountName", NULL);
        if (alias_name == NULL) {
-               DEBUG(0,("sAMAccountName field missing for sid %s\n", sidstr));
+               DEBUG(0,("sAMAccountName field missing for sid %s\n", 
+                        dom_sid_string(mem_ctx, sid)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
@@ -1876,7 +1977,7 @@ static NTSTATUS samr_OpenAlias(struct dcesrv_call_state *dce_call, TALLOC_CTX *m
        a_state->access_mask = r->in.access_mask;
        a_state->domain_state = talloc_reference(a_state, d_state);
        a_state->account_dn = talloc_steal(a_state, msgs[0]->dn);
-       a_state->account_sid = talloc_steal(a_state, sidstr);
+       a_state->account_sid = talloc_steal(a_state, sid);
        a_state->account_name = talloc_strdup(a_state, alias_name);
        if (!a_state->account_name) {
                return NT_STATUS_NO_MEMORY;
@@ -1916,8 +2017,8 @@ static NTSTATUS samr_QueryAliasInfo(struct dcesrv_call_state *dce_call, TALLOC_C
        a_state = h->data;
 
        /* pull all the alias attributes */
-       ret = gendb_search(a_state->sam_ctx, mem_ctx, NULL, &res, attrs,
-                          "dn=%s", a_state->account_dn);
+       ret = gendb_search_dn(a_state->sam_ctx, mem_ctx,
+                             a_state->account_dn ,&res, attrs);
        if (ret != 1) {
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
@@ -1971,7 +2072,7 @@ static NTSTATUS samr_SetAliasInfo(struct dcesrv_call_state *dce_call, TALLOC_CTX
                return NT_STATUS_NO_MEMORY;
        }
 
-       msg->dn = talloc_strdup(mem_ctx, a_state->account_dn);
+       msg->dn = ldb_dn_copy(mem_ctx, a_state->account_dn);
        if (!msg->dn) {
                return NT_STATUS_NO_MEMORY;
        }
@@ -2036,11 +2137,10 @@ static NTSTATUS samr_AddAliasMember(struct dcesrv_call_state *dce_call, TALLOC_C
        struct dcesrv_handle *h;
        struct samr_account_state *a_state;
        struct samr_domain_state *d_state;
-       const char *sidstr;
        struct ldb_message *mod;
        struct ldb_message **msgs;
-       const char * const attrs[2] = { "dn", NULL };
-       const char *memberdn = NULL;
+       const char * const attrs[2] = { "distinguishedName", NULL };
+       struct ldb_dn *memberdn = NULL;
        int ret;
 
        DCESRV_PULL_HANDLE(h, r->in.alias_handle, SAMR_HANDLE_ALIAS);
@@ -2048,28 +2148,27 @@ static NTSTATUS samr_AddAliasMember(struct dcesrv_call_state *dce_call, TALLOC_C
        a_state = h->data;
        d_state = a_state->domain_state;
 
-       sidstr = dom_sid_string(mem_ctx, r->in.sid);
-       if (sidstr == NULL)
-               return NT_STATUS_INVALID_PARAMETER;
-
        ret = gendb_search(d_state->sam_ctx, mem_ctx, NULL,
-                          &msgs, attrs, "(objectsid=%s)", sidstr);
+                          &msgs, attrs, "(objectsid=%s)", 
+                          ldap_encode_ndr_dom_sid(mem_ctx, r->in.sid));
 
        if (ret == 1) {
-               memberdn = ldb_msg_find_string(msgs[0], "dn", NULL);
+               memberdn = ldb_dn_explode(mem_ctx, ldb_msg_find_string(msgs[0], "distinguishedName", NULL));
        } else  if (ret > 1) {
-               DEBUG(0,("Found %d records matching sid %s\n", ret, sidstr));
+               DEBUG(0,("Found %d records matching sid %s\n", 
+                        ret, dom_sid_string(mem_ctx, r->in.sid)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        } else if (ret == 0) {
                struct ldb_message *msg;
-               struct GUID guid;
-               const char *guidstr, *basedn;
+               struct ldb_dn *basedn;
+               const char *sidstr;
+
+               sidstr = dom_sid_string(mem_ctx, r->in.sid);
+               NT_STATUS_HAVE_NO_MEMORY(sidstr);
 
                /* We might have to create a ForeignSecurityPrincipal, but
                 * only if it's not our own domain */
-               if (dom_sid_in_domain(dom_sid_parse_talloc(mem_ctx,
-                                                          d_state->domain_sid),
-                                     r->in.sid))
+               if (dom_sid_in_domain(d_state->domain_sid, r->in.sid))
                        return NT_STATUS_OBJECT_NAME_NOT_FOUND;
 
                msg = ldb_msg_new(mem_ctx);
@@ -2077,34 +2176,14 @@ static NTSTATUS samr_AddAliasMember(struct dcesrv_call_state *dce_call, TALLOC_C
                        return NT_STATUS_NO_MEMORY;
                }
 
-               /* pull in all the template attributes */
-               ret = samdb_copy_template(d_state->sam_ctx, mem_ctx, msg, 
-                                         "(&(name=TemplateForeignSecurityPrincipal)"
-                                         "(objectclass=foreignSecurityPrincipalTemplate))");
-               if (ret != 0) {
-                       DEBUG(0,("Failed to load "
-                                "TemplateForeignSecurityPrincipal "
-                                "from samdb\n"));
-                       return NT_STATUS_INTERNAL_DB_CORRUPTION;
-               }
-
-               /* a new GUID */
-               guid = GUID_random();
-               guidstr = GUID_string(mem_ctx, &guid);
-               if (!guidstr) {
-                       return NT_STATUS_NO_MEMORY;
-               }
-
                /* TODO: Hmmm. This feels wrong. How do I find the base dn to
                 * put the ForeignSecurityPrincipals? d_state->domain_dn does
                 * not work, this is wrong for the Builtin domain, there's no
                 * cn=For...,cn=Builtin,dc={BASEDN}.  -- vl
                 */
 
-               basedn = samdb_search_string(d_state->sam_ctx, mem_ctx, NULL,
-                                            "dn",
-                                            "(&(objectClass=container)"
-                                            "(cn=ForeignSecurityPrincipals))");
+               basedn = samdb_search_dn(d_state->sam_ctx, mem_ctx, NULL,
+                                        "(&(objectClass=container)(cn=ForeignSecurityPrincipals))");
 
                if (basedn == NULL) {
                        DEBUG(0, ("Failed to find DN for "
@@ -2113,27 +2192,21 @@ static NTSTATUS samr_AddAliasMember(struct dcesrv_call_state *dce_call, TALLOC_C
                }
 
                /* add core elements to the ldb_message for the alias */
-               msg->dn = talloc_asprintf(mem_ctx, "CN=%s,%s", sidstr, basedn);
+               msg->dn = ldb_dn_build_child(mem_ctx, "CN", sidstr, basedn);
                if (msg->dn == NULL)
                        return NT_STATUS_NO_MEMORY;
 
                memberdn = msg->dn;
 
-               samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg,
-                                    "name", sidstr);
                samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg,
                                     "objectClass",
                                     "foreignSecurityPrincipal");
-               samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg,
-                                    "objectSid", sidstr);
-               samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg,
-                                    "objectGUID", guidstr);
-               
+
                /* create the alias */
                ret = samdb_add(d_state->sam_ctx, mem_ctx, msg);
                if (ret != 0) {
                        DEBUG(0,("Failed to create foreignSecurityPrincipal "
-                                "record %s\n", msg->dn));
+                                "record %s\n", ldb_dn_linearize(mem_ctx, msg->dn)));
                        return NT_STATUS_INTERNAL_DB_CORRUPTION;
                }
        } else {
@@ -2153,7 +2226,7 @@ static NTSTATUS samr_AddAliasMember(struct dcesrv_call_state *dce_call, TALLOC_C
        mod->dn = talloc_reference(mem_ctx, a_state->account_dn);
 
        if (samdb_msg_add_addval(d_state->sam_ctx, mem_ctx, mod, "member",
-                                memberdn) != 0)
+                                ldb_dn_linearize(mem_ctx, memberdn)) != 0)
                return NT_STATUS_UNSUCCESSFUL;
 
        if (samdb_modify(a_state->sam_ctx, mem_ctx, mod) != 0)
@@ -2172,7 +2245,6 @@ static NTSTATUS samr_DeleteAliasMember(struct dcesrv_call_state *dce_call, TALLO
        struct dcesrv_handle *h;
        struct samr_account_state *a_state;
        struct samr_domain_state *d_state;
-       const char *sidstr;
        struct ldb_message *mod;
        const char *memberdn;
 
@@ -2181,12 +2253,9 @@ static NTSTATUS samr_DeleteAliasMember(struct dcesrv_call_state *dce_call, TALLO
        a_state = h->data;
        d_state = a_state->domain_state;
 
-       sidstr = dom_sid_string(mem_ctx, r->in.sid);
-       if (sidstr == NULL)
-               return NT_STATUS_INVALID_PARAMETER;
-
        memberdn = samdb_search_string(d_state->sam_ctx, mem_ctx, NULL,
-                                      "dn", "(objectSid=%s)", sidstr);
+                                      "distinguishedName", "(objectSid=%s)", 
+                                      ldap_encode_ndr_dom_sid(mem_ctx, r->in.sid));
 
        if (memberdn == NULL)
                return NT_STATUS_OBJECT_NAME_NOT_FOUND;
@@ -2229,8 +2298,8 @@ static NTSTATUS samr_GetMembersInAlias(struct dcesrv_call_state *dce_call, TALLO
        a_state = h->data;
        d_state = a_state->domain_state;
 
-       ret = gendb_search(d_state->sam_ctx, mem_ctx, NULL, &msgs, attrs,
-                          "dn=%s", a_state->account_dn);
+       ret = gendb_search_dn(d_state->sam_ctx, mem_ctx,
+                             a_state->account_dn, &msgs, attrs);
 
        if (ret != 1)
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
@@ -2252,9 +2321,9 @@ static NTSTATUS samr_GetMembersInAlias(struct dcesrv_call_state *dce_call, TALLO
                for (i=0; i<el->num_values; i++) {
                        struct ldb_message **msgs2;
                        const char * const attrs2[2] = { "objectSid", NULL };
-                       ret = gendb_search(a_state->sam_ctx, mem_ctx, NULL,
-                                          &msgs2, attrs2, "dn=%s",
-                                          (char *)el->values[i].data);
+                       ret = gendb_search_dn(a_state->sam_ctx, mem_ctx,
+                                          ldb_dn_explode(mem_ctx, el->values[i].data),
+                                          &msgs2, attrs2);
                        if (ret != 1)
                                return NT_STATUS_INTERNAL_DB_CORRUPTION;
 
@@ -2280,7 +2349,8 @@ static NTSTATUS samr_OpenUser(struct dcesrv_call_state *dce_call, TALLOC_CTX *me
        struct samr_domain_state *d_state;
        struct samr_account_state *a_state;
        struct dcesrv_handle *h;
-       const char *account_name, *sidstr;
+       const char *account_name;
+       struct dom_sid *sid;
        struct ldb_message **msgs;
        struct dcesrv_handle *u_handle;
        const char * const attrs[2] = { "sAMAccountName", NULL };
@@ -2293,8 +2363,8 @@ static NTSTATUS samr_OpenUser(struct dcesrv_call_state *dce_call, TALLOC_CTX *me
        d_state = h->data;
 
        /* form the users SID */
-       sidstr = talloc_asprintf(mem_ctx, "%s-%u", d_state->domain_sid, r->in.rid);
-       if (!sidstr) {
+       sid = dom_sid_add_rid(mem_ctx, d_state->domain_sid, r->in.rid);
+       if (!sid) {
                return NT_STATUS_NO_MEMORY;
        }
 
@@ -2302,18 +2372,20 @@ static NTSTATUS samr_OpenUser(struct dcesrv_call_state *dce_call, TALLOC_CTX *me
        ret = gendb_search(d_state->sam_ctx,
                           mem_ctx, d_state->domain_dn, &msgs, attrs,
                           "(&(objectSid=%s)(objectclass=user))", 
-                          sidstr);
+                          ldap_encode_ndr_dom_sid(mem_ctx, sid));
        if (ret == 0) {
                return NT_STATUS_NO_SUCH_USER;
        }
        if (ret != 1) {
-               DEBUG(0,("Found %d records matching sid %s\n", ret, sidstr));
+               DEBUG(0,("Found %d records matching sid %s\n", ret, 
+                        dom_sid_string(mem_ctx, sid)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
        account_name = samdb_result_string(msgs[0], "sAMAccountName", NULL);
        if (account_name == NULL) {
-               DEBUG(0,("sAMAccountName field missing for sid %s\n", sidstr));
+               DEBUG(0,("sAMAccountName field missing for sid %s\n", 
+                        dom_sid_string(mem_ctx, sid)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
@@ -2325,7 +2397,7 @@ static NTSTATUS samr_OpenUser(struct dcesrv_call_state *dce_call, TALLOC_CTX *me
        a_state->access_mask = r->in.access_mask;
        a_state->domain_state = talloc_reference(a_state, d_state);
        a_state->account_dn = talloc_steal(a_state, msgs[0]->dn);
-       a_state->account_sid = talloc_steal(a_state, sidstr);
+       a_state->account_sid = talloc_steal(a_state, sid);
        a_state->account_name = talloc_strdup(a_state, account_name);
        if (!a_state->account_name) {
                return NT_STATUS_NO_MEMORY;
@@ -2391,8 +2463,8 @@ static NTSTATUS samr_QueryUserInfo(struct dcesrv_call_state *dce_call, TALLOC_CT
        a_state = h->data;
 
        /* pull all the user attributes */
-       ret = gendb_search(a_state->sam_ctx, mem_ctx, NULL, &res, NULL,
-                          "dn=%s", a_state->account_dn);
+       ret = gendb_search_dn(a_state->sam_ctx, mem_ctx,
+                             a_state->account_dn ,&res, NULL);
        if (ret != 1) {
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
@@ -2807,29 +2879,25 @@ static NTSTATUS samr_GetGroupsForUser(struct dcesrv_call_state *dce_call, TALLOC
        struct samr_account_state *a_state;
        struct samr_domain_state *d_state;
        struct ldb_message **res;
-       struct dom_sid *domain_sid;
        const char * const attrs[2] = { "objectSid", NULL };
-       struct samr_RidWithTypeArray *array;
+       struct samr_RidWithAttributeArray *array;
        int count;
 
        DCESRV_PULL_HANDLE(h, r->in.user_handle, SAMR_HANDLE_USER);
 
        a_state = h->data;
        d_state = a_state->domain_state;
-       domain_sid = dom_sid_parse_talloc(mem_ctx, d_state->domain_sid);
-       if (domain_sid == NULL)
-               return NT_STATUS_NO_MEMORY;
 
        count = samdb_search_domain(a_state->sam_ctx, mem_ctx, NULL, &res,
-                                   attrs, domain_sid,
+                                   attrs, d_state->domain_sid,
                                    "(&(member=%s)(grouptype=%s)(objectclass=group))",
-                                   a_state->account_dn,
+                                   ldb_dn_linearize(mem_ctx, a_state->account_dn),
                                    ldb_hexstr(mem_ctx,
                                               GTYPE_SECURITY_GLOBAL_GROUP));
        if (count < 0)
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
 
-       array = talloc(mem_ctx, struct samr_RidWithTypeArray);
+       array = talloc(mem_ctx, struct samr_RidWithAttributeArray);
        if (array == NULL)
                return NT_STATUS_NO_MEMORY;
 
@@ -2838,7 +2906,7 @@ static NTSTATUS samr_GetGroupsForUser(struct dcesrv_call_state *dce_call, TALLOC
 
        if (count > 0) {
                int i;
-               array->rids = talloc_array(mem_ctx, struct samr_RidWithType,
+               array->rids = talloc_array(mem_ctx, struct samr_RidWithAttribute,
                                            count);
 
                if (array->rids == NULL)
@@ -2856,7 +2924,7 @@ static NTSTATUS samr_GetGroupsForUser(struct dcesrv_call_state *dce_call, TALLOC
 
                        array->rids[array->count].rid =
                                group_sid->sub_auths[group_sid->num_auths-1];
-                       array->rids[array->count].type = 7;
+                       array->rids[array->count].attributes = SE_GROUP_MANDATORY | SE_GROUP_ENABLED_BY_DEFAULT | SE_GROUP_ENABLED;
                        array->count += 1;
                }
        }
@@ -2879,7 +2947,6 @@ static NTSTATUS samr_QueryDisplayInfo(struct dcesrv_call_state *dce_call, TALLOC
        int ldb_cnt, count, i;
        const char * const attrs[4] = { "objectSid", "sAMAccountName",
                                        "description", NULL };
-       struct dom_sid *domain_sid;
        struct samr_DispEntryFull *entriesFull = NULL;
        struct samr_DispEntryAscii *entriesAscii = NULL;
        struct samr_DispEntryGeneral * entriesGeneral = NULL;
@@ -2913,15 +2980,11 @@ static NTSTATUS samr_QueryDisplayInfo(struct dcesrv_call_state *dce_call, TALLOC
                return NT_STATUS_INVALID_INFO_CLASS;
        }
 
-       domain_sid = dom_sid_parse_talloc(mem_ctx, d_state->domain_sid);
-       if (domain_sid == NULL)
-               return NT_STATUS_NO_MEMORY;
-
        /* search for all requested objects in this domain. This could
           possibly be cached and resumed based on resume_key */
        ldb_cnt = samdb_search_domain(d_state->sam_ctx, mem_ctx,
                                      d_state->domain_dn, &res, attrs,
-                                     domain_sid, "%s", filter);
+                                     d_state->domain_sid, "%s", filter);
        if (ldb_cnt == -1) {
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
@@ -2965,7 +3028,7 @@ static NTSTATUS samr_QueryDisplayInfo(struct dcesrv_call_state *dce_call, TALLOC
 
                switch(r->in.level) {
                case 1:
-                       entriesGeneral[count].idx = count;
+                       entriesGeneral[count].idx = count + 1;
                        entriesGeneral[count].rid = 
                                objectsid->sub_auths[objectsid->num_auths-1];
                        entriesGeneral[count].acct_flags =
@@ -2981,7 +3044,7 @@ static NTSTATUS samr_QueryDisplayInfo(struct dcesrv_call_state *dce_call, TALLOC
                        break;
                case 2:
                case 3:
-                       entriesFull[count].idx = count;
+                       entriesFull[count].idx = count + 1;
                        entriesFull[count].rid =
                                objectsid->sub_auths[objectsid->num_auths-1];
                        entriesFull[count].acct_flags =
@@ -2999,7 +3062,7 @@ static NTSTATUS samr_QueryDisplayInfo(struct dcesrv_call_state *dce_call, TALLOC
                        break;
                case 4:
                case 5:
-                       entriesAscii[count].idx = count;
+                       entriesAscii[count].idx = count + 1;
                        entriesAscii[count].account_name.string =
                                samdb_result_string(res[i], "sAMAccountName",
                                                    "");
@@ -3117,10 +3180,12 @@ static NTSTATUS samr_GetUserPwInfo(struct dcesrv_call_state *dce_call, TALLOC_CT
 
        a_state = h->data;
 
-       r->out.info.min_password_length = samdb_search_uint(a_state->sam_ctx, mem_ctx, 0, NULL, "minPwdLength", 
-                                                           "dn=%s", a_state->domain_state->domain_dn);
-       r->out.info.password_properties = samdb_search_uint(a_state->sam_ctx, mem_ctx, 0, NULL, "pwdProperties", 
-                                                           "dn=%s", a_state->account_dn);
+       r->out.info.min_password_length = samdb_search_uint(a_state->sam_ctx, mem_ctx, 0,
+                                                           a_state->domain_state->domain_dn, "minPwdLength", 
+                                                           NULL);
+       r->out.info.password_properties = samdb_search_uint(a_state->sam_ctx, mem_ctx, 0,
+                                                           a_state->account_dn, 
+                                                           "pwdProperties", NULL);
        return NT_STATUS_OK;
 }
 
@@ -3133,23 +3198,18 @@ static NTSTATUS samr_RemoveMemberFromForeignDomain(struct dcesrv_call_state *dce
 {
        struct dcesrv_handle *h;
        struct samr_domain_state *d_state;
-       struct dom_sid *domain_sid;
-       const char *membersid, *memberdn;
+       const char *memberdn;
        struct ldb_message **res;
-       const char * const attrs[3] = { "dn", "objectSid", NULL };
+       const char * const attrs[3] = { "distinguishedName", "objectSid", NULL };
        int i, count;
 
        DCESRV_PULL_HANDLE(h, r->in.domain_handle, SAMR_HANDLE_DOMAIN);
 
        d_state = h->data;
 
-       domain_sid = dom_sid_parse_talloc(mem_ctx, d_state->domain_sid);
-       membersid = dom_sid_string(mem_ctx, r->in.sid);
-       if ((domain_sid == NULL) || (membersid == NULL))
-               return NT_STATUS_NO_MEMORY;
-
        memberdn = samdb_search_string(d_state->sam_ctx, mem_ctx, NULL,
-                                      "dn", "(objectSid=%s)", membersid);
+                                      "distinguishedName", "(objectSid=%s)", 
+                                      ldap_encode_ndr_dom_sid(mem_ctx, r->in.sid));
        if (memberdn == NULL)
                return NT_STATUS_OBJECT_NAME_NOT_FOUND;
 
@@ -3158,7 +3218,7 @@ static NTSTATUS samr_RemoveMemberFromForeignDomain(struct dcesrv_call_state *dce
 
        count = samdb_search_domain(d_state->sam_ctx, mem_ctx,
                                    d_state->domain_dn, &res, attrs,
-                                   domain_sid,
+                                   d_state->domain_sid,
                                    "(&(member=%s)(objectClass=group)"
                                    "(|(groupType=%s)(groupType=%s)))",
                                    memberdn,
@@ -3178,9 +3238,7 @@ static NTSTATUS samr_RemoveMemberFromForeignDomain(struct dcesrv_call_state *dce
                        return NT_STATUS_NO_MEMORY;
                }
 
-               mod->dn = talloc_reference(mod,
-                                          samdb_result_string(res[i], "dn",
-                                                              NULL));
+               mod->dn = samdb_result_dn(mod, res[i], "distinguishedName", NULL);
                if (mod->dn == NULL) {
                        talloc_free(mod);
                        continue;
@@ -3313,19 +3371,18 @@ static NTSTATUS samr_GetDomPwInfo(struct dcesrv_call_state *dce_call, TALLOC_CTX
        struct ldb_message **msgs;
        int ret;
        const char * const attrs[] = {"minPwdLength", "pwdProperties", NULL };
-       void *sam_ctx;
+       struct ldb_context *sam_ctx;
 
        ZERO_STRUCT(r->out.info);
 
-       sam_ctx = samdb_connect(mem_ctx);
+       sam_ctx = samdb_connect(mem_ctx, dce_call->conn->auth_state.session_info); 
        if (sam_ctx == NULL) {
                return NT_STATUS_INVALID_SYSTEM_SERVICE;
        }
 
-       ret = gendb_search(sam_ctx, 
-                          mem_ctx, NULL, &msgs, attrs, 
-                          "(&(name=%s)(objectclass=domain))",
-                          lp_workgroup());
+       /* The domain name in this call is ignored */
+       ret = gendb_search_dn(sam_ctx, 
+                          mem_ctx, samdb_base_dn(mem_ctx), &msgs, attrs);
        if (ret <= 0) {
                return NT_STATUS_NO_SUCH_DOMAIN;
        }