AS OF SVN REV. 5901, WE ARE NOW USING TRUNK. ALL UNTESTED BUGFIXES/FEATURES GO INTO TRUNK.

IF YOU HAVE A WORKING AND TESTED BUGFIX PUT IT INTO STABLE AS WELL AS TRUNK.  EVERYTHING ELSE
GOES INTO TRUNK AND WILL BE MERGED INTO STABLE BY VALARIS AND WIZPUTER. -- VALARIS


git-svn-id: https://rathena.svn.sourceforge.net/svnroot/rathena/trunk@5094 54d463be-8e91-2dee-dedb-b68131a5f0ec

1 files changed, 229 insertions, 0 deletions

diff --git a/src/char_sql/itemdb.c b/src/char_sql/itemdb.c
new file mode 100644
index 000000000..25c55e73d
--- /dev/null
+++ b/src/char_sql/itemdb.c
@@ -0,0 +1,229 @@
+// Copyright (c) Athena Dev Teams - Licensed under GNU GPL

+// For more information, see LICENCE in the main folder

+

+#include <stdio.h>

+#include <stdlib.h>

+#include <string.h>

+

+#include "itemdb.h"

+#include "db.h"

+#include "inter.h"

+#include "char.h"

+#include "utils.h"

+#include "../common/showmsg.h"

+

+#define MAX_RANDITEM	2000

+

+// ** ITEMDB_OVERRIDE_NAME_VERBOSE **

+//   定義すると、itemdb.txtとgrfで名前が異なる場合、表示します.

+//#define ITEMDB_OVERRIDE_NAME_VERBOSE	1

+

+char item_db_db[256]="item_db"; // added to specify item_db sql table [Valaris]

+

+static struct dbt* item_db;

+

+static void* create_item(DBKey key, va_list args) {

+	struct item_data *id;

+	int nameid = key.i;

+

+	CREATE(id, struct item_data, 1);

+		id->nameid = nameid;

+	if(nameid>500 && nameid<600)

+		id->type=0;   //heal item

+	else if(nameid>600 && nameid<700)

+		id->type=2;   //use item

+	else if((nameid>700 && nameid<1100) ||

+			(nameid>7000 && nameid<8000))

+		id->type=3;   //correction

+	else if(nameid>=1750 && nameid<1771)

+		id->type=10;  //arrow

+	else if(nameid>1100 && nameid<2000)

+		id->type=4;   //weapon

+	else if((nameid>2100 && nameid<3000) ||

+			(nameid>5000 && nameid<6000))

+		id->type=5;   //armor

+	else if(nameid>4000 && nameid<5000)

+		id->type=6;   //card

+	else if(nameid>9000 && nameid<10000)

+		id->type=7;   //egg

+	else if(nameid>10000)

+		id->type=8;   //petequip

+	return id;

+}

+/*==========================================

+ * DBの検索

+ *------------------------------------------

+ */

+struct item_data* itemdb_search(int nameid)

+{

+	return idb_ensure(item_db,nameid,create_item);

+}

+

+/*==========================================

+ *

+ *------------------------------------------

+ */

+int itemdb_isequip(int nameid)

+{

+	int type=itemdb_type(nameid);

+	if(type==0 || type==2 || type==3 || type==6 || type==10)

+		return 0;

+	return 1;

+}

+/*==========================================

+ *

+ *------------------------------------------

+ */

+int itemdb_isequip2(struct item_data *data)

+{

+	if(data) {

+		int type=data->type;

+		if(type==0 || type==2 || type==3 || type==6 || type==10)

+			return 0;

+		else

+			return 1;

+	}

+	return 0;

+}

+

+

+

+/*==========================================

+ * アイテムデータベースの読み込み

+ *------------------------------------------

+ */

+static int itemdb_readdb(void)

+{

+	FILE *fp;

+	char line[1024];

+	int ln=0;

+	int nameid,j;

+	char *str[128],*p,*np;

+	struct item_data *id;

+

+	sprintf(line, "%s/item_db.txt", db_path);

+	fp=fopen(line,"r");

+	if(fp==NULL){

+		ShowError("can't read %s\n", str);

+		exit(1);

+	}

+	while(fgets(line,1020,fp)){

+		if(line[0]=='/' && line[1]=='/')

+			continue;

+		memset(str,0,sizeof(str));

+		for(j=0,np=p=line;j<17 && p;j++){

+			str[j]=p;

+			p=strchr(p,',');

+			if(p){ *p++=0; np=p; }

+		}

+		if(str[0]==NULL)

+			continue;

+

+		nameid=atoi(str[0]);

+		if(nameid<=0 || nameid>=20000)

+			continue;

+		ln++;

+

+		//ID,Name,Jname,Type,Price,Sell,Weight,ATK,DEF,Range,Slot,Job,Gender,Loc,wLV,eLV,View

+		id=itemdb_search(nameid);

+		memcpy(id->name,str[1],ITEM_NAME_LENGTH-1);

+		memcpy(id->jname,str[2],ITEM_NAME_LENGTH-1);

+		id->type=atoi(str[3]);

+

+	}

+	fclose(fp);

+	ShowStatus("done reading item_db.txt (count=%d)\n",ln);

+	return 0;

+}

+

+static int itemdb_read_sqldb(void) // sql item_db read, shortened version of map-server item_db read [Valaris]

+{

+	unsigned int nameid; 	// Type should be "unsigned short int", but currently isn't for compatibility with numdb_insert()

+	struct item_data *id;

+

+	// ----------

+

+	// Output query to retrieve all rows from the item database table

+	sprintf(tmp_sql, "SELECT * FROM `%s`", item_db_db);

+

+	// Execute the query; if the query execution fails, output an error

+	if (mysql_query(&mysql_handle, tmp_sql)) {

+		ShowSQL("DB error - %s\n",mysql_error(&mysql_handle));

+		ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql);

+	}

+

+	// Store the query result

+	sql_res = mysql_store_result(&mysql_handle);

+

+	// If the storage of the query result succeeded

+	if (sql_res) {

+		// Parse each row in the query result into sql_row

+		while ((sql_row = mysql_fetch_row(sql_res))) {

+			nameid = atoi(sql_row[0]);

+

+			// If the identifier is not within the valid range, process the next row

+			if (nameid == 0 || nameid >= 20000)	{	// Should ">= 20000" be "> 20000"?

+				continue;

+			}

+

+			// ----------

+

+			// Update/Insert row into the item database

+         id=itemdb_search(nameid);

+

+			memcpy(id->name, sql_row[1], ITEM_NAME_LENGTH-1);

+			memcpy(id->jname, sql_row[2], ITEM_NAME_LENGTH-1);

+

+			id->type = atoi(sql_row[3]);

+		}

+

+		// If the retrieval failed, output an error

+		if (mysql_errno(&mysql_handle)) {

+			ShowSQL("DB error - %s\n",mysql_error(&mysql_handle));

+			ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql);

+		}

+

+		ShowInfo("read %s done (count = %lu)\n", item_db_db, (unsigned long) mysql_num_rows(sql_res));

+

+		// Free the query result

+		mysql_free_result(sql_res);

+	} else {

+		ShowSQL("DB error - %s\n",mysql_error(&mysql_handle));

+		ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql);

+	}

+

+	return 0;

+}

+

+static int itemdb_final(DBKey key,void *data,va_list ap)

+{

+	struct item_data *id = (struct item_data*)data;

+	if(id->use_script)

+		aFree(id->use_script);

+	if(id->equip_script)

+		aFree(id->equip_script);

+	return 0;

+}

+

+

+/*==========================================

+ *

+ *------------------------------------------

+ */

+void do_final_itemdb(void)

+{

+	if(item_db){

+		item_db->destroy(item_db,itemdb_final);

+		item_db=NULL;

+	}

+}

+int do_init_itemdb(void)

+{

+	item_db = db_alloc(__FILE__,__LINE__,DB_INT,DB_OPT_RELEASE_DATA,sizeof(int));

+

+	if (db_use_sqldbs) // it db_use_sqldbs in inter config are yes, will read from item_db for char server display [Valaris]

+		itemdb_read_sqldb();

+	else

+		itemdb_readdb();

+	return 0;

+}