SuperScriptMaterializer/SuperScriptMaterializer/database.cpp

#include "database.h"

#pragma region helper

void dbScriptDataStructHelper::init(CKParameterManager* paramManager) {
	_dbCKBehavior = new dbCKBehavior();
	_dbCKScript = new dbCKScript();
	_db_pTarget = new db_pTarget();
	_db_pIn = new db_pIn();
	_db_pOut = new db_pOut();
	_db_bIn = new db_bIn();
	_db_bOut = new db_bOut();
	_db_bLink = new db_bLink();
	_db_pLocal = new db_pLocal();
	_db_pLink = new db_pLink();
	_db_pLocalData = new db_pLocalData();
	_db_pOper = new db_pOper();
	_db_eLink = new db_eLink();

	_parameterManager = paramManager;
	_stringCache = (char*)malloc(STRINGCACHE_SIZE * sizeof(char));
	if (_stringCache == NULL)
		throw new std::bad_alloc();
}

void dbScriptDataStructHelper::dispose() {
	delete _dbCKBehavior;
	delete _dbCKScript;
	delete _db_pTarget;
	delete _db_pIn;
	delete _db_pOut;
	delete _db_bIn;
	delete _db_bOut;
	delete _db_bLink;
	delete _db_pLocalData;
	delete _db_pLink;
	delete _db_pLocal;
	delete _db_pOper;
	delete _db_eLink;

	_parameterManager = NULL;
	free(_stringCache);
}

void dbEnvDataStructHelper::init() {
	_db_envOp = new db_envOp;
	_db_envParam = new db_envParam;
	_db_envMsg = new db_envMsg;
	_db_envAttr = new db_envAttr;
	_db_envPlugin = new db_envPlugin;

	_stringCache = (char*)malloc(STRINGCACHE_SIZE * sizeof(char));
	if (_stringCache == NULL)
		throw new std::bad_alloc();
}

void dbEnvDataStructHelper::dispose() {
	delete _db_envOp;
	delete _db_envParam;
	delete _db_envMsg;
	delete _db_envAttr;
	delete _db_envPlugin;

	free(_stringCache);
}

#pragma endregion


#pragma region general func

void database::open(const char* file) {
	db = NULL;
	stmtCache = new std::vector<sqlite3_stmt*>(13, NULL);

	//open db
	int result;
	result = sqlite3_open(file, &db);
	if (result != SQLITE_OK) goto fail;

	if (!init()) goto fail;

	return;
fail:
	db = NULL;
}

void database::close() {
	if (db == NULL) return;

	finalJob();

	//release res
	sqlite3_close(db);
	db = NULL;
	delete stmtCache;
}

BOOL scriptDatabase::init() {
	int result;
	result = sqlite3_exec(db, "PRAGMA synchronous = OFF;", NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;

	//init table
	result = sqlite3_exec(db, "begin;", NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;

	result = sqlite3_exec(db,
		"CREATE TABLE script([thisobj] INTEGER, [name] TEXT, [index] INTEGER, [behavior] INTEGER);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;
	result = sqlite3_exec(db,
		"CREATE TABLE behavior([thisobj] INTEGER, [name] TEXT, [type] INTEGER, [proto_name] TEXT, [proto_guid] TEXT, [flags] INTEGER, [priority] INTEGER, [version] INTEGER, [pin_count] TEXT, [parent] INTEGER);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;
	result = sqlite3_exec(db,
		"CREATE TABLE pTarget([thisobj] INTEGER, [name] TEXT, [type] TEXT, [type_guid] TEXT, [belong_to] INTEGER, [direct_source] INTEGER, [shard_source] INTEGER);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;
	result = sqlite3_exec(db,
		"CREATE TABLE pIn([thisobj] INTEGER, [index] INTEGER, [name] TEXT, [type] TEXT, [type_guid] TEXT, [belong_to] INTEGER, [direct_source] INTEGER, [shard_source] INTEGER);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;
	result = sqlite3_exec(db,
		"CREATE TABLE pOut([thisobj] INTEGER, [index] INTEGER, [name] TEXT, [type] TEXT, [type_guid] TEXT, [belong_to] INTEGER);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;
	result = sqlite3_exec(db,
		"CREATE TABLE bIn([thisobj] INTEGER, [index] INTEGER, [name] TEXT, [belong_to] INTEGER);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;
	result = sqlite3_exec(db,
		"CREATE TABLE bOut([thisobj] INTEGER, [index] INTEGER, [name] TEXT, [belong_to] INTEGER);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;
	result = sqlite3_exec(db,
		"CREATE TABLE bLink([input] INTEGER, [output] INTEGER, [delay] INTEGER, [input_obj] INTEGER, [input_type] INTEGER, [input_index] INETEGR, [output_obj] INTEGER, [output_type] INTEGER, [output_index] INETEGR, [belong_to] INTEGER);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;
	result = sqlite3_exec(db,
		"CREATE TABLE pLocal([thisobj] INTEGER, [name] TEXT, [type] TEXT, [type_guid] TEXT, [is_setting] INTEGER, [belong_to] INTEGER);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;
	result = sqlite3_exec(db,
		"CREATE TABLE pLocalData([field] TEXT, [data] TEXT, [belong_to] INTEGER);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;
	result = sqlite3_exec(db,
		"CREATE TABLE pLink([input] INTEGER, [output] INTEGER, [input_obj] INTEGER, [input_type] INTEGER, [input_is_bb] INTEGER, [input_index] INETEGR, [output_obj] INTEGER, [output_type] INTEGER, [output_is_bb] INTEGER, [output_index] INETEGR, [belong_to] INTEGER);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;
	result = sqlite3_exec(db,
		"CREATE TABLE pOper([thisobj] INTEGER, [op] TEXT, [op_guid] TEXT, [belong_to] INTEGER);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;
	result = sqlite3_exec(db,
		"CREATE TABLE eLink([export_obj] INTEGER, [internal_obj] INTEGER, [is_in] INTEGER, [index] INTEGER, [belong_to] INTEGER);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;

	result = sqlite3_exec(db, "commit;", NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;

	//start job
	sqlite3_exec(db, "begin;", NULL, NULL, NULL);

	return TRUE;
}

BOOL scriptDatabase::finalJob() {
	//stop job
	for (auto it = stmtCache->begin(); it != stmtCache->end(); it++) {
		if (*it != NULL)
			sqlite3_finalize(*it);
	}
	sqlite3_exec(db, "commit;", NULL, NULL, NULL);

	//create index for quick select in following app
	sqlite3_exec(db, "begin;", NULL, NULL, NULL);
	sqlite3_exec(db, "CREATE INDEX [quick_where1] ON behavior ([parent])", NULL, NULL, NULL);
	sqlite3_exec(db, "CREATE INDEX [quick_where2] ON pOper ([belong_to], [thisobj])", NULL, NULL, NULL);
	sqlite3_exec(db, "CREATE INDEX [quick_where3] ON pTarget ([belong_to])", NULL, NULL, NULL);
	sqlite3_exec(db, "CREATE INDEX [quick_where4] ON bIn ([belong_to])", NULL, NULL, NULL);
	sqlite3_exec(db, "CREATE INDEX [quick_where5] ON bOut ([belong_to])", NULL, NULL, NULL);
	sqlite3_exec(db, "CREATE INDEX [quick_where6] ON pIn ([belong_to], [thisobj])", NULL, NULL, NULL);
	sqlite3_exec(db, "CREATE INDEX [quick_where7] ON pOut ([belong_to], [thisobj])", NULL, NULL, NULL);
	sqlite3_exec(db, "CREATE INDEX [quick_where8] ON pLocal ([belong_to])", NULL, NULL, NULL);
	sqlite3_exec(db, "CREATE INDEX [quick_where9] ON pLink ([belong_to])", NULL, NULL, NULL);
	sqlite3_exec(db, "CREATE INDEX [quick_where10] ON bLink ([belong_to])", NULL, NULL, NULL);
	sqlite3_exec(db, "CREATE INDEX [quick_where11] ON elink ([belong_to])", NULL, NULL, NULL);
	sqlite3_exec(db, "commit;", NULL, NULL, NULL);

	return TRUE;
}

BOOL envDatabase::init() {
	stmtCache = new std::vector<sqlite3_stmt*>(5, NULL);


	int result;
	result = sqlite3_exec(db, "PRAGMA synchronous = OFF;", NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;

	//init table
	result = sqlite3_exec(db, "begin;", NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;

	result = sqlite3_exec(db,
		"CREATE TABLE op([funcptr] INTEGER, [in1_guid] TEXT, [in2_guid] TEXT, [out_guid] TEXT, [op_guid] INTEGER, [op_name] TEXT, [op_code] INTEGER);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;
	result = sqlite3_exec(db,
		"CREATE TABLE param([index] INTEGER, [guid] TEXT, [derived_from] TEXT, [type_name] TEXT, [default_size] INTEGER, [func_CreateDefault] INTEGER, [func_Delete] INTEGER, [func_SaveLoad] INTEGER, [func_Check] INTEGER, [func_Copy] INTEGER, [func_String] INTEGER, [func_UICreator] INTEGER, [creator_dll_index] INTEGER, [creator_plugin_index] INTEGER, [dw_param] INTEGER, [dw_flags] INTEGER, [cid] INTEGER, [saver_manager] TEXT);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;
	result = sqlite3_exec(db,
		"CREATE TABLE msg([index] INTEGER, [name] TEXT);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;
	result = sqlite3_exec(db,
		"CREATE TABLE attr([index] INTEGER, [name] TEXT, [category_index] INTEGER, [category_name] TEXT, [flags] INTEGER, [param_index] INTEGER, [compatible_classid] INTEGER, [default_value] TEXT);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;
	result = sqlite3_exec(db,
		"CREATE TABLE plugin([dll_index] INTEGER, [dll_name] TEXT, [plugin_index] INTEGER, [category] TEXT, [active] INTEGER, [needed_by_file] INTEGER, [guid] TEXT, [desc] TEXT, [author] TEXT, [summary] TEXT, [version] INTEGER, [func_init] INTEGER, [func_exit] INTEGER);",
		NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;

	result = sqlite3_exec(db, "commit;", NULL, NULL, NULL);
	if (result != SQLITE_OK) return FALSE;

	//start job
	sqlite3_exec(db, "begin;", NULL, NULL, NULL);

	return TRUE;
}

BOOL envDatabase::finalJob() {
	//stop job
	for (auto it = stmtCache->begin(); it != stmtCache->end(); it++) {
		if (*it != NULL)
			sqlite3_finalize(*it);
	}
	sqlite3_exec(db, "commit;", NULL, NULL, NULL);

	return TRUE;
}

#pragma endregion

#pragma region write func

#define tryGetStmt(index,defaultStr) stmt=(*stmtCache)[index];if(stmt==NULL){sqlite3_prepare_v2(db,defaultStr,-1,&stmt,NULL);(*stmtCache)[index]=stmt;}

void scriptDatabase::write_CKBehavior(dbCKBehavior* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(0, "INSERT INTO behavior VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, data->thisobj);
	sqlite3_bind_text(stmt, 2, data->name.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 3, data->type);
	sqlite3_bind_text(stmt, 4, data->proto_name.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 5, data->proto_guid.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 6, data->flags);
	sqlite3_bind_int(stmt, 7, data->priority);
	sqlite3_bind_int(stmt, 8, data->version);
	sqlite3_bind_text(stmt, 9, data->pin_count.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 10, data->parent);
	sqlite3_step(stmt);
}

void scriptDatabase::write_CKScript(dbCKScript* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(1, "INSERT INTO script VALUES (?, ?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, data->thisobj);
	sqlite3_bind_text(stmt, 2, data->host_name.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 3, data->index);
	sqlite3_bind_int(stmt, 4, data->behavior);
	sqlite3_step(stmt);
}

void scriptDatabase::write_pTarget(db_pTarget* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(2, "INSERT INTO pTarget VALUES (?, ?, ?, ?, ?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, data->thisobj);
	sqlite3_bind_text(stmt, 2, data->name.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 3, data->type.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 4, data->type_guid.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 5, data->belong_to);
	sqlite3_bind_int(stmt, 6, data->direct_source);
	sqlite3_bind_int(stmt, 7, data->shared_source);
	sqlite3_step(stmt);
}

void scriptDatabase::write_pIn(db_pIn* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(3, "INSERT INTO pIn VALUES (?, ?, ?, ?, ?, ?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, data->thisobj);
	sqlite3_bind_int(stmt, 2, data->index);
	sqlite3_bind_text(stmt, 3, data->name.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 4, data->type.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 5, data->type_guid.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 6, data->belong_to);
	sqlite3_bind_int(stmt, 7, data->direct_source);
	sqlite3_bind_int(stmt, 8, data->shared_source);
	sqlite3_step(stmt);
}

void scriptDatabase::write_pOut(db_pOut* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(4, "INSERT INTO pOut VALUES (?, ?, ?, ?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, data->thisobj);
	sqlite3_bind_int(stmt, 2, data->index);
	sqlite3_bind_text(stmt, 3, data->name.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 4, data->type.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 5, data->type_guid.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 6, data->belong_to);
	sqlite3_step(stmt);
}

void scriptDatabase::write_bIn(db_bIn* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(5, "INSERT INTO bIn VALUES (?, ?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, data->thisobj);
	sqlite3_bind_int(stmt, 2, data->index);
	sqlite3_bind_text(stmt, 3, data->name.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 4, data->belong_to);
	sqlite3_step(stmt);
}

void scriptDatabase::write_bOut(db_bOut* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(6, "INSERT INTO bOut VALUES (?, ?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, data->thisobj);
	sqlite3_bind_int(stmt, 2, data->index);
	sqlite3_bind_text(stmt, 3, data->name.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 4, data->belong_to);
	sqlite3_step(stmt);
}

void scriptDatabase::write_bLink(db_bLink* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(7, "INSERT INTO bLink VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, data->input);
	sqlite3_bind_int(stmt, 2, data->output);
	sqlite3_bind_int(stmt, 3, data->delay);
	sqlite3_bind_int(stmt, 4, data->input_obj);
	sqlite3_bind_int(stmt, 5, data->input_type);
	sqlite3_bind_int(stmt, 6, data->input_index);
	sqlite3_bind_int(stmt, 7, data->output_obj);
	sqlite3_bind_int(stmt, 8, data->output_type);
	sqlite3_bind_int(stmt, 9, data->output_index);
	sqlite3_bind_int(stmt, 10, data->belong_to);
	sqlite3_step(stmt);
}

void scriptDatabase::write_pLocal(db_pLocal* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(8, "INSERT INTO pLocal VALUES (?, ?, ?, ?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, data->thisobj);
	sqlite3_bind_text(stmt, 2, data->name.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 3, data->type.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 4, data->type_guid.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 5, data->is_setting);
	sqlite3_bind_int(stmt, 6, data->belong_to);
	sqlite3_step(stmt);
}

void scriptDatabase::write_pLink(db_pLink* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(9, "INSERT INTO pLink VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, data->input);
	sqlite3_bind_int(stmt, 2, data->output);
	sqlite3_bind_int(stmt, 3, data->input_obj);
	sqlite3_bind_int(stmt, 4, data->input_type);
	sqlite3_bind_int(stmt, 5, data->input_is_bb);
	sqlite3_bind_int(stmt, 6, data->input_index);
	sqlite3_bind_int(stmt, 7, data->output_obj);
	sqlite3_bind_int(stmt, 8, data->output_type);
	sqlite3_bind_int(stmt, 9, data->output_is_bb);
	sqlite3_bind_int(stmt, 10, data->output_index);
	sqlite3_bind_int(stmt, 11, data->belong_to);
	sqlite3_step(stmt);
}

void scriptDatabase::write_pLocalData(db_pLocalData* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(10, "INSERT INTO pLocalData VALUES (?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_text(stmt, 1, data->field.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 2, data->data.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 3, data->belong_to);
	sqlite3_step(stmt);
}

void scriptDatabase::write_pOper(db_pOper* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(11, "INSERT INTO pOper VALUES (?, ?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, data->thisobj);
	sqlite3_bind_text(stmt, 2, data->op.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 3, data->op_guid.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 4, data->belong_to);
	sqlite3_step(stmt);
}

void scriptDatabase::write_eLink(db_eLink* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(12, "INSERT INTO eLink VALUES (?, ?, ?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, data->export_obj);
	sqlite3_bind_int(stmt, 2, data->internal_obj);
	sqlite3_bind_int(stmt, 3, data->is_in);
	sqlite3_bind_int(stmt, 4, data->index);
	sqlite3_bind_int(stmt, 5, data->belong_to);
	sqlite3_step(stmt);
}

void envDatabase::write_envOp(db_envOp* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(0, "INSERT INTO op VALUES (?, ?, ?, ?, ?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, (int)data->funcPtr);
	sqlite3_bind_text(stmt, 2, data->in1_guid.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 3, data->in2_guid.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 4, data->out_guid.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 5, data->op_guid.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 6, data->op_name.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 7, data->op_code);
	sqlite3_step(stmt);
}

void envDatabase::write_envParam(db_envParam* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(1, "INSERT INTO param VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, data->index);
	sqlite3_bind_text(stmt, 2, data->guid.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 3, data->derived_from.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 4, data->type_name.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 5, data->default_size);
	sqlite3_bind_int(stmt, 6, (int)data->func_CreateDefault);
	sqlite3_bind_int(stmt, 7, (int)data->func_Delete);
	sqlite3_bind_int(stmt, 8, (int)data->func_SaveLoad);
	sqlite3_bind_int(stmt, 9, (int)data->func_Check);
	sqlite3_bind_int(stmt, 10, (int)data->func_Copy);
	sqlite3_bind_int(stmt, 11, (int)data->func_String);
	sqlite3_bind_int(stmt, 12, (int)data->func_UICreator);
	sqlite3_bind_int(stmt, 13, data->creator_dll_index);
	sqlite3_bind_int(stmt, 14, data->creator_plugin_index);
	sqlite3_bind_int(stmt, 15, data->dw_param);
	sqlite3_bind_int(stmt, 16, data->dw_flags);
	sqlite3_bind_int(stmt, 17, data->cid);
	sqlite3_bind_text(stmt, 18, data->saver_manager.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_step(stmt);
}

void envDatabase::write_envMsg(db_envMsg* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(2, "INSERT INTO msg VALUES (?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, data->index);
	sqlite3_bind_text(stmt, 2, data->name.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_step(stmt);
}

void envDatabase::write_envAttr(db_envAttr* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(3, "INSERT INTO attr VALUES (?, ?, ?, ?, ?, ?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, data->index);
	sqlite3_bind_text(stmt, 2, data->name.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 3, data->category_index);
	sqlite3_bind_text(stmt, 4, data->category_name.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 5, data->flags);
	sqlite3_bind_int(stmt, 6, data->param_index);
	sqlite3_bind_int(stmt, 7, data->compatible_classid);
	sqlite3_bind_text(stmt, 8, data->default_value.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_step(stmt);
}

void envDatabase::write_envPlugin(db_envPlugin* data) {
	if (db == NULL) return;

	sqlite3_stmt* stmt = NULL;
	tryGetStmt(4, "INSERT INTO plugin VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");
	sqlite3_reset(stmt);

	sqlite3_bind_int(stmt, 1, data->dll_index);
	sqlite3_bind_text(stmt, 2, data->dll_name.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 3, data->plugin_index);
	sqlite3_bind_text(stmt, 4, data->category.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 5, data->active);
	sqlite3_bind_int(stmt, 6, data->needed_by_file);
	sqlite3_bind_text(stmt, 7, data->guid.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 8, data->desc.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 9, data->author.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_text(stmt, 10, data->summary.c_str(), -1, SQLITE_TRANSIENT);
	sqlite3_bind_int(stmt, 11, data->version);
	sqlite3_bind_int(stmt, 12, (int)data->func_init);
	sqlite3_bind_int(stmt, 13, (int)data->func_exit);
	sqlite3_step(stmt);
}

#undef tryGetStmt

#pragma endregion