123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095 |
- #include "Datenbank.h"
- #include <Text.h>
- #include <Datei.h>
- #include <Zeit.h>
- #include <iostream>
- // Inhalt der SSDatenbank Klasse aus Datenbank.h
- // Konstruktor
- SSDatenbank::SSDatenbank(InitDatei* zIni)
- : ReferenceCounter()
- {
- datenbank = new Datenbank(zIni->zWert("DBBenutzer")->getText(), zIni->zWert("DBPasswort")->getText(),
- zIni->zWert("DBName")->getText(), zIni->zWert("DBIP")->getText(),
- (unsigned short)TextZuInt(zIni->zWert("DBPort")->getText(), 10));
- if (!datenbank->istOk())
- {
- std::cout << "SS: Die Verbindung zur Datenbank konnte nicht hergestellt werden.\nDas Programm wird beendet.";
- exit(1);
- }
- InitializeCriticalSection(&cs);
- ini = dynamic_cast<InitDatei*>(zIni->getThis());
- Text befehl = "SELECT port, admin_port, ip FROM server WHERE id = ";
- befehl += zIni->zWert("ServerId")->getText();
- lock();
- datenbank->befehl(befehl);
- Result res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl == 1)
- {
- zIni->addWert("ServerPort", res.values[0]);
- zIni->addWert("AdminServerPort", res.values[1]);
- zIni->addWert("ServerIp", res.values[2]);
- }
- res.destroy();
- }
- // Destruktor
- SSDatenbank::~SSDatenbank()
- {
- datenbank->release();
- DeleteCriticalSection(&cs);
- ini->release();
- }
- // nicht constant
- void SSDatenbank::lock()
- {
- EnterCriticalSection(&cs);
- }
- void SSDatenbank::unlock()
- {
- LeaveCriticalSection(&cs);
- }
- Text* SSDatenbank::getKlientKey(int cId)
- {
- lock();
- if (!datenbank->befehl(Text("SELECT schluessel FROM client WHERE id = ") += cId))
- {
- unlock();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- Text* ret = new Text(res.values[0].getText());
- res.destroy();
- return ret;
- }
- int SSDatenbank::istAdministrator(const char* name, const char* passwort)
- {
- Text* befehl = new Text("SELECT id FROM benutzer WHERE name = '");
- Text n(name);
- n.ersetzen("'", "''");
- befehl->append(n);
- befehl->append("' AND passwort = md5( '");
- Text p(passwort);
- p.ersetzen("'", "''");
- befehl->append(p);
- befehl->append("' )");
- lock();
- datenbank->befehl(befehl->getText());
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- int ret = 0;
- if (res.zeilenAnzahl > 0)
- ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- bool SSDatenbank::adminHatRecht(int id, int recht)
- {
- Text* befehl = new Text("SELECT * FROM benutzer_rechte WHERE benutzer_id = ");
- befehl->append(id);
- befehl->append(" AND rechte_id = ");
- befehl->append(recht);
- lock();
- datenbank->befehl(befehl->getText());
- int ret = datenbank->getZeilenAnzahl();
- unlock();
- befehl->release();
- return ret != 0;
- }
- bool SSDatenbank::setServerStatus(int id, int status)
- {
- Text* befehl = new Text("UPDATE server SET server_status_id = ");
- *befehl += status;
- *befehl += "WHERE id = ";
- *befehl += id;
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- bool ret = datenbank->getZeilenAnzahl() != 0;
- unlock();
- befehl->release();
- return ret;
- }
- bool SSDatenbank::setMaxSpiele(int id, int maxS)
- {
- Text* befehl = new Text("UPDATE server SET max_tasks = ");
- befehl->append(maxS);
- befehl->append(" WHERE id = ");
- befehl->append(id);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- bool ret = datenbank->getZeilenAnzahl() > 0;
- unlock();
- befehl->release();
- return ret;
- }
- bool SSDatenbank::serverIstNichtPausiert(int id)
- {
- Text* befehl = new Text("SELECT server_status_id FROM server WHERE id = ");
- befehl->append(id);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- bool ret = (int)res.values[0] == 3;
- res.destroy();
- return ret;
- }
- int SSDatenbank::getAccountId(int clientId)
- {
- if (!clientId)
- return 0;
- Text* befehl = new Text("SELECT account_id FROM account_client WHERE client_id = ");
- befehl->append(clientId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- Text* SSDatenbank::getSpielArtName(int spielId)
- {
- if (!spielId)
- return new Text("");
- Text* befehl = new Text("SELECT name FROM spiel_art WHERE id = ");
- befehl->append(spielId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return new Text("");
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return new Text("");
- }
- Text* ret = new Text(res.values[0].getText());
- res.destroy();
- return ret;
- }
- Text* SSDatenbank::getKarteName(int karteId)
- {
- if (!karteId)
- return new Text("Inoffiziell");
- Text* befehl = new Text("SELECT name FROM karte WHERE id = ");
- befehl->append(karteId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return new Text("Inoffiziell");
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return new Text("Inoffiziell");
- }
- Text* ret = new Text(res.values[0].getText());
- res.destroy();
- return ret;
- }
- int SSDatenbank::getSpielArtId(int karteId)
- {
- if (!karteId)
- return 0;
- Text* befehl = new Text("SELECT spiel_art_id FROM karte WHERE id = ");
- befehl->append(karteId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- int SSDatenbank::erstelleSpiel(int serverId)
- {
- if (!serverId)
- return 0;
- Text* befehl = new Text("SELECT such_spieler_fuer_spiel( ");
- befehl->append(serverId);
- befehl->append(")");
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- bool SSDatenbank::deleteSpielErstelltNext(int serverId)
- {
- if (!serverId)
- return 0;
- Text* befehl = new Text("DELETE FROM server_spiel_next WHERE server_spiel_id = ");
- befehl->append(serverId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- unlock();
- befehl->release();
- return 1;
- }
- int SSDatenbank::getSpielErstelltId(int serverId)
- {
- if (!serverId)
- return 0;
- Text* befehl = new Text("SELECT spiel_erstellt_id FROM server_spiel_next WHERE server_spiel_id = ");
- befehl->append(serverId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- int SSDatenbank::getSpielErstelltSpieler(int spielErstelltId, Array< int >* accountIds)
- {
- if (!spielErstelltId)
- return 0;
- Text* befehl = new Text("SELECT a.account_id FROM spiel_erstellt_spieler a WHERE a.spiel_erstellt_id = ");
- befehl->append(spielErstelltId);
- befehl->append(" UNION SELECT a.account_id FROM gruppe_spieler a, spiel_erstellt_gruppe b WHERE a.gruppe_id = b.gruppe_id AND b.spiel_erstellt_id = ");
- befehl->append(spielErstelltId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- int ret = res.zeilenAnzahl;
- for (int i = 0; i < ret; i++)
- accountIds->add(TextZuInt(res.values[i].getText(), 10));
- res.destroy();
- return ret;
- }
- int SSDatenbank::getKarteVonErstelltemSpiel(int spielErstelltId)
- {
- if (!spielErstelltId)
- return 0;
- Text* befehl = new Text("SELECT karte_id FROM spiel_erstellt WHERE id = ");
- befehl->append(spielErstelltId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- bool SSDatenbank::getChatServerPortIp(int accountId, int* port, Text* zIp)
- {
- if (!accountId)
- return 0;
- Text* befehl = new Text("SELECT a.port, a.ip FROM server a, account_client b, server_client c WHERE a.server_typ_name = 'chat' AND a.id = c.server_id AND c.client_id = b.client_id AND b.account_id = ");
- befehl->append(accountId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- *port = TextZuInt(res.values[0].getText(), 10);
- zIp->setText(res.values[1].getText());
- res.destroy();
- return 1;
- }
- bool SSDatenbank::spielErstelltAbbruch(int spielErstelltId, int anzahl, Array< int >* accounts, Array< int >* status, Array< bool >* inWarteschlange, RCArray< Zeit >* zeit)
- {
- if (!spielErstelltId || !anzahl)
- return 0;
- Text* befehl = new Text("BEGIN");
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- befehl->setText("UPDATE server_spiel_regel SET jetzt_spiele = jetzt_spiele - 1 FROM spiel_erstellt "
- "WHERE server_spiel_regel.server_spiel_id = spiel_erstellt.server_spiel_id "
- "AND server_spiel_regel.karte_id = spiel_erstellt.karte_id AND spiel_erstellt.id = ");
- befehl->append(spielErstelltId);
- if (!datenbank->befehl(befehl->getText()))
- {
- befehl->setText("ROLLBACK");
- datenbank->befehl(befehl->getText());
- unlock();
- befehl->release();
- return 0;
- }
- befehl->setText("UPDATE server SET tasks = tasks - 1 FROM spiel_erstellt "
- "WHERE server.id = spiel_erstellt.server_spiel_id AND spiel_erstellt.id = ");
- befehl->append(spielErstelltId);
- if (!datenbank->befehl(befehl->getText()))
- {
- befehl->setText("ROLLBACK");
- datenbank->befehl(befehl->getText());
- unlock();
- befehl->release();
- return 0;
- }
- befehl->setText("SELECT karte_id FROM spiel_erstellt WHERE id = ");
- befehl->append(spielErstelltId);
- if (!datenbank->befehl(befehl->getText()))
- {
- befehl->setText("ROLLBACK");
- datenbank->befehl(befehl->getText());
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- if (!res.zeilenAnzahl)
- {
- befehl->setText("ROLLBACK");
- datenbank->befehl(befehl->getText());
- unlock();
- befehl->release();
- res.destroy();
- return 0;
- }
- int karteId = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- befehl->setText("SELECT account_id, anmeldung_zeit FROM spiel_erstellt_spieler WHERE spiel_erstellt_id = ");
- befehl->append(spielErstelltId);
- if (!datenbank->befehl(befehl->getText()))
- {
- befehl->setText("ROLLBACK");
- datenbank->befehl(befehl->getText());
- unlock();
- befehl->release();
- return 0;
- }
- Result acc = datenbank->getResult();
- befehl->setText("SELECT gruppe_id, anmeldung_zeit FROM spiel_erstellt_gruppe WHERE spiel_erstellt_id = ");
- befehl->append(spielErstelltId);
- if (!datenbank->befehl(befehl->getText()))
- {
- befehl->setText("ROLLBACK");
- datenbank->befehl(befehl->getText());
- unlock();
- acc.destroy();
- befehl->release();
- return 0;
- }
- Result gru = datenbank->getResult();
- befehl->setText("DELETE FROM spiel_erstellt_spieler WHERE spiel_erstellt_id = ");
- befehl->append(spielErstelltId);
- if (!datenbank->befehl(befehl->getText()))
- {
- befehl->setText("ROLLBACK");
- datenbank->befehl(befehl->getText());
- unlock();
- acc.destroy();
- gru.destroy();
- befehl->release();
- return 0;
- }
- befehl->setText("DELETE FROM spiel_erstellt_gruppe WHERE spiel_erstellt_id = ");
- befehl->append(spielErstelltId);
- if (!datenbank->befehl(befehl->getText()))
- {
- befehl->setText("ROLLBACK");
- datenbank->befehl(befehl->getText());
- unlock();
- acc.destroy();
- gru.destroy();
- befehl->release();
- return 0;
- }
- befehl->setText("DELETE FROM spiel_erstellt WHERE id = ");
- befehl->append(spielErstelltId);
- if (!datenbank->befehl(befehl->getText()))
- {
- befehl->setText("ROLLBACK");
- datenbank->befehl(befehl->getText());
- unlock();
- acc.destroy();
- gru.destroy();
- befehl->release();
- return 0;
- }
- for (int i = 0; i < acc.zeilenAnzahl; i++)
- {
- int accId = TextZuInt(acc.values[i * 2].getText(), 10);
- for (int j = 0; j < anzahl; j++)
- {
- if (accounts->hat(j) && accId == accounts->get(j))
- {
- if (status->hat(j) && status->get(j) == 2)
- { // zurück in Warteschlange
- befehl->setText("INSERT INTO account_anmeldung_fuer_spiel( account_id, karte_id, anmeldung_zeit ) VALUES( ");
- befehl->append(accId);
- befehl->append(", ");
- befehl->append(karteId);
- befehl->append(", '");
- befehl->append(acc.values[i * 2 + 1].getText());
- befehl->append("' )");
- if (datenbank->befehl(befehl->getText()))
- {
- while (!inWarteschlange->hat(j))
- inWarteschlange->add(0);
- inWarteschlange->set(1, j);
- Zeit* jetzt = getZeit();
- Zeit* anmeldung = new Zeit();
- anmeldung->setZeit("y-m-d h:i:s", acc.values[i * 2 + 1].getText());
- jetzt->minusZeit(anmeldung);
- while (!zeit->hat(j))
- zeit->add(0);
- zeit->set(jetzt, j);
- }
- }
- break;
- }
- }
- }
- acc.destroy();
- for (int i = 0; i < gru.zeilenAnzahl; i++)
- {
- bool backInWarteschlange = 1;
- Array< int >* mitglieder = new Array< int >();
- int mAnzahl = getSpielerAusGruppe(TextZuInt(gru.values[i * 2].getText(), 10), mitglieder);
- for (int j = 0; j < mAnzahl; j++)
- {
- if (mitglieder->hat(j))
- {
- int akkId = mitglieder->get(j);
- for (int k = 0; k < anzahl; k++)
- {
- if (accounts->hat(k) && akkId == accounts->get(k))
- backInWarteschlange &= status->hat(k) && status->get(k) == 2;
- }
- if (!backInWarteschlange)
- break;
- }
- }
- if (backInWarteschlange)
- {
- befehl->setText("INSERT INTO grupe_aneldung_fuer_spiel( gruppe_id, anmeldung_zeit ) VALUES( ");
- befehl->append(TextZuInt(gru.values[i * 2].getText(), 10));
- befehl->append(", '");
- befehl->append(gru.values[i * 2 + 1].getText());
- befehl->append("' )");
- if (datenbank->befehl(befehl->getText()))
- {
- Zeit* jetzt = getZeit();
- Zeit* anmeldung = new Zeit();
- anmeldung->setZeit("y-m-d h:i:s", gru.values[i * 2 + 1].getText());
- jetzt->minusZeit(anmeldung);
- for (int j = 0; j < mAnzahl; j++)
- {
- int akkId = mitglieder->get(j);
- for (int k = 0; k < anzahl; k++)
- {
- if (accounts->hat(k) && akkId == accounts->get(k))
- {
- while (!inWarteschlange->hat(j))
- inWarteschlange->add(0);
- inWarteschlange->set(1, k);
- while (!zeit->hat(j))
- zeit->add(0);
- zeit->set(dynamic_cast<Zeit*>(jetzt->getThis()), k);
- }
- }
- }
- jetzt->release();
- }
- }
- mitglieder->release();
- }
- gru.destroy();
- befehl->setText("COMMIT");
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- unlock();
- befehl->release();
- return 1;
- }
- int SSDatenbank::spielErstelltFortsetzen(int spielErstelltId)
- {
- if (!spielErstelltId)
- return 0;
- Text* befehl = new Text("SELECT spiel_erstellt_fortsetzen( ");
- befehl->append(spielErstelltId);
- befehl->append(" )");
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- void SSDatenbank::spielSetTeams(int spielId, int sAnzahl, Array< int >* accounts, Array< int >* team)
- {
- Text* befehl = new Text("");
- for (int i = 0; i < sAnzahl; i++)
- {
- if (team->hat(i) && accounts->hat(i))
- {
- befehl->setText("UPDATE spiel_spieler SET team_id = ");
- befehl->append(team->get(i));
- befehl->append(" WHERE account_id = ");
- befehl->append(accounts->get(i));
- befehl->append(" AND spiel_id = ");
- befehl->append(spielId);
- lock();
- datenbank->befehl(befehl->getText());
- unlock();
- }
- }
- befehl->release();
- }
- void SSDatenbank::spielSetSpielerNummern(int spielId, int sAnzahl, Array< int >* accounts, Array< int >* spielerNummern)
- {
- Text* befehl = new Text("");
- for (int i = 0; i < sAnzahl; i++)
- {
- if (spielerNummern->hat(i) && accounts->hat(i))
- {
- befehl->setText("UPDATE spiel_spieler SET spieler_nummer = ");
- befehl->append(spielerNummern->get(i));
- befehl->append(" WHERE account_id = ");
- befehl->append(accounts->get(i));
- befehl->append(" AND spiel_id = ");
- befehl->append(spielId);
- lock();
- datenbank->befehl(befehl->getText());
- unlock();
- }
- }
- befehl->release();
- }
- int SSDatenbank::getSpielerAusGruppe(int gruppeId, Array< int >* accounts)
- {
- Text* befehl = new Text("SELECT account_id FROM gruppe_spieler WHERE gruppe_id = ");
- befehl->append(gruppeId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- int ret = res.zeilenAnzahl;
- for (int i = 0; i < ret; i++)
- accounts->add(TextZuInt(res.values[i].getText(), 10));
- res.destroy();
- return ret;
- }
- int SSDatenbank::getAktionForKlient(int serverId, int accountId, int* id)
- {
- if (!serverId || !accountId)
- return 0;
- Text* befehl = new Text("SELECT a.id FROM spiel_erstellt a, spiel_erstellt_spieler b "
- "WHERE b.spiel_erstellt_id = a.id AND b.account_id = ");
- befehl->append(accountId);
- befehl->append(" AND a.server_spiel_id = ");
- befehl->append(serverId);
- befehl->append(" UNION SELECT a.id FROM spiel_erstellt a, spiel_erstellt_gruppe b, gruppe_spieler d "
- "WHERE b.spiel_erstellt_id = a.id AND d.gruppe_id = b.gruppe_id AND d.account_id = ");
- befehl->append(accountId);
- befehl->append(" AND a.server_spiel_id = ");
- befehl->append(serverId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- {
- befehl->release();
- *id = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return 1;
- }
- res.destroy();
- befehl->setText("SELECT a.id FROM spiel a, spiel_spieler b WHERE a.id = b.spiel_id AND a.spiel_status_id < 3 AND a.spiel_server_id = ");
- befehl->append(serverId);
- befehl->append(" AND b.account_id = ");
- befehl->append(accountId); lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- befehl->release();
- if (res.zeilenAnzahl)
- {
- *id = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return 2;
- }
- res.destroy();
- return 0;
- }
- bool SSDatenbank::setSpielStatusIsRunning(int spielId)
- {
- if (!spielId)
- return 0;
- Text* befehl = new Text("UPDATE spiel SET spiel_status_id = 2 WHERE id = ");
- befehl->append(spielId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- unlock();
- befehl->release();
- return 1;
- }
- bool SSDatenbank::setSpielStatusBeendet(int spielId, int status)
- {
- if (!spielId)
- return 0;
- Text* befehl = new Text("UPDATE spiel SET spiel_status_id = ");
- befehl->append(status);
- befehl->append(" WHERE id = ");
- befehl->append(spielId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- unlock();
- befehl->setText("UPDATE spiel SET end_datum = now() WHERE id = ");
- befehl->append(spielId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- unlock();
- befehl->setText("UPDATE server SET tasks = tasks - 1 FROM spiel WHERE server.id = spiel.spiel_server_id AND spiel.id = ");
- befehl->append(spielId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- unlock();
- befehl->setText("UPDATE server_spiel_regel SET jetzt_spiele = jetzt_spiele - 1 FROM spiel WHERE server_spiel_regel.server_spiel_id = spiel.spiel_server_id AND server_spiel_regel.karte_id = spiel.karte_id AND spiel.id = ");
- befehl->append(spielId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- unlock();
- befehl->release();
- return 1;
- }
- bool SSDatenbank::setSpielSpielerStatus(int spielId, int accountId, int punkte, int status)
- {
- if (!spielId || !accountId)
- return 0;
- Text* befehl = new Text("UPDATE spiel_spieler SET spiel_spieler_status_id = ");
- befehl->append(status);
- befehl->append(" WHERE spiel_id = ");
- befehl->append(spielId);
- befehl->append(" AND account_id = ");
- befehl->append(accountId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- unlock();
- befehl->setText("UPDATE spiel_spieler SET punkte = ");
- befehl->append(punkte);
- befehl->append(" WHERE spiel_id = ");
- befehl->append(spielId);
- befehl->append(" AND account_id = ");
- befehl->append(accountId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- unlock();
- if ((punkte / 10 + status - 1) > 0 && (status == 1 || status == 2))
- {
- int kupfer = punkte / 10;
- kupfer += status - 1;
- befehl->setText("UPDATE account SET kupfer = kupfer + ");
- befehl->append(kupfer);
- befehl->append(" WHERE id = ");
- befehl->append(accountId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- unlock();
- }
- befehl->release();
- return 1;
- }
- bool SSDatenbank::addSpielerStatistik(int accountId, int spielId)
- {
- if (!spielId || !accountId)
- return 0;
- Text* befehl = new Text("SELECT spiel_statistik.* FROM spiel_statistik, spiel, karte "
- "WHERE spiel_statistik.spiel_art_id = karte.spiel_art_id AND karte.id = spiel.karte_id "
- "AND spiel_statistik.account_id = ");
- befehl->append(accountId);
- befehl->append(" AND spiel.id = ");
- befehl->append(spielId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- int anz = datenbank->getZeilenAnzahl();
- unlock();
- if (!anz)
- {
- befehl->setText("INSERT INTO spiel_statistik( account_id, spiel_art_id ) SELECT ");
- befehl->append(accountId);
- befehl->append(" AS account_id, spiel_art.id FROM spiel_art, karte, spiel "
- "WHERE spiel_art.id = karte.spiel_art_id AND karte.id = spiel.karte_id AND spiel.id = ");
- befehl->append(spielId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- unlock();
- }
- befehl->setText("SELECT spiel_spieler_status_id FROM spiel_spieler WHERE account_id = ");
- befehl->append(accountId);
- befehl->append(" AND spiel_id = ");
- befehl->append(spielId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- befehl->release();
- return 0;
- }
- int status = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- befehl->setText("UPDATE spiel_statistik SET gespielt = gespielt + 1, ");
- if (status == 1)
- befehl->append(" verloren = spiel_statistik.verloren + 1, ");
- if (status == 2)
- befehl->append(" gewonnen = spiel_statistik.gewonnen + 1, ");
- befehl->append(" punkte = spiel_statistik.punkte + spiel_spieler.punkte FROM spiel_spieler, karte, spiel "
- "WHERE spiel_statistik.account_id = spiel_spieler.account_id "
- "AND spiel_statistik.spiel_art_id = karte.spiel_art_id "
- "AND karte.id = spiel.karte_id AND spiel_spieler.spiel_id = spiel.id AND spiel.id = ");
- befehl->append(spielId);
- befehl->append(" AND spiel_statistik.account_id = ");
- befehl->append(accountId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- unlock();
- befehl->release();
- return 1;
- }
- Text* SSDatenbank::getAccountRufName(int accountId)
- {
- if (!accountId)
- return 0;
- Text* befehl = new Text("SELECT ruf_name FROM account WHERE id = ");
- befehl->append(accountId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- Text* ret = new Text(res.values[0].getText());
- res.destroy();
- return ret;
- }
- bool SSDatenbank::suchHistorieServer(short* port, Text* ip)
- {
- lock();
- if (!datenbank->befehl("SELECT such_historie_server()"))
- {
- unlock();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- if (!res.zeilenAnzahl || (int)res.values[0] == 0)
- {
- res.destroy();
- return 0;
- }
- lock();
- if (!datenbank->befehl(Text("SELECT port, ip FROM server WHERE id = ") += res.values[0].getText()))
- {
- unlock();
- res.destroy();
- return 0;
- }
- res.destroy();
- res = datenbank->getResult();
- unlock();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- *port = (short)(int)res.values[0];
- *ip = res.values[1].getText();
- res.destroy();
- return 1;
- }
- bool SSDatenbank::getKartenServer(int karteId, int* port, Text* ip)
- {
- Text befehl = "SELECT a.port, a.ip FROM server a, karte b ";
- befehl += "WHERE a.id = b.server_karten_id AND a.server_status_id = 3 AND b.id = ";
- befehl += karteId;
- lock();
- if (!datenbank->befehl(befehl))
- {
- unlock();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- *port = (int)res.values[0];
- ip->setText(res.values[1]);
- res.destroy();
- return 1;
- }
- Text* SSDatenbank::getSpielPfad(int karteId)
- {
- Text befehl = "SELECT a.id FROM spiel_art a, karte b WHERE b.spiel_art_id = a.id AND b.id = ";
- befehl += karteId;
- lock();
- if (!datenbank->befehl(befehl))
- {
- unlock();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int id = (int)res.values[0];
- res.destroy();
- Text* ret = new Text(ini->zWert("SpielePfad")->getText());
- ret->append("/");
- ret->append(id);
- return ret;
- }
- // constant
- Text* SSDatenbank::getLetzterFehler() const
- {
- return datenbank->getLetzterFehler();
- }
|