Changeset 272 for trunk/src/shared/Database/SQLStorage.cpp

Timestamp:

11/22/08 00:35:41 (17 years ago)

Author:

yumileroy

Message:

Delete possessed AI only on creature delete.

Original author: gvcoman
Date: 2008-11-16 14:38:02-05:00

Files:

• trunk/src/shared/Database/SQLStorage.cpp (modified) (5 diffs)

trunk/src/shared/Database/SQLStorage.cpp

@@ -11 +11 @@
  * This program is distributed in the hope that it will be useful,
  * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  * GNU General Public License for more details.
  *
  * You should have received a copy of the GNU General Public License
  * along with this program; if not, write to the Free Software
- * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
  */
 
 #include "SQLStorage.h"
-#include "SQLStorageImpl.h"
+#include "ProgressBar.h"
+#include "Log.h"
+#include "dbcfile.h"
 
 #ifdef DO_POSTGRESQL
@@ -28 +30 @@
 #endif
 
-const char CreatureInfosrcfmt[]="iiiiiisssiiiiiiiiiiffiffiiiiiiiiiiiffiiiiiiiiiiiiiiiiiiisiilliiis";
-const char CreatureInfodstfmt[]="iiiiiisssiiiiiiiiiiffiffiiiiiiiiiiiffiiiiiiiiiiiiiiiiiiisiilliiii";
+const char CreatureInfofmt[]="iiiiiisssiiiiiiiiiiffiffiiiiiiiiiiiffiiiiiiiiiiiiiiiiiiisiilliiis";
 const char CreatureDataAddonInfofmt[]="iiiiiiis";
 const char CreatureModelfmt[]="iffbi";
 const char CreatureInfoAddonInfofmt[]="iiiiiiis";
 const char EquipmentInfofmt[]="iiiiiiiiii";
-const char GameObjectInfosrcfmt[]="iiissiifiiiiiiiiiiiiiiiiiiiiiiiis";
-const char GameObjectInfodstfmt[]="iiissiifiiiiiiiiiiiiiiiiiiiiiiiii";
-const char ItemPrototypesrcfmt[]="iiiisiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiffiffiffiffiffiiiiiiiiiifiiifiiiiiifiiiiiifiiiiiifiiiiiifiiiisiiiiiiiiiiiiiiiiiiiiiiiiifsiiiii";
-const char ItemPrototypedstfmt[]="iiiisiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiffiffiffiffiffiiiiiiiiiifiiifiiiiiifiiiiiifiiiiiifiiiiiifiiiisiiiiiiiiiiiiiiiiiiiiiiiiifiiiiii";
+const char GameObjectInfofmt[]="iiissiifiiiiiiiiiiiiiiiiiiiiiiiis";
+const char ItemPrototypefmt[]="iiiisiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiffiffiffiffiffiiiiiiiiiifiiifiiiiiifiiiiiifiiiiiifiiiiiifiiiisiiiiiiiiiiiiiiiiiiiiiiiiifsiiiii";
 const char PageTextfmt[]="isi";
 const char SpellThreatfmt[]="ii";
-const char InstanceTemplatesrcfmt[]="iiiiiiffffs";
-const char InstanceTemplatedstfmt[]="iiiiiiffffi";
+const char InstanceTemplatefmt[]="iiiiiiffffs";
 
-SQLStorage sCreatureStorage(CreatureInfosrcfmt, CreatureInfodstfmt, "entry","creature_template");
+SQLStorage sCreatureStorage(CreatureInfofmt,"entry","creature_template");
 SQLStorage sCreatureDataAddonStorage(CreatureDataAddonInfofmt,"guid","creature_addon");
 SQLStorage sCreatureModelStorage(CreatureModelfmt,"modelid","creature_model_info");
 SQLStorage sCreatureInfoAddonStorage(CreatureInfoAddonInfofmt,"entry","creature_template_addon");
 SQLStorage sEquipmentStorage(EquipmentInfofmt,"entry","creature_equip_template");
-SQLStorage sGOStorage(GameObjectInfosrcfmt, GameObjectInfodstfmt, "entry","gameobject_template");
-SQLStorage sItemStorage(ItemPrototypesrcfmt, ItemPrototypedstfmt, "entry","item_template");
+SQLStorage sGOStorage(GameObjectInfofmt,"entry","gameobject_template");
+SQLStorage sItemStorage(ItemPrototypefmt,"entry","item_template");
 SQLStorage sPageTextStore(PageTextfmt,"entry","page_text");
 SQLStorage sSpellThreatStore(SpellThreatfmt,"entry","spell_threat");
-SQLStorage sInstanceTemplate(InstanceTemplatesrcfmt, InstanceTemplatedstfmt, "map","instance_template");
+SQLStorage sInstanceTemplate(InstanceTemplatefmt,"map","instance_template");
 
 void SQLStorage::Free ()
@@ -58 +56 @@
     uint32 offset=0;
     for(uint32 x=0;x<iNumFields;x++)
-        if (dst_format[x]==FT_STRING)
+        if (format[x]==FT_STRING)
         {
             for(uint32 y=0;y<MaxEntry;y++)
@@ -64 +62 @@
                     delete [] *(char**)((char*)(pIndex[y])+offset);
 
-            offset += sizeof(char*);
+            offset+=sizeof(char*);
         }
-        else if (dst_format[x]==FT_LOGIC)
-            offset += sizeof(bool);
-        else if (dst_format[x]==FT_BYTE)
-            offset += sizeof(char);
+        else if (format[x]==FT_LOGIC)
+            offset+=sizeof(bool);
+        else if (format[x]==FT_BYTE)
+            offset+=sizeof(char);
         else
-            offset += 4;
+            offset+=4;
 
     delete [] pIndex;
@@ -77 +75 @@
 }
 
-void SQLStorage::Load()
+void SQLStorage::Load ()
 {
-    SQLStorageLoader loader;
-    loader.Load(*this);
+    uint32 maxi;
+    Field *fields;
+    QueryResult *result  = WorldDatabase.PQuery("SELECT MAX(%s) FROM %s",entry_field,table);
+    if(!result)
+    {
+        sLog.outError("Error loading %s table (not exist?)\n",table);
+        exit(1);                                            // Stop server at loading non exited table or not accessable table
+    }
+
+    maxi= (*result)[0].GetUInt32()+1;
+    delete result;
+
+    result = WorldDatabase.PQuery("SELECT COUNT(*) FROM %s",table);
+    if(result)
+    {
+        fields = result->Fetch();
+        RecordCount=fields[0].GetUInt32();
+        delete result;
+    }
+    else
+        RecordCount = 0;
+
+    result = WorldDatabase.PQuery("SELECT * FROM %s",table);
+
+    if(!result)
+    {
+        sLog.outError("%s table is empty!\n",table);
+        RecordCount = 0;
+        return;
+    }
+
+    uint32 recordsize=0;
+    uint32 offset=0;
+
+    if(iNumFields!=result->GetFieldCount())
+    {
+        RecordCount = 0;
+        sLog.outError("Error in %s table, probably sql file format was updated (there should be %d fields in sql).\n",table,iNumFields);
+        delete result;
+        exit(1);                                            // Stop server at loading broken or non-compatiable table.
+    }
+
+    //get struct size
+    uint32 sc=0;
+    uint32 bo=0;
+    uint32 bb=0;
+    for(uint32 x=0;x<iNumFields;x++)
+        if(format[x]==FT_STRING)
+            ++sc;
+        else if (format[x]==FT_LOGIC)
+            ++bo;
+        else if (format[x]==FT_BYTE)
+            ++bb;
+    recordsize=(iNumFields-sc-bo-bb)*4+sc*sizeof(char*)+bo*sizeof(bool)+bb*sizeof(char);
+
+    char** newIndex=new char*[maxi];
+    memset(newIndex,0,maxi*sizeof(char*));
+
+    char * _data= new char[RecordCount *recordsize];
+    uint32 count=0;
+    barGoLink bar( RecordCount );
+    do
+    {
+        fields = result->Fetch();
+        bar.step();
+        char *p=(char*)&_data[recordsize*count];
+        newIndex[fields[0].GetUInt32()]=p;
+
+        offset=0;
+        for(uint32 x=0;x<iNumFields;x++)
+            switch(format[x])
+            {
+                case FT_LOGIC:
+                    *((bool*)(&p[offset]))=(fields[x].GetUInt32()>0);
+                    offset+=sizeof(bool);
+                    break;
+                case FT_BYTE:
+                    *((char*)(&p[offset]))=(fields[x].GetUInt8());
+                    offset+=sizeof(char);
+                    break;
+                case FT_INT:
+                    *((uint32*)(&p[offset]))=fields[x].GetUInt32();
+                    offset+=sizeof(uint32);
+                    break;
+                case FT_FLOAT:
+                    *((float*)(&p[offset]))=fields[x].GetFloat();
+                    offset+=sizeof(float);
+                    break;
+                case FT_STRING:
+                    char const* tmp = fields[x].GetString();
+                    char* st;
+                    if(!tmp)
+                    {
+                        st=new char[1];
+                        *st=0;
+                    }
+                    else
+                    {
+                        uint32 l=strlen(tmp)+1;
+                        st=new char[l];
+                        memcpy(st,tmp,l);
+                    }
+                    *((char**)(&p[offset]))=st;
+                    offset+=sizeof(char*);
+                    break;
+            }
+        ++count;
+    }while( result->NextRow() );
+
+    delete result;
+
+    pIndex =newIndex;
+    MaxEntry=maxi;
+    data=_data;
 }