pegasus/anope
1
0
Fork 0
mirror of https://github.com/anope/anope.git synced 2026-06-25 05:16:38 +02:00
Code Activity

Have db_flatfile store object ids if they are set, even though it doesn't use them, so that if other database modules that use them are loaded they can keep track of objects properly

Browse Source
This commit is contained in:
Adam
2013-03-16 20:08:39 -05:00
parent 1a0e6b0be3
commit 810685cb73
2 changed files with 30 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
modules/database/db_sql.cpp
+11 -5
View File
@@ -63,6 +63,7 @@ class DBSQL : public Module, public Pipe
bool shutting_down;
bool loading_databases;
bool loaded;
bool imported;
void RunBackground(const Query &q, Interface *iface = NULL)
{
@@ -86,7 +87,7 @@ class DBSQL : public Module, public Pipe
}
public:
DBSQL(const Anope::string &modname, const Anope::string &creator) : Module(modname, creator, DATABASE), sql("", ""), sqlinterface(this), shutting_down(false), loading_databases(false), loaded(false)
DBSQL(const Anope::string &modname, const Anope::string &creator) : Module(modname, creator, DATABASE), sql("", ""), sqlinterface(this), shutting_down(false), loading_databases(false), loaded(false), imported(false)
{
this->SetAuthor("Anope");
@@ -121,17 +122,22 @@ class DBSQL : public Module, public Pipe
this->RunBackground(create[i]);
Query insert = this->sql->BuildInsert(this->prefix + s_type->GetName(), obj->id, data);
if (this->loaded)
if (this->imported)
this->RunBackground(insert, new ResultSQLSQLInterface(this, obj));
else
/* If we aren't loading these objects then we are importing them, so don't do asynchronous
* queries in case for some reason the core has to shut down, it will cut short the import
{
/* On the first loop we may be importing objects from another database module, so don't do asynchronous
* queries in case the core has to shut down, it will cut short the import
*/
this->sql->RunQuery(insert);
Result r = this->sql->RunQuery(insert);
if (r.GetID() > 0)
obj->id = r.GetID();
}
}
}
this->updated_items.clear();
this->imported = true;
}
void OnReload() anope_override