summaryrefslogtreecommitdiff
path: root/modules/extra/mysql/db_mysql_read.cpp
diff options
context:
space:
mode:
authorAdam <Adam@anope.org>2010-07-15 22:55:02 -0400
committerAdam <Adam@anope.org>2010-07-15 22:55:02 -0400
commita22f8d3b2de88b9bb6f80f0c2780846ae23ab389 (patch)
treea2fdf570868896a787df8a1169951b0028e68d6b /modules/extra/mysql/db_mysql_read.cpp
parent43b1e43afb85639485e36d24da351dc0f121be6e (diff)
Moved some files and diretories around, made cmake skip files it knows it can't compile because of missing dependices.
Diffstat (limited to 'modules/extra/mysql/db_mysql_read.cpp')
-rw-r--r--modules/extra/mysql/db_mysql_read.cpp618
1 files changed, 618 insertions, 0 deletions
diff --git a/modules/extra/mysql/db_mysql_read.cpp b/modules/extra/mysql/db_mysql_read.cpp
new file mode 100644
index 000000000..3ffc82366
--- /dev/null
+++ b/modules/extra/mysql/db_mysql_read.cpp
@@ -0,0 +1,618 @@
+/* RequiredLibraries: mysqlpp */
+
+#include "db_mysql.h"
+
+static std::vector<std::string> MakeVector(std::string buf)
+{
+ std::string s;
+ spacesepstream sep(buf);
+ std::vector<std::string> params;
+
+ while (sep.GetToken(s))
+ {
+ if (s[0] == ':')
+ {
+ s.erase(s.begin());
+ if (!s.empty() && !sep.StreamEnd())
+ params.push_back(s + " " + sep.GetRemaining());
+ else if (!s.empty())
+ params.push_back(s);
+ }
+ else
+ params.push_back(s);
+ }
+
+ return params;
+}
+
+static void LoadDatabase()
+{
+ mysqlpp::Query query(me->Con);
+ mysqlpp::StoreQueryResult qres;
+
+ query << "SELECT * FROM `anope_ns_core`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ NickCore *nc = new NickCore(SQLAssign(qres[i]["display"]));
+ nc->pass = SQLAssign(qres[i]["pass"]);
+ if (qres[i]["email"].size())
+ nc->email = sstrdup(qres[i]["email"].c_str());
+ if (qres[i]["greet"].size())
+ nc->greet = sstrdup(qres[i]["greet"].c_str());
+ if (qres[i]["icq"].size())
+ nc->icq = atol(qres[i]["icq"].c_str());
+ if (qres[i]["url"].size())
+ nc->url = sstrdup(qres[i]["url"].c_str());
+
+ spacesepstream sep(SQLAssign(qres[i]["flags"]));
+ std::string buf;
+ while (sep.GetToken(buf))
+ for (int j = 0; NickCoreFlags[j].Flag != -1; ++j)
+ if (NickCoreFlags[j].Name == buf)
+ nc->SetFlag(NickCoreFlags[j].Flag);
+
+ nc->language = atoi(qres[i]["language"].c_str());
+ nc->channelcount = atoi(qres[i]["channelcount"].c_str());
+ nc->memos.memomax = atoi(qres[i]["memomax"].c_str());
+ }
+
+ query << "SELECT * FROM `anope_ns_access`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ NickCore *nc = findcore(qres[i]["display"].c_str());
+ if (!nc)
+ {
+ Alog() << "MySQL: Got NickCore access entry for nonexistant core " << qres[i]["display"];
+ continue;
+ }
+
+ nc->AddAccess(SQLAssign(qres[i]["access"]));
+ }
+
+ query << "SELECT * FROM `anope_ns_core_metadata`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ NickCore *nc = findcore(qres[i]["display"].c_str());
+ if (!nc)
+ {
+ Alog() << "MySQL: Got NickCore access entry for nonexistant core " << qres[i]["display"];
+ continue;
+ }
+ EventReturn MOD_RESULT;
+ std::vector<std::string> Params = MakeVector(SQLAssign(qres[i]["value"]));
+ FOREACH_RESULT(I_OnDatabaseReadMetadata, OnDatabaseReadMetadata(nc, SQLAssign(qres[i]["name"]), Params));
+ }
+
+ query << "SELECT * FROM `anope_ns_alias`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ NickCore *nc = findcore(qres[i]["display"].c_str());
+ if (!nc)
+ {
+ Alog() << "MySQL: Got NickAlias for nick " << qres[i]["nick"] << " with nonexistant core " << qres[i]["display"];
+ continue;
+ }
+
+ NickAlias *na = new NickAlias(SQLAssign(qres[i]["nick"]), nc);
+ na->last_quit = sstrdup(qres[i]["last_quit"].c_str());
+ na->last_realname = sstrdup(qres[i]["last_realname"].c_str());
+ na->last_usermask = sstrdup(qres[i]["last_usermask"].c_str());
+ na->time_registered = atol(qres[i]["time_registered"].c_str());
+ na->last_seen = atol(qres[i]["last_seen"].c_str());
+
+ spacesepstream sep(SQLAssign(qres[i]["flags"]));
+ std::string buf;
+ while (sep.GetToken(buf))
+ for (int j = 0; NickAliasFlags[j].Flag != -1; ++j)
+ if (NickAliasFlags[j].Name == buf)
+ na->SetFlag(NickAliasFlags[j].Flag);
+ }
+
+ query << "SELECT * FROM `anope_ns_alias_metadata`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ NickAlias *na = findnick(SQLAssign(qres[i]["nick"]));
+ if (!na)
+ {
+ Alog() << "MySQL: Got metadata for nonexistant nick " << qres[i]["nick"];
+ continue;
+ }
+ EventReturn MOD_RESULT;
+ std::vector<std::string> Params = MakeVector(SQLAssign(qres[i]["value"]));
+ FOREACH_RESULT(I_OnDatabaseReadMetadata, OnDatabaseReadMetadata(na, SQLAssign(qres[i]["name"]), Params));
+ }
+
+ query << "SELECT * FROM `anope_bs_core`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ BotInfo *bi = findbot(SQLAssign(qres[i]["nick"]));
+ if (!bi)
+ bi = new BotInfo(SQLAssign(qres[i]["nick"]));
+ bi->user = SQLAssign(qres[i]["user"]);
+ bi->host = SQLAssign(qres[i]["host"]);
+ bi->real = SQLAssign(qres[i]["rname"]);
+
+ if (qres[i]["flags"].size())
+ {
+ spacesepstream sep(SQLAssign(qres[i]["flags"]));
+ std::string buf;
+ while (sep.GetToken(buf))
+ for (unsigned j = 0; BotServFlags[j].Flag != -1; ++j)
+ if (buf == BotServFlags[j].Name)
+ {
+ bi->SetFlag(BotServFlags[j].Flag);
+ break;
+ }
+ }
+ bi->created = atol(qres[i]["created"]);
+ bi->chancount = atol(qres[i]["chancount"]);
+ }
+
+ query << "SELECT * FROM `anope_bs_info_metadata`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ BotInfo *bi = findbot(SQLAssign(qres[i]["botname"]));
+ if (!bi)
+ {
+ Alog() << "MySQL: BotInfo metadata for nonexistant bot " << qres[i]["botname"];
+ continue;
+ }
+
+ EventReturn MOD_RESULT;
+ std::vector<std::string> Params = MakeVector(SQLAssign(qres[i]["value"]));
+ FOREACH_RESULT(I_OnDatabaseReadMetadata, OnDatabaseReadMetadata(bi, SQLAssign(qres[i]["name"]), Params));
+ }
+
+ query << "SELECT * FROM `anope_cs_info`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ NickCore *nc;
+ if (qres[i]["founder"].size())
+ {
+ nc = findcore(qres[i]["founder"].c_str());
+ if (!nc)
+ {
+ Alog() << "MySQL: Channel " << qres[i]["name"] << " with nonexistant founder " << qres[i]["founder"];
+ continue;
+ }
+ }
+
+ ChannelInfo *ci = new ChannelInfo(SQLAssign(qres[i]["name"]));
+ ci->founder = nc;
+ if (qres[i]["successor"].size())
+ ci->successor = findcore(qres[i]["successor"].c_str());
+ ci->desc = sstrdup(qres[i]["descr"].c_str());
+ if (qres[i]["url"].size())
+ ci->url = sstrdup(qres[i]["url"].c_str());
+ if (qres[i]["email"].size())
+ ci->email = sstrdup(qres[i]["email"].c_str());
+ ci->time_registered = atol(qres[i]["time_registered"]);
+ ci->last_used = atol(qres[i]["last_used"]);
+ if (qres[i]["last_topic"].size())
+ ci->last_topic = sstrdup(qres[i]["last_topic"].c_str());
+ if (qres[i]["last_topic_setter"].size())
+ ci->last_topic_setter = SQLAssign(qres[i]["last_topic_setter"]);
+ if (qres[i]["last_topic_time"].size())
+ ci->last_topic_time = atol(qres[i]["last_topic_time"].c_str());
+ if (qres[i]["flags"].size())
+ {
+ std::string buf;
+ spacesepstream sep(SQLAssign(qres[i]["flags"]));
+ while (sep.GetToken(buf))
+ for (int j = 0; ChannelFlags[j].Flag != -1; ++j)
+ if (buf == ChannelFlags[j].Name)
+ {
+ ci->SetFlag(ChannelFlags[j].Flag);
+ break;
+ }
+ }
+ if (qres[i]["forbidby"].size())
+ ci->forbidby = sstrdup(qres[i]["forbidby"].c_str());
+ if (qres[i]["forbidreason"].size())
+ ci->forbidreason = sstrdup(qres[i]["forbidreason"].c_str());
+ ci->bantype = atoi(qres[i]["bantype"].c_str());
+ if (qres[i]["mlock_on"].size())
+ {
+ std::vector<std::string> modes;
+ std::string buf;
+
+ spacesepstream sep(SQLAssign(qres[i]["mlock_on"]));
+ while (sep.GetToken(buf))
+ modes.push_back(buf);
+
+ ci->Extend("db_mlock_modes_on", new ExtensibleItemRegular<std::vector<std::string> >(modes));
+ }
+ if (qres[i]["mlock_off"].size())
+ {
+ std::vector<std::string> modes;
+ std::string buf;
+
+ spacesepstream sep(SQLAssign(qres[i]["mlock_off"]));
+ while (sep.GetToken(buf))
+ modes.push_back(buf);
+
+ ci->Extend("db_mlock_modes_off", new ExtensibleItemRegular<std::vector<std::string> >(modes));
+ }
+ if (qres[i]["mlock_params"].size())
+ {
+ std::vector<std::pair<std::string, std::string> > mlp;
+ std::string buf, buf2;
+
+ spacesepstream sep(SQLAssign(qres[i]["mlock_params"]));
+
+ while (sep.GetToken(buf) && sep.GetToken(buf2))
+ mlp.push_back(std::make_pair(buf, buf2));
+
+ ci->Extend("db_mlp", new ExtensibleItemRegular<std::vector<std::pair<std::string, std::string> > >(mlp));
+ }
+ if (qres[i]["entry_message"].size())
+ ci->entry_message = sstrdup(qres[i]["entry_message"].c_str());
+ ci->memos.memomax = atoi(qres[i]["memomax"].c_str());
+ if (qres[i]["botnick"].size())
+ ci->bi = findbot(SQLAssign(qres[i]["botnick"]));
+ if (ci->bi)
+ {
+ if (qres[i]["botflags"].size())
+ {
+ std::string buf;
+ spacesepstream sep(SQLAssign(qres[i]["botflags"]));
+ while (sep.GetToken(buf))
+ for (int j = 0; BotFlags[j].Flag != -1; ++j)
+ if (buf == BotFlags[j].Name)
+ {
+ ci->botflags.SetFlag(BotFlags[j].Flag);
+ break;
+ }
+ }
+ }
+ if (qres[i]["capsmin"].size())
+ ci->capsmin = atoi(qres[i]["capsmin"].c_str());
+ if (qres[i]["capspercent"].size())
+ ci->capspercent = atoi(qres[i]["capspercent"].c_str());
+ if (qres[i]["floodlines"].size())
+ ci->floodlines = atoi(qres[i]["floodlines"].c_str());
+ if (qres[i]["floodsecs"].size())
+ ci->floodsecs = atoi(qres[i]["floodsecs"].c_str());
+ if (qres[i]["repeattimes"].size())
+ ci->repeattimes = atoi(qres[i]["repeattimes"].c_str());
+ }
+
+ query << "SELECT * FROM `anope_cs_ttb";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ ChannelInfo *ci = cs_findchan(SQLAssign(qres[i]["channel"]));
+ if (!ci)
+ {
+ Alog() << "MySQL: Channel ttb for nonexistant channel " << qres[i]["channel"];
+ continue;
+ }
+
+ ci->ttb[atoi(qres[i]["ttb_id"].c_str())] = atoi(qres[i]["value"].c_str());
+ }
+
+ query << "SELECT * FROM `anope_bs_badwords`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ ChannelInfo *ci = cs_findchan(SQLAssign(qres[i]["channel"]));
+ if (!ci)
+ {
+ Alog() << "MySQL: Channel badwords entry for nonexistant channel " << qres[i]["channel"];
+ continue;
+ }
+
+ BadWordType BWTYPE = BW_ANY;
+ if (qres[i]["type"] == "SINGLE")
+ BWTYPE = BW_SINGLE;
+ else if (qres[i]["type"] == "START")
+ BWTYPE = BW_START;
+ else if (qres[i]["type"] == "END")
+ BWTYPE = BW_END;
+ ci->AddBadWord(SQLAssign(qres[i]["word"]), BWTYPE);
+ }
+
+ query << "SELECT * FROM `anope_cs_access`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ ChannelInfo *ci = cs_findchan(SQLAssign(qres[i]["channel"]));
+ if (!ci)
+ {
+ Alog() << "MySQL: Channel access entry for nonexistant channel " << qres[i]["channel"];
+ continue;
+ }
+ NickCore *nc = findcore(qres[i]["display"]);
+ if (!nc)
+ {
+ Alog() << "MySQL: Channel access entry for " << ci->name << " with nonexistant nick " << qres[i]["display"];
+ continue;
+ }
+
+ ci->AddAccess(nc, atoi(qres[i]["level"]), SQLAssign(qres[i]["creator"]), atol(qres[i]["last_seen"]));
+ }
+
+ query << "SELECT * FROM `anope_cs_akick`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ ChannelInfo *ci = cs_findchan(SQLAssign(qres[i]["channel"]));
+ if (!ci)
+ {
+ Alog() << "MySQL: Channel akick entry for nonexistant channel " << qres[i]["channel"];
+ continue;
+ }
+ NickCore *nc = NULL;
+ spacesepstream sep(qres[i]["flags"]);
+ std::string flag, mask;
+ bool stuck = false;
+ while (sep.GetToken(flag))
+ if (flag == "ISNICK")
+ nc = findcore(qres[i]["mask"]);
+ else if (flag == "STUCK")
+ stuck = true;
+ AutoKick *ak;
+ if (nc)
+ ak = ci->AddAkick(SQLAssign(qres[i]["creator"]), nc, SQLAssign(qres[i]["reason"]), atol(qres[i]["created"].c_str()), atol(qres[i]["last_used"].c_str()));
+ else
+ ak = ci->AddAkick(SQLAssign(qres[i]["creator"]), SQLAssign(qres[i]["mask"]), SQLAssign(qres[i]["reason"]), atol(qres[i]["created"].c_str()), atol(qres[i]["last_used"].c_str()));
+ if (stuck)
+ ak->SetFlag(AK_STUCK);
+ if (nc)
+ ak->SetFlag(AK_ISNICK);
+ }
+
+ query << "SELECT * FROM `anope_cs_levels`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ ChannelInfo *ci = cs_findchan(SQLAssign(qres[i]["channel"]));
+ if (!ci)
+ {
+ Alog() << "MySQL: Channel level entry for nonexistant channel " << qres[i]["channel"];
+ continue;
+ }
+ ci->levels[atoi(qres[i]["position"])] = atoi(qres[i]["level"]);
+ }
+
+ query << "SELECT * FROM `anope_cs_info_metadata`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ ChannelInfo *ci = cs_findchan(SQLAssign(qres[i]["channel"]));
+ if (!ci)
+ {
+ Alog() << "MySQL: Channel metadata for nonexistant channel " << qres[i]["channel"];
+ continue;
+ }
+
+ EventReturn MOD_RESULT;
+ std::vector<std::string> Params = MakeVector(SQLAssign(qres[i]["value"]));
+ FOREACH_RESULT(I_OnDatabaseReadMetadata, OnDatabaseReadMetadata(ci, SQLAssign(qres[i]["name"]), Params));
+ }
+
+ query << "SELECT * FROM `anope_ns_request`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ NickRequest *nr = new NickRequest(qres[i]["nick"].c_str());
+ nr->passcode = SQLAssign(qres[i]["passcode"]);
+ nr->password = SQLAssign(qres[i]["password"]);
+ nr->email = sstrdup(qres[i]["email"].c_str());
+ nr->requested = atol(qres[i]["requested"].c_str());
+ }
+
+ EventReturn MOD_RESULT;
+ query << "SELECT * FROM `anope_extra`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ std::vector<std::string> params = MakeVector(SQLAssign(qres[i]["data"]));
+ FOREACH_RESULT(I_OnDatabaseRead, OnDatabaseRead(params));
+ }
+
+ query << "SELECT * FROM `anope_ns_core_metadata`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ NickCore *nc = findcore(qres[i]["nick"].c_str());
+ if (nc)
+ {
+ std::vector<std::string> params = MakeVector(SQLAssign(qres[i]["value"]));
+ FOREACH_RESULT(I_OnDatabaseReadMetadata, OnDatabaseReadMetadata(nc, SQLAssign(qres[i]["name"]), params));
+ }
+ }
+
+ query << "SELECT * FROM `anope_ns_alias_metadata`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ NickAlias *na = findnick(SQLAssign(qres[i]["nick"]));
+ if (na)
+ {
+ std::vector<std::string> params = MakeVector(SQLAssign(qres[i]["value"]));
+ FOREACH_RESULT(I_OnDatabaseReadMetadata, OnDatabaseReadMetadata(na, SQLAssign(qres[i]["name"]), params));
+ }
+ }
+
+ query << "SELECT * FROM `anope_cs_info_metadata`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ ChannelInfo *ci = cs_findchan(SQLAssign(qres[i]["channel"]));
+ if (ci)
+ {
+ std::vector<std::string> params = MakeVector(SQLAssign(qres[i]["value"]));
+ FOREACH_RESULT(I_OnDatabaseReadMetadata, OnDatabaseReadMetadata(ci, SQLAssign(qres[i]["name"]), params));
+ }
+ }
+
+ query << "SELECT * FROM `anope_ms_info`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ MemoInfo *mi = NULL;
+ if (qres[i]["serv"] == "NICK")
+ {
+ NickCore *nc = findcore(qres[i]["receiver"].c_str());
+ if (nc)
+ mi = &nc->memos;
+ }
+ else if (qres[i]["serv"] == "CHAN")
+ {
+ ChannelInfo *ci = cs_findchan(SQLAssign(qres[i]["receiver"]));
+ if (ci)
+ mi = &ci->memos;
+ }
+ if (mi)
+ {
+ Memo *m = new Memo();
+ mi->memos.push_back(m);
+ m->sender = SQLAssign(qres[i]["sender"]);
+ if (mi->memos.size() > 1)
+ {
+ m->number = mi->memos[mi->memos.size() - 2]->number + 1;
+ if (m->number < 1)
+ {
+ for (unsigned j = 0; j < mi->memos.size(); ++j)
+ mi->memos[j]->number = j + 1;
+ }
+ }
+ else
+ m->number = 1;
+ m->time = atol(qres[i]["time"].c_str());
+ m->text = sstrdup(qres[i]["text"].c_str());
+
+ if (qres[i]["flags"].size())
+ {
+ spacesepstream sep(SQLAssign(qres[i]["flags"]));
+ std::string buf;
+ while (sep.GetToken(buf))
+ for (unsigned j = 0; MemoFlags[j].Flag != -1; ++j)
+ if (MemoFlags[j].Name == buf)
+ m->SetFlag(MemoFlags[j].Flag);
+ }
+ }
+ }
+
+ query << "SELECT * FROM `anope_os_akills`";
+ qres = StoreQuery(query);
+
+ if (qres && SGLine)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ ci::string user = qres[i]["user"].c_str();
+ ci::string host = qres[i]["host"].c_str();
+ ci::string by = qres[i]["xby"].c_str();
+ std::string reason = SQLAssign(qres[i]["reason"]);
+ time_t seton = atol(qres[i]["seton"].c_str());
+ time_t expires = atol(qres[i]["expire"].c_str());
+
+ XLine *x = SGLine->Add(NULL, NULL, user + "@" + host, expires, reason);
+ if (x)
+ {
+ x->By = by;
+ x->Created = seton;
+ }
+ }
+
+ query << "SELECT * FROM `anope_os_xlines`";
+ qres = StoreQuery(query);
+
+ if (qres)
+ for (size_t i = 0, end = qres.num_rows(); i < end; ++i)
+ {
+ ci::string mask = qres[i]["mask"].c_str();
+ ci::string by = qres[i]["xby"].c_str();
+ std::string reason = SQLAssign(qres[i]["reason"]);
+ time_t seton = atol(qres[i]["seton"].c_str());
+ time_t expires = atol(qres[i]["expires"].c_str());
+
+ XLine *x = NULL;
+ if (qres[i]["type"] == "SNLINE" && SNLine)
+ x = SNLine->Add(NULL, NULL, mask, expires, reason);
+ else if (qres[i]["type"] == "SQLINE" && SQLine)
+ x = SQLine->Add(NULL, NULL, mask, expires, reason);
+ else if (qres[i]["type"] == "SZLINE" && SZLine)
+ x = SZLine->Add(NULL, NULL,mask, expires, reason);
+ if (x)
+ {
+ x->By = by;
+ x->Created = seton;
+ }
+ }
+}
+
+class DBMySQLRead : public DBMySQL
+{
+ public:
+ DBMySQLRead(const std::string &modname, const std::string &creator) : DBMySQL(modname, creator)
+ {
+ Implementation i[] = { I_OnLoadDatabase };
+ ModuleManager::Attach(i, this, 1);
+ }
+
+ ~DBMySQLRead()
+ {
+ }
+
+ EventReturn OnLoadDatabase()
+ {
+ LoadDatabase();
+
+ /* No need to ever reload this again, although this should never be triggered again */
+ ModuleManager::Detach(I_OnLoadDatabase, this);
+
+ return EVENT_STOP;
+ }
+};
+
+MODULE_INIT(DBMySQLRead)