Datenbank.cpp 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552
  1. #include "Datenbank.h"
  2. #include <iostream>
  3. // Inhalt der LSDatenbank Klasse aus Datenbank.h
  4. // Konstruktor
  5. MSDatenbank::MSDatenbank( InitDatei *zIni )
  6. {
  7. datenbank = new Datenbank( zIni->zWert( "DBBenutzer" )->getText(), zIni->zWert( "DBPasswort" )->getText(),
  8. zIni->zWert( "DBName" )->getText(), zIni->zWert( "DBIP" )->getText(),
  9. (unsigned short)TextZuInt( zIni->zWert( "DBPort" )->getText(), 10 ) );
  10. if( !datenbank->istOk() )
  11. {
  12. std::cout << "MS: Die Verbindung zur Datenbank konnte nicht hergestellt werden.\nDas Programm wird beendet.";
  13. exit( 1 );
  14. }
  15. InitializeCriticalSection( &cs );
  16. ref = 1;
  17. Text befehl = "SELECT port, admin_port FROM server WHERE id = ";
  18. befehl += zIni->zWert( "ServerId" )->getText();
  19. lock();
  20. datenbank->befehl( befehl );
  21. Result res = datenbank->getResult();
  22. unlock();
  23. if( res.zeilenAnzahl == 1 )
  24. {
  25. zIni->addWert( "ServerPort", res.values[ 0 ] );
  26. zIni->addWert( "AdminServerPort", res.values[ 1 ] );
  27. }
  28. res.destroy();
  29. }
  30. // Destruktor
  31. MSDatenbank::~MSDatenbank()
  32. {
  33. datenbank->release();
  34. DeleteCriticalSection( &cs );
  35. }
  36. // nicht constant
  37. void MSDatenbank::lock()
  38. {
  39. EnterCriticalSection( &cs );
  40. }
  41. void MSDatenbank::unlock()
  42. {
  43. LeaveCriticalSection( &cs );
  44. }
  45. int MSDatenbank::istAdministrator( const char *name, const char *passwort )
  46. {
  47. Text *befehl = new Text( "SELECT id FROM benutzer WHERE name = '" );
  48. Text n( name );
  49. n.ersetzen( "'", "''" );
  50. befehl->append( (char*)n );
  51. befehl->append( "' AND passwort = md5( '" );
  52. Text p( passwort );
  53. p.ersetzen( "'", "''" );
  54. befehl->append( (char*)p );
  55. befehl->append( "' )" );
  56. lock();
  57. datenbank->befehl( befehl->getText() );
  58. Result res = datenbank->getResult();
  59. unlock();
  60. befehl->release();
  61. int ret = 0;
  62. if( res.zeilenAnzahl > 0 )
  63. ret = TextZuInt( res.values[ 0 ].getText(), 10 );
  64. res.destroy();
  65. return ret;
  66. }
  67. bool MSDatenbank::adminHatRecht( int id, int recht )
  68. {
  69. Text *befehl = new Text( "SELECT * FROM benutzer_rechte WHERE benutzer_id = " );
  70. befehl->append( id );
  71. befehl->append( " AND rechte_id = " );
  72. befehl->append( recht );
  73. lock();
  74. datenbank->befehl( befehl->getText() );
  75. int ret = datenbank->getZeilenAnzahl();
  76. unlock();
  77. befehl->release();
  78. return ret != 0;
  79. }
  80. bool MSDatenbank::proveKlient( int num, int sNum )
  81. {
  82. Text *befehl = new Text( "SELECT * FROM server_client WHERE server_id = " );
  83. befehl->append( sNum );
  84. befehl->append( " AND client_id = " );
  85. befehl->append( num );
  86. lock();
  87. datenbank->befehl( befehl->getText() );
  88. Result res = datenbank->getResult();
  89. unlock();
  90. befehl->release();
  91. bool ret = 0;
  92. if( res.zeilenAnzahl == 1 )
  93. ret = 1;
  94. res.destroy();
  95. return ret;
  96. }
  97. Text *MSDatenbank::getKlientKey( int cId )
  98. {
  99. lock();
  100. if( !datenbank->befehl( Text( "SELECT schluessel FROM client WHERE id = " ) += cId ) )
  101. {
  102. unlock();
  103. return 0;
  104. }
  105. Result res = datenbank->getResult();
  106. unlock();
  107. if( !res.zeilenAnzahl )
  108. {
  109. res.destroy();
  110. return 0;
  111. }
  112. Text *ret = new Text( res.values[ 0 ].getText() );
  113. res.destroy();
  114. return ret;
  115. }
  116. void MSDatenbank::unregisterKlient( int num, int sNum )
  117. {
  118. Text *befehl = new Text( "DELETE FROM server_client WHERE client_id = " );
  119. befehl->append( num );
  120. befehl->append( " AND server_id = " );
  121. befehl->append( sNum );
  122. lock();
  123. datenbank->befehl( befehl->getText() );
  124. int za = datenbank->getZeilenAnzahl();
  125. unlock();
  126. if( za == 1 )
  127. {
  128. befehl->setText( "UPDATE server SET tasks = tasks - 1 WHERE id = " );
  129. befehl->append( sNum );
  130. lock();
  131. datenbank->befehl( befehl->getText() );
  132. unlock();
  133. }
  134. befehl->release();
  135. }
  136. bool MSDatenbank::setServerStatus( int id, int status )
  137. {
  138. Text *befehl = new Text( "UPDATE server SET server_status_id = " );
  139. *befehl += status;
  140. *befehl += "WHERE id = ";
  141. *befehl += id;
  142. lock();
  143. if( !datenbank->befehl( befehl->getText() ) )
  144. {
  145. unlock();
  146. befehl->release();
  147. return 0;
  148. }
  149. bool ret = datenbank->getZeilenAnzahl() != 0;
  150. unlock();
  151. befehl->release();
  152. return ret;
  153. }
  154. bool MSDatenbank::setMaxClients( int id, int maxC )
  155. {
  156. Text *befehl = new Text( "UPDATE server SET max_tasks = " );
  157. befehl->append( maxC );
  158. befehl->append( " WHERE id = " );
  159. befehl->append( id );
  160. lock();
  161. if( !datenbank->befehl( befehl->getText() ) )
  162. {
  163. unlock();
  164. befehl->release();
  165. return 0;
  166. }
  167. bool ret = datenbank->getZeilenAnzahl() > 0;
  168. unlock();
  169. befehl->release();
  170. return ret;
  171. }
  172. bool MSDatenbank::serverIstNichtPausiert( int id )
  173. {
  174. Text *befehl = new Text( "SELECT server_status_id FROM server WHERE id = " );
  175. befehl->append( id );
  176. lock();
  177. if( !datenbank->befehl( befehl->getText() ) )
  178. {
  179. unlock();
  180. befehl->release();
  181. return 0;
  182. }
  183. Result res = datenbank->getResult();
  184. unlock();
  185. befehl->release();
  186. if( !res.zeilenAnzahl )
  187. {
  188. res.destroy();
  189. return 0;
  190. }
  191. bool ret = (int)res.values[ 0 ] == 3;
  192. res.destroy();
  193. return ret;
  194. }
  195. int MSDatenbank::getAccountId( int clientNumber )
  196. {
  197. Text befehl = "SELECT account_id FROM account_client WHERE client_id = ";
  198. befehl += clientNumber;
  199. lock();
  200. if( !datenbank->befehl( befehl ) )
  201. {
  202. unlock();
  203. return 0;
  204. }
  205. Result res = datenbank->getResult();
  206. unlock();
  207. if( !res.zeilenAnzahl )
  208. return 0;
  209. int ret = res.values[ 0 ];
  210. res.destroy();
  211. return ret;
  212. }
  213. Text *MSDatenbank::getAccountName( int accountId )
  214. {
  215. Text befehl = "SELECT ruf_name FROM account WHERE id = ";
  216. befehl += accountId;
  217. lock();
  218. if( !datenbank->befehl( befehl ) )
  219. {
  220. unlock();
  221. return 0;
  222. }
  223. Result res = datenbank->getResult();
  224. unlock();
  225. if( !res.zeilenAnzahl )
  226. return 0;
  227. Text *ret = new Text( res.values[ 0 ].getText() );
  228. res.destroy();
  229. return ret;
  230. }
  231. Text *MSDatenbank::getSecret( int client )
  232. {
  233. Text befehl = "SELECT secret FROM client WHERE id = ";
  234. befehl += client;
  235. lock();
  236. if( !datenbank->befehl( befehl ) )
  237. {
  238. unlock();
  239. return 0;
  240. }
  241. Result res = datenbank->getResult();
  242. unlock();
  243. if( !res.zeilenAnzahl )
  244. return 0;
  245. Text *ret = new Text( res.values[ 0 ].getText() );
  246. res.destroy();
  247. return ret;
  248. }
  249. int MSDatenbank::getMinigameOptionList( char *minigame, RCArray< Text > *zOptionList )
  250. {
  251. Text befehl = "SELECT a.options FROM minigame_option a, minigame b WHERE a.minigame_id = b.id AND b.name = '";
  252. Text m( minigame );
  253. m.ersetzen( "'", "''" );
  254. befehl += m;
  255. befehl += "' ORDER BY a.options";
  256. lock();
  257. if( !datenbank->befehl( befehl ) )
  258. {
  259. unlock();
  260. return 0;
  261. }
  262. Result res = datenbank->getResult();
  263. unlock();
  264. int anz = res.zeilenAnzahl;
  265. for( int i = 0; i < anz; i++ )
  266. zOptionList->add( new Text( (char*)res.values[ i ] ) );
  267. res.destroy();
  268. return anz;
  269. }
  270. int MSDatenbank::getMinigameBestscore( char *options, char *minigame, Text *zPlayer )
  271. {
  272. Text o( options );
  273. o.ersetzen( "'", "''" );
  274. Text m( minigame );
  275. m.ersetzen( "'", "''" );
  276. Text befehl = "SELECT b.score, a.ruf_name FROM account a, minigame_bestscore b, minigame_option o, minigame m "
  277. "WHERE m.id = o.minigame_id AND o.id = b.minigame_options_id AND a.id = b.account_id AND m.name = '";
  278. befehl += o;
  279. befehl += "' AND o.options = '";
  280. befehl += m;
  281. befehl += "'";
  282. lock();
  283. if( !datenbank->befehl( befehl ) )
  284. {
  285. unlock();
  286. return 0;
  287. }
  288. Result res = datenbank->getResult();
  289. unlock();
  290. if( !res.zeilenAnzahl )
  291. {
  292. res.destroy();
  293. return 0;
  294. }
  295. int ret = (int)res.values[ 0 ];
  296. zPlayer->setText( res.values[ 1 ] );
  297. res.destroy();
  298. return ret;
  299. }
  300. int MSDatenbank::getMinigameBestscore( char *minigame, Array< int > *zScoreList, RCArray< Text > *zPlayerList, RCArray< Text > *zOptionList )
  301. {
  302. Text m( minigame );
  303. m.ersetzen( "'", "''" );
  304. Text befehl = "SELECT b.score, a.ruf_name, o.options FROM account a, minigame_bestscore b, minigame_option o, minigame m "
  305. "WHERE m.id = o.minigame_id AND o.id = b.minigame_options_id AND a.id = b.account_id AND m.name = '";
  306. befehl += m;
  307. befehl += "' ORDER BY o.options, b.score";
  308. lock();
  309. if( !datenbank->befehl( befehl ) )
  310. {
  311. unlock();
  312. return 0;
  313. }
  314. Result res = datenbank->getResult();
  315. unlock();
  316. if( !res.zeilenAnzahl )
  317. {
  318. res.destroy();
  319. return 0;
  320. }
  321. int anz = res.zeilenAnzahl;
  322. for( int i = 0; i < anz; i++ )
  323. {
  324. zScoreList->add( (int)res.values[ i * 3 ] );
  325. zPlayerList->add( new Text( res.values[ i * 3 + 1 ] ) );
  326. zOptionList->add( new Text( res.values[ i * 3 + 2 ] ) );
  327. }
  328. res.destroy();
  329. return anz;
  330. }
  331. bool MSDatenbank::updateMinigameScore( int score, char *option, int cId, char *minigame, int sId, Text *zFileName )
  332. {
  333. Text o( option );
  334. o.ersetzen( "'", "''" );
  335. Text m( minigame );
  336. m.ersetzen( "'", "''" );
  337. Text befehl = "UPDATE minigame SET games_played = games_played + 1 WHERE name = '";
  338. befehl += m;
  339. befehl += "'";
  340. lock();
  341. if( !datenbank->befehl( befehl ) )
  342. {
  343. unlock();
  344. return 0;
  345. }
  346. unlock();
  347. befehl = "SELECT a.id FROM minigame_option a, minigame b WHERE a.minigame_id = b.id AND b.name = '";
  348. befehl += m;
  349. befehl += "' AND a.options = '";
  350. befehl += o;
  351. befehl += "'";
  352. lock();
  353. if( !datenbank->befehl( befehl ) )
  354. {
  355. unlock();
  356. return 0;
  357. }
  358. Result res = datenbank->getResult();
  359. unlock();
  360. if( !res.zeilenAnzahl )
  361. {
  362. res.destroy();
  363. return 0;
  364. }
  365. int optionId = res.values[ 0 ];
  366. *zFileName = optionId;
  367. *zFileName += ".mgc";
  368. res.destroy();
  369. befehl = "SELECT score FROM minigame_bestscore WHERE minigame_options_id = ";
  370. befehl += optionId;
  371. lock();
  372. if( !datenbank->befehl( befehl ) )
  373. {
  374. unlock();
  375. return 0;
  376. }
  377. res = datenbank->getResult();
  378. unlock();
  379. int anz = res.zeilenAnzahl;
  380. bool ret = !anz || (int)res.values[ 0 ] < score;
  381. res.destroy();
  382. if( ret )
  383. {
  384. if( anz )
  385. {
  386. befehl = "UPDATE minigame_bestscore b SET score = ";
  387. befehl += score;
  388. befehl += ", account_id = a.account_id, counter = counter + 1, minigame_server_id = ";
  389. befehl += sId;
  390. befehl += " FROM account_client a WHERE a.client_id = ";
  391. befehl += cId;
  392. befehl += " AND b.minigame_options_id = ";
  393. befehl += optionId;
  394. }
  395. else
  396. {
  397. befehl = "INSERT INTO minigame_bestscore( account_id, score, minigame_options_id, minigame_server_id ) SELECT a.account_id AS account_id, ";
  398. befehl += score;
  399. befehl += " AS score, ";
  400. befehl += optionId;
  401. befehl += " AS minigame_options_id, ";
  402. befehl += sId;
  403. befehl += " AS minigame_server_id FROM account_client a WHERE a.client_id = ";
  404. befehl += cId;
  405. }
  406. lock();
  407. if( !datenbank->befehl( befehl ) )
  408. {
  409. unlock();
  410. return 0;
  411. }
  412. unlock();
  413. befehl = "UPDATE account b SET kupfer = b.kupfer + a.counter FROM minigame_bestscore a WHERE a.account_id = b.id AND a.minigame_options_id = ";
  414. befehl += optionId;
  415. lock();
  416. if( !datenbank->befehl( befehl ) )
  417. {
  418. unlock();
  419. return 0;
  420. }
  421. unlock();
  422. }
  423. return ret;
  424. }
  425. Text *MSDatenbank::getMinigameCaptureFileName( char *option, char *minigame )
  426. {
  427. Text o( option );
  428. o.ersetzen( "'", "''" );
  429. Text m( minigame );
  430. m.ersetzen( "'", "''" );
  431. Text befehl = "SELECT a.id FROM minigame_option a, minigame b WHERE a.minigame_id = b.id AND b.name = '";
  432. befehl += m;
  433. befehl += "' AND a.options = '";
  434. befehl += o;
  435. befehl += "'";
  436. lock();
  437. if( !datenbank->befehl( befehl ) )
  438. {
  439. unlock();
  440. return 0;
  441. }
  442. Result res = datenbank->getResult();
  443. unlock();
  444. if( !res.zeilenAnzahl )
  445. {
  446. res.destroy();
  447. return 0;
  448. }
  449. int optionId = res.values[ 0 ];
  450. Text *fileName = new Text();
  451. fileName->append( optionId );
  452. fileName->append( ".mgc" );
  453. res.destroy();
  454. return fileName;
  455. }
  456. int MSDatenbank::getMinigameServer( char *minigame, char *option )
  457. {
  458. Text o( option );
  459. o.ersetzen( "'", "''" );
  460. Text m( minigame );
  461. m.ersetzen( "'", "''" );
  462. Text befehl = "SELECT a.id FROM server a, minigame_bestscore b, minigame_option c, minigame d WHERE a.id = b.minigame_server_id AND d.id = c.minigame_id AND b.minigame_options_id = c.id AND c.options = '";
  463. befehl += o;
  464. befehl += "' AND d.name = '";
  465. befehl += m;
  466. befehl += "'";
  467. lock();
  468. if( !datenbank->befehl( befehl ) )
  469. {
  470. unlock();
  471. return 0;
  472. }
  473. Result res = datenbank->getResult();
  474. unlock();
  475. int ret = 0;
  476. if( res.zeilenAnzahl )
  477. ret = res.values[ 0 ];
  478. res.destroy();
  479. return ret;
  480. }
  481. bool MSDatenbank::getMinigameServer( char *minigame, char *option, Text *zIp, Text *zPort )
  482. {
  483. Text o( option );
  484. o.ersetzen( "'", "''" );
  485. Text m( minigame );
  486. m.ersetzen( "'", "''" );
  487. Text befehl = "SELECT a.ip, a.port FROM server a, minigame_bestscore b, minigame_option c, minigame d WHERE a.id = b.minigame_server_id AND d.id = c.minigame_id AND b.minigame_options_id = c.id AND c.options = '";
  488. befehl += o;
  489. befehl += "' AND d.name = '";
  490. befehl += m;
  491. befehl += "'";
  492. lock();
  493. if( !datenbank->befehl( befehl ) )
  494. {
  495. unlock();
  496. return 0;
  497. }
  498. Result res = datenbank->getResult();
  499. unlock();
  500. if( res.zeilenAnzahl )
  501. {
  502. zIp->setText( (char*)res.values[ 0 ] );
  503. zPort->setText( (char*)res.values[ 1 ] );
  504. res.destroy();
  505. return 1;
  506. }
  507. res.destroy();
  508. return 0;
  509. }
  510. // constant
  511. Text *MSDatenbank::getLetzterFehler() const
  512. {
  513. return datenbank->getLetzterFehler();
  514. }
  515. // Reference Counting
  516. MSDatenbank *MSDatenbank::getThis()
  517. {
  518. ref++;
  519. return this;
  520. }
  521. MSDatenbank *MSDatenbank::release()
  522. {
  523. ref--;
  524. if( !ref )
  525. delete this;
  526. return 0;
  527. }