From 6af763206ef602b6b01f59d756d0bc3e61bc308e Mon Sep 17 00:00:00 2001
From: shubham_meena <shubham_meena@localhost>
Date: Wed, 28 May 2014 03:48:44 +0530
Subject: [PATCH] restructuring of AMS database functions to work with CRUD

---
 .../ryzom_ams/ams_lib/autoload/assigned.php   | 16 +++----
 .../ryzom_ams/ams_lib/autoload/forwarded.php  | 14 +++---
 .../ryzom_ams/ams_lib/autoload/helpers.php    |  2 +-
 .../ams_lib/autoload/in_support_group.php     | 12 ++---
 .../ams_lib/autoload/mail_handler.php         |  9 +---
 .../ryzom_ams/ams_lib/autoload/querycache.php |  8 ++--
 .../ams_lib/autoload/support_group.php        | 24 ++++------
 .../ryzom_ams/ams_lib/autoload/sync.php       | 25 ++++++-----
 .../ryzom_ams/ams_lib/autoload/ticket.php     | 14 +++---
 .../ams_lib/autoload/ticket_category.php      | 15 +++----
 .../ams_lib/autoload/ticket_content.php       | 12 ++---
 .../ams_lib/autoload/ticket_info.php          | 18 ++++----
 .../ryzom_ams/ams_lib/autoload/ticket_log.php | 16 +++----
 .../ams_lib/autoload/ticket_reply.php         | 12 ++---
 .../ams_lib/autoload/ticket_user.php          | 17 +++----
 .../ryzom_ams/ams_lib/autoload/users.php      | 36 +++++++--------
 .../ryzom_ams/www/html/autoload/webusers.php  | 44 +++++++++----------
 .../ryzom_ams/www/html/func/add_user.php      | 11 +++--
 18 files changed, 129 insertions(+), 176 deletions(-)

diff --git a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/assigned.php b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/assigned.php
index 8de17a9e2..d9d730c8e 100644
--- a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/assigned.php
+++ b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/assigned.php
@@ -80,9 +80,9 @@ class Assigned{
         $dbl = new DBLayer("lib");
         //check if ticket is already assigned
         
-        if($user_id == 0 &&  $dbl->execute(" SELECT * FROM `assigned` WHERE `Ticket` = :ticket_id", array('ticket_id' => $ticket_id) )->rowCount() ){
+        if($user_id == 0 &&  $dbl->select("`assigned`", array('ticket_id' => $ticket_id), "`Ticket` = :ticket_id")->rowCount() ){
             return true;
-        }else if( $dbl->execute(" SELECT * FROM `assigned` WHERE `Ticket` = :ticket_id and `User` = :user_id", array('ticket_id' => $ticket_id, 'user_id' => $user_id) )->rowCount()){
+        }else if( $dbl->select("`assigned`", array('ticket_id' => $ticket_id, 'user_id' => $user_id), "`Ticket` = :ticket_id and `User` = :user_id")->rowCount() ){
             return true;
         }else{
             return false;
@@ -115,9 +115,7 @@ class Assigned{
     */
     public function create() {
         $dbl = new DBLayer("lib");
-        $query = "INSERT INTO `assigned` (`User`,`Ticket`) VALUES (:user, :ticket)";
-        $values = Array('user' => $this->getUser(), 'ticket' => $this->getTicket());
-        $dbl->execute($query, $values);
+	$dbl->insert("`assigned`", Array('User' => $this->getUser(), 'Ticket' => $this->getTicket());
     }
     
     
@@ -127,9 +125,7 @@ class Assigned{
     */
     public function delete() {
         $dbl = new DBLayer("lib");
-        $query = "DELETE FROM `assigned` WHERE `User` = :user_id and `Ticket` = :ticket_id";
-        $values = array('user_id' => $this->getUser() ,'ticket_id' => $this->getTicket());
-        $dbl->execute($query, $values);
+	$dbl->delete("`assigned`", array('user_id' => $this->getUser() ,'ticket_id' => $this->getTicket(), "`User` = :user_id and `Ticket` = :ticket_id"); 
     }
 
     /**
@@ -139,7 +135,7 @@ class Assigned{
     */
     public function load($ticket_id) {
         $dbl = new DBLayer("lib");
-        $statement = $dbl->execute("SELECT * FROM `assigned` WHERE `Ticket` = :ticket_id", Array('ticket_id' => $ticket_id));
+        $statement = $dbl->select("`assigned`", Array('ticket_id' => $ticket_id), "`Ticket` = :ticket_id");
         $row = $statement->fetch();
         $this->set($row);
     }
@@ -181,4 +177,4 @@ class Assigned{
     }
    
     
-}
\ No newline at end of file
+}
diff --git a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/forwarded.php b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/forwarded.php
index 54fece58c..ccba764e6 100644
--- a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/forwarded.php
+++ b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/forwarded.php
@@ -55,7 +55,7 @@ class Forwarded{
     */
     public static function isForwarded( $ticket_id) {
         $dbl = new DBLayer("lib");
-        if( $dbl->execute(" SELECT * FROM `forwarded` WHERE `Ticket` = :ticket_id", array('ticket_id' => $ticket_id))->rowCount()){
+        if( $dbl->select("`forwarded`", array('ticket_id' => $ticket_id), "`Ticket` = :ticket_id")->rowCount() ){
             return true;
         }else{
             return false;
@@ -90,9 +90,7 @@ class Forwarded{
     */
     public function create() {
         $dbl = new DBLayer("lib");
-        $query = "INSERT INTO `forwarded` (`Group`,`Ticket`) VALUES (:group, :ticket)";
-        $values = Array('group' => $this->getGroup(), 'ticket' => $this->getTicket());
-        $dbl->execute($query, $values);
+        $dbl->insert("`forwarded`", Array('Group' => $this->getGroup(), 'Ticket' => $this->getTicket()));
     }
     
     
@@ -102,9 +100,7 @@ class Forwarded{
     */
     public function delete() {
         $dbl = new DBLayer("lib");
-        $query = "DELETE FROM `forwarded` WHERE `Group` = :group_id and `Ticket` = :ticket_id";
-        $values = array('group_id' => $this->getGroup() ,'ticket_id' => $this->getTicket());
-        $dbl->execute($query, $values);
+        $dbl->delete("`forwarded`", array('group_id' => $this->getGroup() ,'ticket_id' => $this->getTicket(), "`Group` = :group_id and `Ticket` = :ticket_id");
     }
 
 
@@ -115,7 +111,7 @@ class Forwarded{
     */
     public function load( $ticket_id) {
         $dbl = new DBLayer("lib");
-        $statement = $dbl->execute("SELECT * FROM `forwarded` WHERE `Ticket` = :ticket_id", Array('ticket_id' => $ticket_id));
+        $statement = $dbl->select("`forwarded`", Array('ticket_id' => $ticket_id), "`Ticket` = :ticket_id");
         $row = $statement->fetch();
         $this->set($row);
     }
@@ -156,4 +152,4 @@ class Forwarded{
     }
    
     
-}
\ No newline at end of file
+}
diff --git a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/helpers.php b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/helpers.php
index 40a96f6c1..2d26f3c21 100644
--- a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/helpers.php
+++ b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/helpers.php
@@ -206,7 +206,7 @@ class Helpers{
                $dbr = new DBLayer("ring");
                if (isset($_GET['UserId']) && isset($_COOKIE['ryzomId'])){
                     $id = $_GET['UserId'];
-                    $statement = $dbr->execute("SELECT * FROM ring_users WHERE user_id=:id AND cookie =:cookie", array('id' => $id, 'cookie' => $_COOKIE['ryzomId']));
+                    $statement = $dbr->select("ring_users", array('id' => $id, 'cookie' => $_COOKIE['ryzomId']), "user_id=:id AND cookie =:cookie");
                     if ($statement->rowCount() ){
                          $entry = $statement->fetch();
 			//print_r($entry);
diff --git a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/in_support_group.php b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/in_support_group.php
index bf10d3d9a..86c678cd3 100644
--- a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/in_support_group.php
+++ b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/in_support_group.php
@@ -21,7 +21,7 @@ class In_Support_Group{
     public static function userExistsInSGroup( $user_id, $group_id) {
         $dbl = new DBLayer("lib");
         //check if name is already used
-        if(  $dbl->execute(" SELECT * FROM `in_support_group` WHERE `User` = :user_id and `Group` = :group_id ", array('user_id' => $user_id, 'group_id' => $group_id) )->rowCount() ){
+        if(  $dbl->select("in_support_group", array('user_id' => $user_id, 'group_id' => $group_id), "`User` = :user_id and `Group` = :group_id")->rowCount() ){
             return true;
         }else{
             return false;
@@ -54,9 +54,7 @@ class In_Support_Group{
     */
     public function create() {
         $dbl = new DBLayer("lib");
-        $query = "INSERT INTO `in_support_group` (`User`,`Group`) VALUES (:user, :group)";
-        $values = Array('user' => $this->user, 'group' => $this->group);
-        $dbl->execute($query, $values);
+        $dbl->insert("`in_support_group`", Array('User' => $this->user, 'Group' => $this->group);
     }
     
     
@@ -66,9 +64,7 @@ class In_Support_Group{
     */
     public function delete() {
         $dbl = new DBLayer("lib");
-        $query = "DELETE FROM `in_support_group` WHERE `User` = :user_id and `Group` = :group_id";
-        $values = array('user_id' => $this->getUser() ,'group_id' => $this->getGroup());
-        $dbl->execute($query, $values);
+        $dbl->delete("`in_support_group`", array('user_id' => $this->getUser() ,'group_id' => $this->getGroup(), "`User` = :user_id and `Group` = :group_id");
     }
 
     /*
@@ -118,4 +114,4 @@ class In_Support_Group{
     }
    
     
-}
\ No newline at end of file
+}
diff --git a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/mail_handler.php b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/mail_handler.php
index dde8d4e02..66cb0f95d 100644
--- a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/mail_handler.php
+++ b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/mail_handler.php
@@ -118,12 +118,7 @@ class Mail_Handler{
             $id_user = $recipient;
             $recipient = NULL;
         }
-
-        $query = "INSERT INTO email (Recipient,Subject,Body,Status,Attempts,Sender,UserId,MessageId,TicketId) VALUES (:recipient, :subject, :body, :status, :attempts, :sender, :id_user, :messageId, :ticketId)";
-        $values = array('recipient' => $recipient, 'subject' => $subject, 'body' => $body, 'status' => 'NEW', 'attempts'=> 0, 'sender' => $from,'id_user' => $id_user,  'messageId' => 0, 'ticketId'=> $ticket_id);
-        $db = new DBLayer("lib");
-        $db->execute($query, $values);
-        
+        $db->insert("email", array('Recipient' => $recipient, 'Subject' => $subject, 'Body' => $body, 'Status' => 'NEW', 'Attempts'=> 0, 'Sender' => $from,'UserId' 		=> $id_user,  'MessageId' => 0, 'TicketId'=> $ticket_id));
     }
     
      
@@ -173,7 +168,7 @@ class Mail_Handler{
                 
                 //select all new & failed emails & try to send them
                 //$emails = db_query("select * from email where status = 'NEW' or status = 'FAILED'");
-                $statement = $this->db->executeWithoutParams("select * from email where Status = 'NEW' or Status = 'FAILED'");
+                $statement = $this->db->select("email",array(null), "Status = 'NEW' or Status = 'FAILED'");
                 $emails = $statement->fetchAll();
 
                 foreach($emails as $email) {
diff --git a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/querycache.php b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/querycache.php
index 3da0887c9..6f0c0dca6 100644
--- a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/querycache.php
+++ b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/querycache.php
@@ -47,7 +47,7 @@ class Querycache{
     */
     public function load_With_SID( $id) {
         $dbl = new DBLayer("lib");
-        $statement = $dbl->execute("SELECT * FROM ams_querycache WHERE SID=:id", array('id' => $id));
+        $statement = $dbl->select("ams_querycache", array('id' => $id), "SID=:id");
         $row = $statement->fetch();
         $this->set($row);
     } 
@@ -58,9 +58,7 @@ class Querycache{
     */
     public function update(){
         $dbl = new DBLayer("lib");
-        $query = "UPDATE ams_querycache SET type= :t, query = :q, db = :d WHERE SID=:id";
-        $values = Array('id' => $this->getSID(), 't' => $this->getType(), 'q' => $this->getQuery(), 'd' => $this->getDb());
-        $statement = $dbl->execute($query, $values);
+        $dbl->update("ams_querycache", Array('type' => $this->getType(), 'query' => $this->getQuery(), 'db' => $this->getDb(), "SID=$this->getSID()" );
     }
     
     ////////////////////////////////////////////Getters////////////////////////////////////////////////////
@@ -127,4 +125,4 @@ class Querycache{
         $this->db= $d;
     }
     
-}
\ No newline at end of file
+}
diff --git a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/support_group.php b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/support_group.php
index c42d12efb..7b8a864d4 100644
--- a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/support_group.php
+++ b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/support_group.php
@@ -24,7 +24,7 @@ class Support_Group{
     */
     public static function getGroup($id) {
         $dbl = new DBLayer("lib");
-        $statement = $dbl->execute("SELECT * FROM support_group WHERE SGroupId = :id", array('id' => $id));
+        $statement = $dbl->select("support_group", array('id' => $id), "SGroupId = :id");
         $row = $statement->fetch();
         $instanceGroup = new self();
         $instanceGroup->set($row);
@@ -102,10 +102,10 @@ class Support_Group{
     public static function supportGroup_EntryNotExists( $name, $tag) {
         $dbl = new DBLayer("lib");
         //check if name is already used
-        if(  $dbl->execute("SELECT * FROM support_group WHERE Name = :name",array('name' => $name))->rowCount() ){
+        if(  $dbl->select("support_group", array('name' => $name), "Name = :name")->rowCount() ){
             return "NAME_TAKEN";
         }
-        else if(  $dbl->execute("SELECT * FROM support_group WHERE Tag = :tag",array('tag' => $tag))->rowCount() ){
+        else if(  $dbl->select("support_group", array('tag' => $tag), "Tag = :tag")->rowCount() ){
             return "TAG_TAKEN";
         }else{
             return "SUCCESS";
@@ -121,7 +121,7 @@ class Support_Group{
     public static function supportGroup_Exists( $id) {
         $dbl = new DBLayer("lib");
         //check if supportgroup id exist
-        if(  $dbl->execute("SELECT * FROM support_group WHERE SGroupId = :id",array('id' => $id ))->rowCount() ){
+        if(  $dbl->select("support_group", array('id' => $id ), "SGroupId = :id")->rowCount() ){
             return true;
         }else{
             return false;
@@ -305,9 +305,7 @@ class Support_Group{
     */
     public function create() {
         $dbl = new DBLayer("lib");
-        $query = "INSERT INTO support_group (Name, Tag, GroupEmail, IMAP_MailServer, IMAP_Username, IMAP_Password) VALUES (:name, :tag, :groupemail, :imap_mailserver, :imap_username, :imap_password)";
-        $values = Array('name' => $this->getName(), 'tag' => $this->getTag(), 'groupemail' => $this->getGroupEmail(), 'imap_mailserver' => $this->getIMAP_MailServer(), 'imap_username' => $this->getIMAP_Username(), 'imap_password' => $this->getIMAP_Password());
-        $dbl->execute($query, $values);
+	$dbl->insert("support_group", Array('Name' => $this->getName(), 'Tag' => $this->getTag(), 'GroupEmail' => $this->getGroupEmail(), 'IMAP_MailServer' => $this->getIMAP_MailServer(), 'IMAP_Username' => $this->getIMAP_Username(), 'IMAP_Password' => $this->getIMAP_Password());
     } 
 
     
@@ -318,7 +316,7 @@ class Support_Group{
     */
     public function load_With_SGroupId( $id) {
         $dbl = new DBLayer("lib");
-        $statement = $dbl->execute("SELECT * FROM `support_group` WHERE `SGroupId` = :id", array('id' => $id));
+        $statement = $dbl->select("`support_group`", array('id' => $id), "`SGroupId` = :id");
         $row = $statement->fetch();
         $this->set($row);
     }
@@ -329,9 +327,7 @@ class Support_Group{
     */
     public function update(){
         $dbl = new DBLayer("lib");
-        $query = "UPDATE `support_group` SET `Name` = :name, `Tag` = :tag, `GroupEmail` = :groupemail, `IMAP_MailServer` = :mailserver, `IMAP_Username` = :username, `IMAP_Password` = :password WHERE `SGroupId` = :id";
-        $values = Array('id' => $this->getSGroupId(), 'name' => $this->getName(), 'tag' => $this->getTag(), 'groupemail' => $this->getGroupEmail(), 'mailserver' => $this->getIMAP_MailServer(), 'username' => $this->getIMAP_Username(), 'password' => $this->getIMAP_Password() );
-        $statement = $dbl->execute($query, $values);
+        $dbl->update("`support_group`", Array('Name' => $this->getName(), 'Tag' => $this->getTag(), 'GroupEmail' => $this->getGroupEmail(), 'IMAP_MailServer' => $this->getIMAP_MailServer(), 'IMAP_Username' => $this->getIMAP_Username(), 'IMAP_password' => $this->getIMAP_Password(), "`SGroupId` = $this->getSGroupId()");
     }
     
     
@@ -341,9 +337,7 @@ class Support_Group{
     */
     public function delete(){
         $dbl = new DBLayer("lib");
-        $query = "DELETE FROM `support_group` WHERE `SGroupId` = :id";
-        $values = Array('id' => $this->getSGroupId());
-        $statement = $dbl->execute($query, $values);     
+        $dbl->delete("`support_group`", Array('id' => $this->getSGroupId(), "`SGroupId` = :id");
     }
     
     ////////////////////////////////////////////Getters////////////////////////////////////////////////////
@@ -453,4 +447,4 @@ class Support_Group{
     public function setIMAP_Password($p){
         $this->iMap_Password = $p;
     }
-}
\ No newline at end of file
+}
diff --git a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/sync.php b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/sync.php
index e9d4c8748..a79ef8b83 100644
--- a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/sync.php
+++ b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/sync.php
@@ -42,34 +42,37 @@ class Sync{
                                 $decode = json_decode($record['query']);
                                 $values = array('username' => $decode[0]);
                                 //make connection with and put into shard db & delete from the lib
-                                $sth = $db->execute("SELECT UId FROM user WHERE Login= :username;", $values);
+                                $sth=$db->selectWithParameter("UId", "user", $values, "Login= :username" );
                                 $result = $sth->fetchAll();
                                 foreach ($result as $UId) {
-                                    $ins_values = array('id' => $UId['UId']);
-                                    $db->execute("INSERT INTO permission (UId, ClientApplication, AccessPrivilege) VALUES (:id, 'r2', 'OPEN');", $ins_values);
-                                    $db->execute("INSERT INTO permission (UId, ClientApplication, AccessPrivilege) VALUES (:id , 'ryzom_open', 'OPEN');", $ins_values);
+                                    $ins_values = array('UId' => $UId['UId']);
+                                    $ins_values['ClientApplication'] = "r2";
+                                    $ins_values['AccessPrivilege'] = "OPEN";
+                                    $db->insert("permission", $ins_values);
+                                    $ins_values['ClientApplication'] = 'ryzom_open';
+                                    $db->insert("permission",$ins_values);
                                 }
                                 break;
                             case 'change_pass':
                                 $decode = json_decode($record['query']);
-                                $values = array('user' => $decode[0], 'pass' => $decode[1]);
+                                $values = array('Password' => $decode[1]);
                                 //make connection with and put into shard db & delete from the lib
-                                $db->execute("UPDATE user SET Password = :pass WHERE Login = :user",$values);              
+                                $db->update("user", $values, "Login = $decode[0]");              
                                 break;
                             case 'change_mail':
                                 $decode = json_decode($record['query']);
-                                $values = array('user' => $decode[0], 'mail' => $decode[1]);
+                                $values = array('Email' => $decode[1]);
                                 //make connection with and put into shard db & delete from the lib
-                                $db->execute("UPDATE user SET Email = :mail WHERE Login = :user",$values);              
+                                $db->update("user", $values, "Login = $decode[0]");              
                                 break;
                             case 'createUser': 
                                 $decode = json_decode($record['query']);
-                                $values = array('login' => $decode[0], 'pass' => $decode[1], 'mail' => $decode[2] );
+                                $values = array('Login' => $decode[0], 'Password' => $decode[1], 'Email' => $decode[2] );
                                 //make connection with and put into shard db & delete from the lib
-                                $db->execute("INSERT INTO user (Login, Password, Email) VALUES (:login, :pass, :mail)",$values);              
+                                $db->insert("user", $values);              
                                 break;
                         }
-                        $dbl->execute("DELETE FROM ams_querycache WHERE SID=:SID",array('SID' => $record['SID']));
+                        $dbl->delete("ams_querycache", array('SID' => $record['SID']), "SID=:SID");
                     }
                     if ($display == true) {
                         print('Syncing completed');
diff --git a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket.php b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket.php
index 21e2614d5..51f987e5a 100644
--- a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket.php
+++ b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket.php
@@ -27,7 +27,7 @@ class Ticket{
     public static function ticketExists($id) {
         $dbl = new DBLayer("lib");
         //check if ticket exists
-        if(  $dbl->execute(" SELECT * FROM `ticket` WHERE `TId` = :ticket_id", array('ticket_id' => $id) )->rowCount() ){
+        if(  $dbl->select("`ticket`", array('ticket_id' => $id), "`TId` = :ticket_id")->rowCount() ){
             return true;
         }else{
             return false;
@@ -343,9 +343,7 @@ class Ticket{
     */
     public function create(){
         $dbl = new DBLayer("lib");
-        $query = "INSERT INTO ticket (Timestamp, Title, Status, Queue, Ticket_Category, Author, Priority) VALUES (now(), :title, :status, :queue, :tcat, :author, :priority)";
-        $values = Array('title' => $this->title, 'status' => $this->status, 'queue' => $this->queue, 'tcat' => $this->ticket_category, 'author' => $this->author, 'priority' => $this->priority);
-        $this->tId = $dbl->executeReturnId($query, $values); ;
+        $this->tId = $dbl->executeReturnId("ticket", Array('Timestamp'=>now(), 'Title' => $this->title, 'Status' => $this->status, 'Queue' => $this->queue, 'Ticket_Category' => $this->ticket_category, 'Author' => $this->author, 'Priority' => $this->priority)); 
     }
 
     
@@ -356,7 +354,7 @@ class Ticket{
     */
     public function load_With_TId( $id) {
         $dbl = new DBLayer("lib");
-        $statement = $dbl->execute("SELECT * FROM ticket WHERE TId=:id", array('id' => $id));
+        $statement = $dbl->select("ticket", array('id' => $id), "TId=:id");
         $row = $statement->fetch();
         $this->tId = $row['TId'];
         $this->timestamp = $row['Timestamp'];
@@ -374,9 +372,7 @@ class Ticket{
     */
     public function update(){
         $dbl = new DBLayer("lib");
-        $query = "UPDATE ticket SET Timestamp = :timestamp, Title = :title, Status = :status, Queue = :queue, Ticket_Category = :tcat, Author = :author, Priority = :priority WHERE TId=:id";
-        $values = Array('id' => $this->tId, 'timestamp' => $this->timestamp, 'title' => $this->title, 'status' => $this->status, 'queue' => $this->queue, 'tcat' => $this->ticket_category, 'author' => $this->author, 'priority' => $this->priority);
-        $statement = $dbl->execute($query, $values);
+        $dbl->update("ticket", Array('Timestamp' => $this->timestamp, 'Title' => $this->title, 'Status' => $this->status, 'Queue' => $this->queue, 'Ticket_Category' => $this->ticket_category, 'Author' => $this->author, 'Priority' => $this->priority), "TId=$this->tId");
     }
     
     
@@ -575,4 +571,4 @@ class Ticket{
         $this->priority = $p;
     }
     
-}
\ No newline at end of file
+}
diff --git a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_category.php b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_category.php
index 92e603d12..f6941febe 100644
--- a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_category.php
+++ b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_category.php
@@ -16,10 +16,7 @@ class Ticket_Category{
     */
     public static function createTicketCategory( $name) {
         $dbl = new DBLayer("lib");
-        $query = "INSERT INTO ticket_category (Name) VALUES (:name)";
-        $values = Array('name' => $name);
-        $dbl->execute($query, $values);
-
+	$dbl->insert("ticket_category", Array('Name' => $name));
     }
 
 
@@ -40,7 +37,7 @@ class Ticket_Category{
     */
     public static function getAllCategories() {
         $dbl = new DBLayer("lib");
-        $statement = $dbl->executeWithoutParams("SELECT * FROM ticket_category");
+        $statement = $dbl->select("ticket_category", array(null), "1");
         $row = $statement->fetchAll();
         $result = Array();
         foreach($row as $category){
@@ -70,7 +67,7 @@ class Ticket_Category{
     */
     public function load_With_TCategoryId( $id) {
         $dbl = new DBLayer("lib");
-        $statement = $dbl->execute("SELECT * FROM ticket_category WHERE TCategoryId=:id", array('id' => $id));
+        $statement = $dbl->select("ticket_category", array('id' => $id), "TCategoryId=:id");
         $row = $statement->fetch();
         $this->tCategoryId = $row['TCategoryId'];
         $this->name = $row['Name'];
@@ -82,9 +79,7 @@ class Ticket_Category{
     */
     public function update(){
         $dbl = new DBLayer("lib");
-        $query = "UPDATE ticket_category SET Name = :name WHERE TCategoryId=:id";
-        $values = Array('id' => $this->tCategoryId, 'name' => $this->name);
-        $statement = $dbl->execute($query, $values);
+        $dbl->update("ticket_category", Array('Name' => $this->name), "TCategoryId = $this->tCategoryId");
     }
     
     ////////////////////////////////////////////Getters////////////////////////////////////////////////////
@@ -126,4 +121,4 @@ class Ticket_Category{
     }
    
     
-}
\ No newline at end of file
+}
diff --git a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_content.php b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_content.php
index 445cad867..8b7787f8e 100644
--- a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_content.php
+++ b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_content.php
@@ -43,9 +43,7 @@ class Ticket_Content{
     */
     public function create() {
         $dbl = new DBLayer("lib");
-        $query = "INSERT INTO ticket_content (Content) VALUES (:content)";
-        $values = Array('content' => $this->content);
-        $this->tContentId = $dbl->executeReturnId($query, $values); ;
+    	$this->tContentId = $dbl->executeReturnId("ticket_content", Array('Content' => $this->content));
     }
     
     
@@ -56,7 +54,7 @@ class Ticket_Content{
     */
     public function load_With_TContentId( $id) {
         $dbl = new DBLayer("lib");
-        $statement = $dbl->execute("SELECT * FROM ticket_content WHERE TContentId=:id", array('id' => $id));
+        $statement = $dbl->select("ticket_content", array('id' => $id), "TContentId=:id");
         $row = $statement->fetch();
         $this->tContentId = $row['TContentId'];
         $this->content = $row['Content'];
@@ -67,9 +65,7 @@ class Ticket_Content{
     */
     public function update(){
         $dbl = new DBLayer("lib");
-        $query = "UPDATE ticket_content SET Content = :content WHERE TContentId=:id";
-        $values = Array('id' => $this->tContentId, 'content' => $this->content);
-        $statement = $dbl->execute($query, $values);
+        $dbl->update("ticket_content", Array('Content' => $this->content), "TContentId = $this->tContentId");
     }
     
     ////////////////////////////////////////////Getters////////////////////////////////////////////////////
@@ -110,4 +106,4 @@ class Ticket_Content{
         $this->tContentId = $c;
     }
     
-}
\ No newline at end of file
+}
diff --git a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_info.php b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_info.php
index fc852d093..eb7c8ebc5 100644
--- a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_info.php
+++ b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_info.php
@@ -52,7 +52,7 @@ class Ticket_Info{
     public static function TicketHasInfo($ticket_id) {
         $dbl = new DBLayer("lib");
         //check if ticket is already assigned
-        if(  $dbl->execute(" SELECT * FROM `ticket_info` WHERE `Ticket` = :ticket_id", array('ticket_id' => $ticket_id) )->rowCount() ){
+        if(  $dbl->select("`ticket_info`", array('ticket_id' => $ticket_id), "`Ticket` = :ticket_id")->rowCount() ){
             return true;
         }else{
             return false;
@@ -102,7 +102,7 @@ class Ticket_Info{
     */
     public function load_With_TInfoId( $id) {
         $dbl = new DBLayer("lib");
-        $statement = $dbl->execute("SELECT * FROM ticket_info WHERE TInfoId=:id", array('id' => $id));
+        $statement = $dbl->select("ticket_info", array('id' => $id), "TInfoId=:id");
         $row = $statement->fetch();
         $this->set($row);
     }
@@ -115,7 +115,7 @@ class Ticket_Info{
     */
     public function load_With_Ticket( $id) {
         $dbl = new DBLayer("lib");
-        $statement = $dbl->execute("SELECT * FROM ticket_info WHERE Ticket=:id", array('id' => $id));
+        $statement = $dbl->select("ticket_info",  array('id' => $id), "Ticket=:id");
         $row = $statement->fetch();
         $this->set($row);
     }
@@ -127,12 +127,10 @@ class Ticket_Info{
     */
     public function create() {
         $dbl = new DBLayer("lib");
-        $query = "INSERT INTO ticket_info ( Ticket, ShardId, UserPosition,ViewPosition, ClientVersion, PatchVersion,ServerTick, ConnectState, LocalAddress, Memory, OS, 
-Processor, CPUID, CpuMask, HT, NeL3D,  UserId) VALUES ( :ticket, :shardid, :userposition, :viewposition, :clientversion, :patchversion, :servertick, :connectstate, :localaddress, :memory, :os, :processor, :cpuid, :cpu_mask, :ht, :nel3d, :user_id )";
-        $values = Array('ticket' => $this->getTicket(), 'shardid' => $this->getShardId(), 'userposition' => $this->getUser_Position(), 'viewposition' => $this->getView_Position(), 'clientversion' => $this->getClient_Version(),
-'patchversion' => $this->getPatch_Version(), 'servertick' => $this->getServer_Tick(), 'connectstate' => $this->getConnect_State(), 'localaddress' => $this->getLocal_Address(), 'memory' => $this->getMemory(), 'os'=> $this->getOS(), 'processor' => $this->getProcessor(), 'cpuid' => $this->getCPUId(),
-'cpu_mask' => $this->getCpu_Mask(), 'ht' => $this->getHT(), 'nel3d' => $this->getNel3D(), 'user_id' => $this->getUser_Id());
-        $dbl->execute($query, $values);
+        $values = Array('Ticket' => $this->getTicket(), 'ShardId' => $this->getShardId(), 'UserPosition' => $this->getUser_Position(), 'ViewPosition' => $this->getView_Position(), 'ClientVersion' => $this->getClient_Version(),
+'PatchVersion' => $this->getPatch_Version(), 'ServerTick' => $this->getServer_Tick(), 'ConnectState' => $this->getConnect_State(), 'LocalAddress' => $this->getLocal_Address(), 'Memory' => $this->getMemory(), 'OS'=> $this->getOS(), 'Processor' => $this->getProcessor(), 'CPUID' => $this->getCPUId(),
+'CpuMask' => $this->getCpu_Mask(), 'HT' => $this->getHT(), 'NeL3D' => $this->getNel3D(), 'UserId' => $this->getUser_Id());
+        $dbl->insert("ticket_info",$values);
     }
 
     
@@ -411,4 +409,4 @@ Processor, CPUID, CpuMask, HT, NeL3D,  UserId) VALUES ( :ticket, :shardid, :user
     }
     
 
-}
\ No newline at end of file
+}
diff --git a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_log.php b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_log.php
index 8c7439bc0..6693fe3ce 100644
--- a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_log.php
+++ b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_log.php
@@ -82,9 +82,8 @@ class Ticket_Log{
         global $TICKET_LOGGING;
         if($TICKET_LOGGING){
             $dbl = new DBLayer("lib");
-            $query = "INSERT INTO ticket_log (Timestamp, Query, Ticket, Author) VALUES (now(), :query, :ticket, :author )";
-            $values = Array('ticket' => $ticket_id, 'author' => $author_id, 'query' => json_encode(array($action,$arg)));
-            $dbl->execute($query, $values);
+	    $values = Array('Timestamp'=>now(), 'Query' => json_encode(array($action,$arg)), 'Ticket' => $ticket_id, 'Author' => $author_id);
+            $dbl->insert("ticket_log", $values);
         }
     }
 
@@ -148,7 +147,7 @@ class Ticket_Log{
     */
     public function load_With_TLogId( $id) {
         $dbl = new DBLayer("lib");
-        $statement = $dbl->execute("SELECT * FROM ticket_log WHERE TLogId=:id", array('id' => $id));
+        $dbl->select("ticket_log", array('id' => $id), "TLogId=:id");
         $row = $statement->fetch();
         $this->set($row);
     }
@@ -159,9 +158,10 @@ class Ticket_Log{
     */
     public function update(){
         $dbl = new DBLayer("lib");
-        $query = "UPDATE ticket_log SET Timestamp = :timestamp, Query = :query, Author = :author, Ticket = :ticket WHERE TLogId=:id";
-        $values = Array('id' => $this->getTLogId(), 'timestamp' => $this->getTimestamp(), 'query' => $this->getQuery(), 'author' => $this->getAuthor(), 'ticket' => $this->getTicket() );
-        $statement = $dbl->execute($query, $values);
+        
+        $values = Array('timestamp' => $this->getTimestamp(), 'query' => $this->getQuery(), 'author' => $this->getAuthor(), 'ticket' => $this->getTicket() );
+        $dbl->update("ticket_log", $values, "TLogId = $this->getTLogId()");
+        
     }
     
     ////////////////////////////////////////////Getters////////////////////////////////////////////////////
@@ -273,4 +273,4 @@ class Ticket_Log{
     }
    
     
-}
\ No newline at end of file
+}
diff --git a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_reply.php b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_reply.php
index 8e784543d..2675fcfbe 100644
--- a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_reply.php
+++ b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_reply.php
@@ -123,9 +123,7 @@ class Ticket_Reply{
     */
     public function create(){
         $dbl = new DBLayer("lib");
-        $query = "INSERT INTO ticket_reply (Ticket, Content, Author, Timestamp, Hidden) VALUES (:ticket, :content, :author, now(), :hidden)";
-        $values = Array('ticket' => $this->ticket, 'content' => $this->content, 'author' => $this->author, 'hidden' => $this->hidden);
-        $this->tReplyId = $dbl->executeReturnId($query, $values); 
+        $this->tReplyId = $dbl->executeReturnId("ticket_reply", Array('Ticket' => $this->ticket, 'Content' => $this->content, 'Author' => $this->author,'Timestamp'=>now(), 'Hidden' => $this->hidden)); 
     }
 
     /**
@@ -135,7 +133,7 @@ class Ticket_Reply{
     */
     public function load_With_TReplyId( $id) {
         $dbl = new DBLayer("lib");
-        $statement = $dbl->execute("SELECT * FROM ticket_reply WHERE TReplyId=:id", array('id' => $id));
+        $statement = $dbl->select("ticket_reply", array('id' => $id), "TReplyId=:id");
         $row = $statement->fetch();
         $this->tReplyId = $row['TReplyId'];
         $this->ticket = $row['Ticket'];
@@ -150,9 +148,7 @@ class Ticket_Reply{
     */
     public function update(){
         $dbl = new DBLayer("lib");
-        $query = "UPDATE ticket SET Ticket = :ticket, Content = :content, Author = :author, Timestamp = :timestamp, Hidden = :hidden WHERE TReplyId=:id";
-        $values = Array('id' => $this->tReplyId, 'timestamp' => $this->timestamp, 'ticket' => $this->ticket, 'content' => $this->content, 'author' => $this->author, 'hidden' => $this->hidden);
-        $statement = $dbl->execute($query, $values);
+        $dbl->update("ticket", Array('Ticket' => $this->ticket, 'Content' => $this->content, 'Author' => $this->author, 'Timestamp' => $this->timestamp, 'Hidden' => $this->hidden), "TReplyId=$this->tReplyId, ");
     }
     
     ////////////////////////////////////////////Getters////////////////////////////////////////////////////
@@ -249,4 +245,4 @@ class Ticket_Reply{
     public function setHidden($h){
         $this->hidden = $h;
     }
-}
\ No newline at end of file
+}
diff --git a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_user.php b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_user.php
index 46125e284..0937b48b0 100644
--- a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_user.php
+++ b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/ticket_user.php
@@ -21,10 +21,7 @@ class Ticket_User{
     */
     public static function createTicketUser( $extern_id, $permission) {
         $dbl = new DBLayer("lib");
-        $query = "INSERT INTO ticket_user (Permission, ExternId) VALUES (:perm, :ext_id)";
-        $values = Array('perm' => $permission, 'ext_id' => $extern_id);
-        $dbl->execute($query, $values);
-
+	$dbl->insert("ticket_user",array('Permission' => $permission, 'ExternId' => $extern_id));
     }
     
     
@@ -73,7 +70,7 @@ class Ticket_User{
     */
     public static function getModsAndAdmins() {
         $dbl = new DBLayer("lib");
-        $statement = $dbl->executeWithoutParams("SELECT * FROM `ticket_user` WHERE `Permission` > 1");
+        $statement = $dbl->select("ticket_user", array(null), "`Permission` > 1" );
         $rows = $statement->fetchAll();
         $result = Array();
         foreach($rows as $user){
@@ -93,7 +90,7 @@ class Ticket_User{
     public static function constr_ExternId( $id) {
         $instance = new self();
         $dbl = new DBLayer("lib");
-        $statement = $dbl->execute("SELECT * FROM ticket_user WHERE ExternId=:id", array('id' => $id));
+        $statement = $dbl->select("ticket_user" ,array('id'=>$id) ,"ExternId=:id");
         $row = $statement->fetch();
         $instance->tUserId = $row['TUserId'];
         $instance->permission = $row['Permission'];
@@ -196,7 +193,7 @@ class Ticket_User{
     */
     public function load_With_TUserId( $id) {
         $dbl = new DBLayer("lib");
-        $statement = $dbl->execute("SELECT * FROM ticket_user WHERE TUserId=:id", array('id' => $id));
+        $statement = $dbl->select("ticket_user" ,array('id'=>$id), "TUserId=:id" );
         $row = $statement->fetch();
         $this->tUserId = $row['TUserId'];
         $this->permission = $row['Permission'];
@@ -209,9 +206,7 @@ class Ticket_User{
     */
     public function update(){
         $dbl = new DBLayer("lib");
-        $query = "UPDATE ticket_user SET Permission = :perm, ExternId = :ext_id WHERE TUserId=:id";
-        $values = Array('id' => $this->tUserId, 'perm' => $this->permission, 'ext_id' => $this->externId);
-        $statement = $dbl->execute($query, $values);
+        $dbl->update("ticket_user" ,array('Permission' => $this->permission, 'ExternId' => $this->externId) ,"TUserId=$this->tUserId");
     }
     
     ////////////////////////////////////////////Getters////////////////////////////////////////////////////
@@ -266,4 +261,4 @@ class Ticket_User{
     }
     
     
-}
\ No newline at end of file
+}
diff --git a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/users.php b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/users.php
index f83f46576..e9463b0b0 100644
--- a/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/users.php
+++ b/code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/users.php
@@ -291,9 +291,10 @@ class Users{
                //make connection with and put into shard db
                $values['user_id']= $user_id;
                $dbs = new DBLayer("shard");
-               $dbs->execute("INSERT INTO user (Login, Password, Email) VALUES (:name, :pass, :mail)",$values);
+               $dbs->insert("user", $values);
                $dbr = new DBLayer("ring");
-               $dbr->execute("INSERT INTO ring_users (user_id, user_name, user_type) VALUES (:user_id, :name, 'ut_pioneer')",$values);
+               $values['user_type'] = 'ut_pioneer';
+               $dbr->insert("ring_users", $values);	
                ticket_user::createTicketUser( $user_id, 1);
                return "ok";
           }
@@ -301,7 +302,7 @@ class Users{
                //oh noooz, the shard is offline! Put in query queue at ams_lib db!
                try {
                     $dbl = new DBLayer("lib");  
-                    $dbl->execute("INSERT INTO ams_querycache (type, query, db) VALUES (:type, :query, :db)",array("type" => "createUser",
+                    $dbl->insert("ams_querycache", array("type" => "createUser",
                     "query" => json_encode(array($values["name"],$values["pass"],$values["mail"])), "db" => "shard"));
                     ticket_user::createTicketUser( $user_id , 1 );
                     return "shardoffline";
@@ -323,21 +324,20 @@ class Users{
           try {
                $values = array('username' =>  $pvalues[0]);
                $dbs = new DBLayer("shard");
-               $sth = $dbs->execute("SELECT UId FROM user WHERE Login= :username;", $values);
+               $sth = $dbs->selectWithParameter("UId", "user", $values, "Login= :username");
                $result = $sth->fetchAll();
                foreach ($result as $UId) {
-                   $ins_values = array('id' => $UId['UId']);
-                   $dbs->execute("INSERT INTO permission (UId, ClientApplication, AccessPrivilege) VALUES (:id, 'r2', 'OPEN');", $ins_values);
-                   $dbs->execute("INSERT INTO permission (UId, ClientApplication, AccessPrivilege) VALUES (:id , 'ryzom_open', 'OPEN');", $ins_values);
+                   $ins_values = array('UId' => $UId['UId'], 'clientApplication' => 'r2', 'AccessPrivilege' => 'OPEN');
+                   $dbs->insert("permission", $ins_values);
+                   $ins_values['clientApplication'] = 'ryzom_open';
+                   $dbs->insert("permission", $ins_values);
                }
           }
           catch (PDOException $e) {
                //oh noooz, the shard is offline! Put it in query queue at ams_lib db!
                $dbl = new DBLayer("lib");
-               $dbl->execute("INSERT INTO ams_querycache (type, query, db) VALUES (:type, :query, :db)",array("type" => "createPermissions",
-               "query" => json_encode(array($pvalues[0])), "db" => "shard"));
-                    
-            
+               $dbl->insert("ams_querycache", array("type" => "createPermissions",
+               "query" => json_encode(array($pvalues[0])), "db" => "shard"));            
           } 
           return true;
      }
@@ -421,19 +421,19 @@ class Users{
      */
      protected static function setAmsPassword($user, $pass){
           
-           $values = Array('user' => $user, 'pass' => $pass);
+           $values = Array('Password' => $pass);
            
            try {
                //make connection with and put into shard db
                $dbs = new DBLayer("shard");
-               $dbs->execute("UPDATE user SET Password = :pass WHERE Login = :user ",$values);
+               $dbs->update("user", $values, "Login = $user");
                return "ok";
           }
           catch (PDOException $e) {
                //oh noooz, the shard is offline! Put in query queue at ams_lib db!
                try {
                     $dbl = new DBLayer("lib");
-                    $dbl->execute("INSERT INTO ams_querycache (type, query, db) VALUES (:type, :query, :db)",array("type" => "change_pass",
+                    $dbl->insert("ams_querycache", array("type" => "change_pass",
                     "query" => json_encode(array($values["user"],$values["pass"])), "db" => "shard"));
                     return "shardoffline";
                }catch (PDOException $e) {
@@ -451,19 +451,19 @@ class Users{
      */
      protected static function setAmsEmail($user, $mail){
           
-           $values = Array('user' => $user, 'mail' => $mail);
+           $values = Array('Email' => $mail);
            
            try {
                //make connection with and put into shard db
                $dbs = new DBLayer("shard");
-               $dbs->execute("UPDATE user SET Email = :mail WHERE Login = :user ",$values);
+               $dbs->update("user", $values, "Login = $user");
                return "ok";
           }
           catch (PDOException $e) {
                //oh noooz, the shard is offline! Put in query queue at ams_lib db!
                try {
                     $dbl = new DBLayer("lib");
-                    $dbl->execute("INSERT INTO ams_querycache (type, query, db) VALUES (:type, :query, :db)",array("type" => "change_mail",
+                    $dbl->insert("ams_querycache", array("type" => "change_mail",
                     "query" => json_encode(array($values["user"],$values["mail"])), "db" => "shard"));
                     return "shardoffline";
                }catch (PDOException $e) {
@@ -474,4 +474,4 @@ class Users{
 }
 
 
-     
\ No newline at end of file
+     
diff --git a/code/ryzom/tools/server/ryzom_ams/www/html/autoload/webusers.php b/code/ryzom/tools/server/ryzom_ams/www/html/autoload/webusers.php
index d8e59d1f9..78916e606 100644
--- a/code/ryzom/tools/server/ryzom_ams/www/html/autoload/webusers.php
+++ b/code/ryzom/tools/server/ryzom_ams/www/html/autoload/webusers.php
@@ -53,7 +53,7 @@ class WebUsers extends Users{
        */
        protected function checkUserNameExists($username){
               $dbw = new DBLayer("web");
-              return $dbw->execute("SELECT * FROM ams_user WHERE Login = :name",array('name' => $username))->rowCount();  
+              return $dbw->select("ams_user", array('name' => $username), "Login = :name")->rowCount();  
        }
     
     
@@ -65,7 +65,7 @@ class WebUsers extends Users{
        */
        protected function checkEmailExists($email){
               $dbw = new DBLayer("web");
-              return $dbw->execute("SELECT * FROM ams_user WHERE Email = :email",array('email' => $email))->rowCount();
+              return $dbw->select("ams_user" ,array('email' => $email),"Email = :email")->rowCount();
        }
      
      
@@ -78,7 +78,7 @@ class WebUsers extends Users{
        public static function checkLoginMatch($username,$password){
   
           $dbw = new DBLayer("web");
-          $statement = $dbw->execute("SELECT * FROM ams_user WHERE Login=:user", array('user' => $username));
+          $statement = $dbw->select("ams_user", array('value' => $value),"Login=:value OR Email=:value");
           $row = $statement->fetch();
           $salt = substr($row['Password'],0,2);
           $hashed_input_pass = crypt($password, $salt);
@@ -97,7 +97,7 @@ class WebUsers extends Users{
        */
        public static function getId($username){
          $dbw = new DBLayer("web");  
-         $statement = $dbw->execute("SELECT * FROM ams_user WHERE Login=:username", array('username' => $username));
+         $statement = $dbw->select("ams_user", array('username' => $username), "Login=:username");
          $row = $statement->fetch();
          return $row['UId'];
        }
@@ -110,7 +110,7 @@ class WebUsers extends Users{
        */
        public static function getIdFromEmail($email){
           $dbw = new DBLayer("web");  
-          $statement = $dbw->execute("SELECT * FROM ams_user WHERE Email=:email", array('email' => $email));
+          $statement = $dbw->select("ams_user", array('email' => $email), "Email=:email");
           $row = $statement->fetch();
           if(!empty($row)){
               return $row['UId'];
@@ -134,7 +134,7 @@ class WebUsers extends Users{
        public function getUsername(){
           $dbw = new DBLayer("web");
           if(! isset($this->login) || $this->login == ""){
-                $statement = $dbw->execute("SELECT * FROM ams_user WHERE UId=:id", array('id' => $this->uId));
+                $statement = $dbw->select("ams_user", array('id' => $this->uId), "UId=:id");
                 $row = $statement->fetch();
                 $this->set($row);
           }
@@ -148,7 +148,7 @@ class WebUsers extends Users{
        public function getEmail(){
           $dbw = new DBLayer("web");
           if(! isset($this->email) || $this->email == ""){
-                 $statement = $dbw->execute("SELECT * FROM ams_user WHERE UId=:id", array('id' => $this->uId));
+                 $statement = $dbw->select("ams_user", array('id' => $this->uId), "UId=:id");
                  $row = $statement->fetch();
                  $this->set($row);
           }
@@ -160,7 +160,7 @@ class WebUsers extends Users{
        */
        public function getHashedPass(){
               $dbw = new DBLayer("web");
-              $statement = $dbw->execute("SELECT * FROM ams_user WHERE UId=:id", array('id' => $this->uId));
+              $statement = $dbw->select("ams_user", array('id' => $this->uId), "UId=:id");
               $row = $statement->fetch();
               return $row['Password'];
        }
@@ -174,7 +174,7 @@ class WebUsers extends Users{
           $dbw = new DBLayer("web");
           if(! (isset($this->firstname) && isset($this->lastname) && isset($this->gender) && isset($this->country) && isset($this->receiveMail) ) ||
              $this->firstname == "" || $this->lastname == "" || $this->gender == "" || $this->country == "" || $this->receiveMail == ""){
-                $statement = $dbw->execute("SELECT * FROM ams_user WHERE UId=:id", array('id' => $this->uId));
+                $statement = $dbw->select("ams_user", array('id' => $this->uId), "UId=:id");
                 $row = $statement->fetch();
                 $this->set($row);
           }
@@ -189,7 +189,7 @@ class WebUsers extends Users{
        public function getReceiveMail(){
               $dbw = new DBLayer("web");
               if(! isset($this->receiveMail) || $this->receiveMail == ""){
-                     $statement = $dbw->execute("SELECT * FROM ams_user WHERE UId=:id", array('id' => $this->uId));
+                     $statement = $dbw->select("ams_user", array('id' => $this->uId), "UId=:id");
                      $row = $statement->fetch();
                      $this->set($row);
               }
@@ -203,7 +203,7 @@ class WebUsers extends Users{
        public function getLanguage(){
               $dbw = new DBLayer("web");
               if(! isset($this->language) || $this->language == ""){
-                     $statement = $dbw->execute("SELECT * FROM ams_user WHERE UId=:id", array('id' => $this->uId));
+                     $statement = $dbw->select("ams_user", array('id' => $this->uId), "UId=:id");
                      $row = $statement->fetch();
                      $this->set($row);
               }
@@ -234,11 +234,11 @@ class WebUsers extends Users{
               
               $hashpass = crypt($pass, WebUsers::generateSALT());
               $reply = WebUsers::setAmsPassword($user, $hashpass);
-              $values = Array('user' => $user, 'pass' => $hashpass);
+              $values = Array('pass' => $hashpass);
                try {
                      //make connection with and put into shard db
                      $dbw = new DBLayer("web");
-                     $dbw->execute("UPDATE ams_user SET Password = :pass WHERE Login = :user ",$values);
+                     $dbw->update("ams_user", $values,"Login = $user");
                 }
                 catch (PDOException $e) {
                   //ERROR: the web DB is offline
@@ -256,11 +256,11 @@ class WebUsers extends Users{
        */
        public static function setEmail($user, $mail){
           $reply = WebUsers::setAmsEmail($user, $mail);
-          $values = Array('user' => $user, 'mail' => $mail);
+          $values = Array('Email' => $mail);
            try {
                  //make connection with and put into shard db
                  $dbw = new DBLayer("web");
-                 $dbw->execute("UPDATE ams_user SET Email = :mail WHERE Login = :user ",$values);
+                 $dbw->update("ams_user", $values, "Login = $user");
             }
             catch (PDOException $e) {
               //ERROR: the web DB is offline
@@ -276,11 +276,11 @@ class WebUsers extends Users{
        * @param $receivemail the receivemail setting .
        */
        public static function setReceiveMail($user, $receivemail){
-              $values = Array('user' => $user, 'receivemail' => $receivemail);
+              $values = Array('Receivemail' => $receivemail);
               try {
                     //make connection with and put into shard db
                     $dbw = new DBLayer("web");
-                    $dbw->execute("UPDATE ams_user SET ReceiveMail = :receivemail WHERE UId = :user ",$values);
+                    $dbw->update("ams_user", $values, "UId = $user" );	
               }
               catch (PDOException $e) {
                  //ERROR: the web DB is offline
@@ -295,11 +295,11 @@ class WebUsers extends Users{
        * @param $language the new language value.
        */
       public static function setLanguage($user, $language){
-              $values = Array('user' => $user, 'language' => $language);
+              $values = Array('Language' => $language);
               try {
                     //make connection with and put into shard db
                     $dbw = new DBLayer("web");
-                    $dbw->execute("UPDATE ams_user SET Language = :language WHERE UId = :user ",$values);
+                    $dbw->update("ams_user", $values, "UId = $user");
                }
                catch (PDOException $e) {
                  //ERROR: the web DB is offline
@@ -344,15 +344,15 @@ class WebUsers extends Users{
                  $lang = $DEFAULT_LANGUAGE;
           }
           
-          $values = Array('name' => $name, 'pass' => $pass, 'mail' => $mail, 'lang' => $lang);
+          $values = Array('Login' => $name, 'Password' => $pass, 'Email' => $mail, 'Language' => $lang);
           
           try {
              $dbw = new DBLayer("web");
-             return $dbw->executeReturnId("INSERT INTO ams_user (Login, Password, Email, Language) VALUES (:name, :pass, :mail, :lang)",$values);
+             return $dbw->executeReturnId("ams_user", $values);
           }
           catch (PDOException $e) {
                //ERROR: the web DB is offline
           }
        }
     
-}
\ No newline at end of file
+}
diff --git a/code/ryzom/tools/server/ryzom_ams/www/html/func/add_user.php b/code/ryzom/tools/server/ryzom_ams/www/html/func/add_user.php
index fa08ef1a5..a40e22450 100644
--- a/code/ryzom/tools/server/ryzom_ams/www/html/func/add_user.php
+++ b/code/ryzom/tools/server/ryzom_ams/www/html/func/add_user.php
@@ -66,15 +66,14 @@ function write_user($newUser){
      $hashpass = crypt($newUser["pass"], WebUsers::generateSALT());
      
      $params = array(
-          'name' => $newUser["name"],
-          'pass' => $hashpass,
-          'mail' => $newUser["mail"]      
+    	  'Login' => $newUser["name"],
+          'Password' => $hashpass,
+          'Email' => $newUser["mail"]      
      );
-  
      try{
           //make new webuser
-          $user_id = WebUsers::createWebuser($params['name'], $params['pass'], $params['mail']);
-          
+          $user_id = WebUsers::createWebuser($params['Login'], $params['Password'], $params['Email']);
+               
           //Create the user on the shard + in case shard is offline put copy of query in query db
           //returns: ok, shardoffline or liboffline
           $result = WebUsers::createUser($params, $user_id);