Database.cs 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829
  1. using System.Collections;
  2. using System.Collections.Generic;
  3. using UnityEngine;
  4. using Mono.Data.Sqlite;
  5. using System.Data;
  6. using System;
  7. using UnityEngine.Networking;
  8. using System.IO;
  9. public class Database : MonoBehaviour {
  10. private const string onlineQuestionsUrl = "narkampen.nordh.xyz/narKampen/dbFiles/Question.php";
  11. private const string serverUrl = "narkampen.nordh.xyz/narKampen/dbFiles/";
  12. string connectionType;
  13. string databaseUrl;
  14. string gameMode;
  15. int winAmount = -1;
  16. int questionTimer = -1;
  17. public GameObject questionCardPrefab;
  18. private static Database instance;
  19. public static Database Instance { get {
  20. if (instance == null) {
  21. instance = GameObject.FindObjectOfType<Database>();
  22. if (instance == null) {
  23. GameObject container = new GameObject("Database");
  24. instance = container.AddComponent<Database>();
  25. }
  26. }
  27. return instance;
  28. }
  29. }
  30. IDbConnection conn;
  31. internal void GetCategories(List<CategoryPanel.Category> list, string gameMode, int gameId) {
  32. if (gameMode.Equals(Constants.ONLINE)) {
  33. OnlineDatabase.Instance.GetCategories(list, gameId);
  34. } else {
  35. //string sql = "SELECT name, r, g, b, a, id FROM category";
  36. string sql = "SELECT category.*, count(*) as count FROM questions " +
  37. "INNER JOIN questionToCategory ON questions.id = questionToCategory.questionId " +
  38. "INNER JOIN category ON questionToCategory.categoryId = category.id " +
  39. "GROUP BY category.name";
  40. IDbCommand cmd = GetConnection();
  41. cmd.CommandText = sql;
  42. IDataReader reader = cmd.ExecuteReader();
  43. while (reader.Read()) {
  44. CategoryPanel.Category cat = new CategoryPanel.Category();
  45. byte r = (byte)reader.GetInt32(2);
  46. byte g = (byte)reader.GetInt32(3);
  47. byte b = (byte)reader.GetInt32(4);
  48. byte a = (byte)reader.GetInt32(5);
  49. cat.color = new Color32(r, g, b, a);
  50. cat.name = reader.GetString(1);
  51. cat.id = reader.GetInt32(0);
  52. cat.questionCount = reader.GetInt32(6);
  53. list.Add(cat);
  54. }
  55. CloseConnection();
  56. }
  57. }
  58. [Serializable]
  59. public class Question {
  60. public string question;
  61. public string answer;
  62. public string id;
  63. public string category;
  64. }
  65. [Serializable]
  66. public class Questions {
  67. public List<Question> questionsList = new List<Question>();
  68. }
  69. [Serializable]
  70. public class PlayerInfo {
  71. public string username;
  72. public string status;
  73. }
  74. [Serializable]
  75. public class PlayerInfos {
  76. public List<PlayerInfo> playerInfoList = new List<PlayerInfo>();
  77. }
  78. [Serializable]
  79. public class Category {
  80. public int r;
  81. public int g;
  82. public int b;
  83. public int a;
  84. public int id;
  85. public string name;
  86. }
  87. [Serializable]
  88. public class Categories {
  89. public List<Category> categoryList = new List<Category>();
  90. }
  91. [Serializable]
  92. public class OnlineGame {
  93. public string id;
  94. public string winNumber;
  95. public string answerTimer;
  96. public string roundTimeLimit;
  97. public string currentPlayer;
  98. public string round;
  99. public string startDate;
  100. public string LastPlayedDate;
  101. public string finishedDate;
  102. public string status;
  103. }
  104. [Serializable]
  105. public class OnlineGames {
  106. public List<OnlineGame> onlineGamesList = new List<OnlineGame>();
  107. }
  108. [Serializable]
  109. public class UserName {
  110. public string id;
  111. public string username;
  112. }
  113. [Serializable]
  114. public class UserNames {
  115. public List<UserName> usernamesList = new List<UserName>();
  116. }
  117. internal void SetLastPlayedDate(int gameId) {
  118. if (gameMode.Equals(Constants.ONLINE)) {
  119. }
  120. string sql = "UPDATE game SET lastPlayedDate = DATE() WHERE id = " + gameId;
  121. IDbCommand cmd = GetConnection();
  122. cmd.CommandText = sql;
  123. cmd.ExecuteNonQuery();
  124. cmd.Dispose();
  125. CloseConnection();
  126. }
  127. internal List<OnlineDatabase.UserName> FindRandomPlayer(int playerId)
  128. {
  129. List<OnlineDatabase.UserName> result = new List<OnlineDatabase.UserName>();
  130. result = OnlineDatabase.Instance.FindRandomPlayer(playerId);
  131. return result;
  132. }
  133. private IDbCommand GetConnection() {
  134. if (databaseUrl == null) { // ej bra lösning för online
  135. SetLocalOrOnline(Constants.LOCAL);
  136. }
  137. conn = new SqliteConnection(databaseUrl);
  138. conn.Open();
  139. IDbCommand cmd = conn.CreateCommand();
  140. return cmd;
  141. }
  142. private void CloseConnection() {
  143. conn.Close();
  144. }
  145. string questionString = "";
  146. string answerString = "";
  147. string idString = "";
  148. string categoryString = "";
  149. private int round = -1;
  150. private string SearchString;
  151. public string QuestionString { get => questionString; set => questionString = value; }
  152. private void Start() {
  153. if (instance == null) {
  154. instance = this;
  155. }
  156. if (databaseUrl == null || databaseUrl.Equals("")) {
  157. SetLocalOrOnline(Constants.LOCAL); // Temporary, should not be needed after local testing
  158. }
  159. }
  160. internal void SignIn(string username, int userId, bool keepSigendIn) {
  161. int ksi = 0;
  162. if (keepSigendIn) {
  163. ksi = 1;
  164. }
  165. string sql = "INSERT OR REPLACE INTO userSettings (username, userId, keepSignedIn) VALUES ('" + username + "', " + userId + "," + ksi + ")";
  166. IDbCommand cmd = GetConnection();
  167. cmd.CommandText = sql;
  168. cmd.ExecuteNonQuery();
  169. sql = "INSERT OR REPLACE INTO settings (name, value) VALUES ('signedInUser', '" + username + "')";
  170. cmd.CommandText = sql;
  171. cmd.ExecuteNonQuery();
  172. CloseConnection();
  173. }
  174. internal void SetGameFinished(int gameId, string gameMode)
  175. {
  176. if (gameMode.Equals(Constants.ONLINE)) {
  177. OnlineDatabase.Instance.SetGameFinished(gameId, gameMode);
  178. } else {
  179. string sql = "UPDATE game SET finishedDate = DATETIME() WHERE id = " + gameId;
  180. IDbCommand cmd = GetConnection();
  181. cmd.CommandText = sql;
  182. cmd.ExecuteNonQuery();
  183. }
  184. }
  185. internal bool IsKeepSignedIn() {
  186. string sql = "SELECT keepSignedIn FROM userSettings";
  187. IDbCommand cmd = GetConnection();
  188. cmd.CommandText = sql;
  189. IDataReader reader = cmd.ExecuteReader();
  190. int res = 0;
  191. while (reader.Read()) {
  192. res = reader.GetInt32(0);
  193. }
  194. return res == 1;
  195. }
  196. internal KeyValuePair<int, string> GetSignedInUser() {
  197. // string sql = "SELECT userId, username FROM userSettings";
  198. string sql = "SELECT userId, username FROM userSettings WHERE username = (SELECT value FROM settings WHERE name = 'signedInUser')";
  199. IDbCommand cmd = GetConnection();
  200. cmd.CommandText = sql;
  201. int userId = -1;
  202. string username = "";
  203. IDataReader reader = cmd.ExecuteReader();
  204. while (reader.Read()) {
  205. userId = reader.GetInt32(0);
  206. username = reader.GetString(1);
  207. }
  208. CloseConnection();
  209. return new KeyValuePair<int, string>(userId, username);
  210. }
  211. internal void LogoutUser() {
  212. // string sql = "UPDATE userSettings SET keepSignedIn = 0";
  213. string sql = "DELETE FROM userSettings";
  214. IDbCommand cmd = GetConnection();
  215. cmd.CommandText = sql;
  216. cmd.ExecuteNonQuery();
  217. sql = "DELETE FROM settings WHERE name = 'signedInUser'";
  218. cmd.CommandText = sql;
  219. cmd.ExecuteNonQuery();
  220. CloseConnection();
  221. }
  222. internal int GetQuestionTimer(int gameId, string gameMode) {
  223. if (questionTimer == -1) {
  224. string sql = "SELECT answerTimer FROM game WHERE id = " + gameId;
  225. if (databaseUrl == null) {
  226. SetLocalOrOnline(Constants.LOCAL);
  227. }
  228. IDbCommand cmd = GetConnection();
  229. cmd.CommandText = sql;
  230. IDataReader reader = cmd.ExecuteReader();
  231. while (reader.Read()) {
  232. questionTimer = reader.GetInt32(0);
  233. }
  234. reader.Close();
  235. cmd.Dispose();
  236. }
  237. CloseConnection();
  238. return this.questionTimer;
  239. }
  240. internal List<LocalGameScript> GetLocalGames(GameObject prefab) {
  241. List<LocalGameScript> games = new List<LocalGameScript>();
  242. string sql = "SELECT game.*, name, localUsers.id as userId FROM game INNER JOIN localGamePlayers on game.id = localGamePlayers.gameId INNER JOIN localUsers on playerId = localUsers.id order by game.id ASC, userId ASC";
  243. IDbConnection conn = new SqliteConnection(databaseUrl);
  244. conn.Open();
  245. IDbCommand cmd = conn.CreateCommand();
  246. cmd.CommandText = sql;
  247. IDataReader reader = cmd.ExecuteReader();
  248. int currentGame = -1;
  249. GameObject localGame;
  250. LocalGameScript lgs = null;
  251. string currentPlayerName = "";
  252. int currentPoints = 0;
  253. while (reader.Read()) {
  254. if (currentGame != reader.GetInt32(0)) {
  255. localGame = Instantiate(prefab, new Vector2(0, 0), Quaternion.identity) as GameObject;
  256. lgs = localGame.GetComponent<LocalGameScript>();
  257. var test = reader.GetValue(5);
  258. lgs.GameId = reader.GetInt32(0);
  259. lgs.GameMode = reader.GetString(1);
  260. lgs.QuestionsNeededToWin = reader.GetInt32(2).ToString();
  261. lgs.AnswerTimer = reader.GetInt32(3);
  262. lgs.NumberOfPlayers = reader.GetInt32(4).ToString();
  263. lgs.CurrentPlayer = reader.GetString(5);
  264. lgs.Round = reader.GetInt32(6).ToString();
  265. lgs.StartDate = reader.GetString(7);
  266. lgs.LastPlayedDate = reader.GetString(8);
  267. lgs.FinishedDate = reader.IsDBNull(9) ? "" : reader.GetString(9);
  268. currentPlayerName = reader.GetString(10);
  269. currentPoints = GetPlayerPoints(reader.GetInt32(0), currentPlayerName);
  270. lgs.AddPlayer(currentPlayerName, currentPoints);
  271. games.Add(lgs);
  272. } else if (currentGame == reader.GetInt32(0)) {
  273. currentPlayerName = reader.GetString(10);
  274. currentPoints = GetPlayerPoints(currentGame, currentPlayerName);
  275. lgs.AddPlayer(currentPlayerName, currentPoints);
  276. }
  277. currentGame = reader.GetInt32(0);
  278. }
  279. reader.Close();
  280. cmd.Dispose();
  281. conn.Close();
  282. return games;
  283. }
  284. internal void IncreasePlayerRound(int gameId, string currentPlayer) {
  285. if (gameMode.Equals(Constants.ONLINE)) {
  286. OnlineDatabase.Instance.IncreasePlayerRound(gameId, currentPlayer);
  287. } else {
  288. String sql = "UPDATE localGamePlayers SET playerRound = playerRound + 1 WHERE gameId = " + gameId + " AND playerId = (SELECT id FROM localUsers WHERE name = '" + currentPlayer + "')";
  289. IDbConnection conn = new SqliteConnection(databaseUrl);
  290. conn.Open();
  291. IDbCommand cmd = conn.CreateCommand();
  292. cmd.CommandText = sql;
  293. cmd.ExecuteNonQuery();
  294. cmd.Dispose();
  295. conn.Close();
  296. }
  297. }
  298. internal void SetQuestionsLost(int gameId, string playerName, int questionsLost) {
  299. string sql = "UPDATE localGamePlayers SET questionsLost = questionsLost + " + questionsLost + " WHERE gameId = " + gameId + " AND playerId = (SELECT id FROM localUsers WHERE name = '" + playerName + "')";
  300. IDbConnection conn = new SqliteConnection(databaseUrl);
  301. conn.Open();
  302. IDbCommand cmd = conn.CreateCommand();
  303. cmd.CommandText = sql;
  304. cmd.ExecuteNonQuery();
  305. cmd.Dispose();
  306. conn.Close();
  307. }
  308. internal void RemoveGame(int gameId) {
  309. string sql = "DELETE FROM game WHERE id = " + gameId;
  310. List<LocalGameScript> games = new List<LocalGameScript>();
  311. IDbConnection conn = new SqliteConnection(databaseUrl);
  312. conn.Open();
  313. IDbCommand cmd = conn.CreateCommand();
  314. cmd.CommandText = sql;
  315. cmd.ExecuteNonQuery();
  316. string deleteLockedQuestionsSql = "DELETE FROM usersLockedQuestions WHERE gameId = " + gameId;
  317. cmd.CommandText = deleteLockedQuestionsSql;
  318. cmd.ExecuteNonQuery();
  319. cmd.Dispose();
  320. conn.Close();
  321. }
  322. public string GetCurrentPlayer(int gameId, string gameMode) {
  323. if (gameMode.Equals(Constants.ONLINE)) {
  324. return OnlineDatabase.Instance.GetCurrentPlayer(gameId);
  325. }
  326. string sql = "SELECT currentPlayer FROM game WHERE id = " + gameId;
  327. IDbConnection conn = new SqliteConnection(databaseUrl);
  328. conn.Open();
  329. IDbCommand cmd = conn.CreateCommand();
  330. cmd.CommandText = sql;
  331. IDataReader reader = cmd.ExecuteReader();
  332. string currentPlayer = "";
  333. while (reader.Read()) {
  334. currentPlayer = reader.GetString(0);
  335. }
  336. reader.Close();
  337. cmd.Dispose();
  338. conn.Close();
  339. return currentPlayer;
  340. }
  341. public void SetCurrentPlayer(int gameId, string currentPlayer, string gameMode) {
  342. if (gameMode.Equals(Constants.ONLINE)) {
  343. OnlineDatabase.Instance.SetCurrentPlayer(gameId, currentPlayer);
  344. } else {
  345. string sql = "UPDATE game SET currentPlayer = '" + currentPlayer + "' WHERE id = " + gameId;
  346. IDbConnection conn = new SqliteConnection(databaseUrl);
  347. conn.Open();
  348. IDbCommand cmd = conn.CreateCommand();
  349. cmd.CommandText = sql;
  350. cmd.ExecuteNonQuery();
  351. cmd.Dispose();
  352. conn.Close();
  353. }
  354. }
  355. internal int GetPlayerPoints(int gameId, string playerName) {
  356. string sql = "SELECT count(*) FROM usersLockedQuestions WHERE gameId = " + gameId + " AND playerName = '" + playerName + "'";
  357. IDbConnection conn = new SqliteConnection(databaseUrl);
  358. conn.Open();
  359. IDbCommand cmd = conn.CreateCommand();
  360. cmd.CommandText = sql;
  361. IDataReader reader = cmd.ExecuteReader();
  362. int points = 0;
  363. while (reader.Read()) {
  364. points = reader.GetInt32(0);
  365. }
  366. reader.Close();
  367. cmd.Dispose();
  368. conn.Close();
  369. return points;
  370. }
  371. internal void SetFinishedDate(int gameId, string finishedDate, string gameMode) {
  372. if (gameMode.Equals(Constants.ONLINE)) {
  373. OnlineDatabase.Instance.SetFinishedDate(gameId, finishedDate);
  374. } else {
  375. string sql = "UPDATE game SET finishedDate = '" + finishedDate + "' WHERE id = " + gameId;
  376. IDbConnection conn = new SqliteConnection(databaseUrl);
  377. conn.Open();
  378. IDbCommand cmd = conn.CreateCommand();
  379. cmd.CommandText = sql;
  380. cmd.ExecuteNonQuery();
  381. cmd.Dispose();
  382. conn.Close();
  383. }
  384. }
  385. internal void SetRoundValue(int gameId, int round, string gameMode) {
  386. if (gameMode.Equals(Constants.ONLINE)) {
  387. OnlineDatabase.Instance.SetRoundValue(gameId, round);
  388. } else {
  389. string sql = "UPDATE game SET round = " + round + " WHERE id = " + gameId;
  390. IDbConnection conn = new SqliteConnection(databaseUrl);
  391. conn.Open();
  392. IDbCommand cmd = conn.CreateCommand();
  393. cmd.CommandText = sql;
  394. cmd.ExecuteNonQuery();
  395. cmd.Dispose();
  396. conn.Close();
  397. }
  398. }
  399. internal int GetRoundValue(int gameId, string gameMode) {
  400. if (gameMode.Equals(Constants.ONLINE)) {
  401. return OnlineDatabase.Instance.GetRoundValue(gameId);
  402. }
  403. if (this.round == -1) {
  404. SetLocalOrOnline(Constants.LOCAL);
  405. string sql = "SELECT round FROM game WHERE id = " + gameId;
  406. IDbConnection conn = new SqliteConnection(databaseUrl);
  407. conn.Open();
  408. IDbCommand cmd = conn.CreateCommand();
  409. cmd.CommandText = sql;
  410. IDataReader reader = cmd.ExecuteReader();
  411. while (reader.Read()) {
  412. this.round = reader.GetInt32(0);
  413. }
  414. reader.Close();
  415. cmd.Dispose();
  416. conn.Close();
  417. }
  418. return this.round;
  419. }
  420. internal List<KeyValuePair<string, int>> GetPlayersForGame(int gameId, string gameMode) {
  421. if (gameMode.Equals(Constants.ONLINE)) {
  422. return OnlineDatabase.Instance.GetPlayersForGame(gameId);
  423. }
  424. string sql = "SELECT name, (SELECT count(*) FROM usersLockedQuestions WHERE playerName = localUsers.name AND gameId = " + gameId + ") as numAnswers FROM localGamePlayers " +
  425. "LEFT JOIN localUsers ON localGamePlayers.playerId = localUsers.id " +
  426. "WHERE gameId = " + gameId;
  427. IDbConnection conn = new SqliteConnection(databaseUrl);
  428. conn.Open();
  429. IDbCommand cmd = conn.CreateCommand();
  430. cmd.CommandText = sql;
  431. IDataReader reader = cmd.ExecuteReader();
  432. List<KeyValuePair<string, int>> returnList = new List<KeyValuePair<string, int>>();
  433. while (reader.Read()) {
  434. KeyValuePair<string, int> player = new KeyValuePair<string, int>(reader.GetString(0), reader.GetInt32(1));
  435. returnList.Add(player);
  436. }
  437. return returnList;
  438. }
  439. public string AnswerString { get => answerString; set => answerString = value; }
  440. public string IdString { get => idString; set => idString = value; }
  441. public string CategoryString { get => categoryString; set => categoryString = value; }
  442. public void SetLocalOrOnline(string type) {
  443. gameMode = type;
  444. if (type.Equals(Constants.LOCAL)) {
  445. string databaseName = "narKampenLocal.db";
  446. if (Application.platform == RuntimePlatform.Android) {
  447. databaseUrl = Application.persistentDataPath + "/" + databaseName;
  448. if (!File.Exists(databaseUrl)) {
  449. UnityWebRequest load = UnityWebRequest.Get("jar:file://" + Application.dataPath + "!/assets/" + databaseName);
  450. load.SendWebRequest();
  451. while (!load.isDone) { }
  452. File.WriteAllBytes(databaseUrl, load.downloadHandler.data);
  453. }
  454. databaseUrl = "URI=file:" + databaseUrl;
  455. } else {
  456. databaseUrl = "URI=file:" + Application.dataPath + "/narKampenLocal.db";
  457. }
  458. } else {
  459. databaseUrl = onlineQuestionsUrl;
  460. }
  461. connectionType = type;
  462. }
  463. internal int GetQuestionsLost(int gameId, string playerName, string gameMode) {
  464. if (gameMode.Equals(Constants.ONLINE)) {
  465. return OnlineDatabase.Instance.GetQuestionsLost(gameId, playerName);
  466. }
  467. string sql = "SELECT questionsLost FROM localGamePlayers WHERE gameId = " + gameId + " AND playerId = (SELECT id from localUsers WHERE name = '" + playerName + "')";
  468. IDbConnection conn = new SqliteConnection(databaseUrl);
  469. conn.Open();
  470. IDbCommand cmd = conn.CreateCommand();
  471. cmd.CommandText = sql;
  472. IDataReader reader = cmd.ExecuteReader();
  473. int returnValue = 0;
  474. while (reader.Read()) {
  475. returnValue = reader.GetInt32(0);
  476. }
  477. reader.Close();
  478. cmd.Dispose();
  479. conn.Close();
  480. return returnValue;
  481. }
  482. public string GetGameMode(int gameId) {
  483. if (this.gameMode == null) {
  484. string sql = "SELECT gameMode FROM game WHERE id = " + gameId;
  485. IDbConnection conn = new SqliteConnection(databaseUrl);
  486. conn.Open();
  487. IDbCommand cmd = conn.CreateCommand();
  488. cmd.CommandText = sql;
  489. IDataReader reader = cmd.ExecuteReader();
  490. while (reader.Read()) {
  491. this.gameMode = reader.GetString(0);
  492. }
  493. reader.Close();
  494. cmd.Dispose();
  495. conn.Close();
  496. }
  497. return this.gameMode;
  498. }
  499. public void LinkPlayersToLocalGame(List<string> playerNames, int gameId) {
  500. IDbConnection conn = new SqliteConnection(databaseUrl);
  501. conn.Open();
  502. string questionSql = "SELECT id FROM questions order by random() limit 1";
  503. IDbCommand cmd = conn.CreateCommand();
  504. cmd.CommandText = questionSql;
  505. IDataReader reader = cmd.ExecuteReader();
  506. int questionId = -1;
  507. while (reader.Read()) {
  508. questionId = reader.GetInt32(0);
  509. }
  510. List<int> l = new List<int>();
  511. l.Add(questionId);
  512. foreach (string player in playerNames) {
  513. string sql = "SELECT id FROM localUsers WHERE name = '" + player + "'";
  514. int playerId;
  515. cmd = conn.CreateCommand();
  516. cmd.CommandText = sql;
  517. reader = cmd.ExecuteReader();
  518. if (reader.Read()) {
  519. playerId = reader.GetInt32(0);
  520. } else {
  521. reader.Close();
  522. sql = "INSERT INTO localUsers (name) VALUES ('" + player + "')";
  523. cmd.CommandText = sql;
  524. cmd.ExecuteNonQuery();
  525. cmd.CommandText = "SELECT last_insert_rowid()";
  526. Int64 lastInsert64 = (Int64)cmd.ExecuteScalar();
  527. playerId = (int)lastInsert64;
  528. }
  529. cmd.Dispose();
  530. reader.Close();
  531. LinkPlayerToGame(playerId, gameId);
  532. SavePlayersQuestion(l, player, gameId, Constants.LOCAL);
  533. }
  534. IDbCommand cmd2 = conn.CreateCommand();
  535. cmd2.CommandText = "UPDATE game SET currentPlayer = '" + playerNames[0] + "' WHERE id = " + gameId;
  536. cmd2.ExecuteNonQuery();
  537. cmd2.Dispose();
  538. conn.Close();
  539. }
  540. private void LinkPlayerToGame(int playerId, int gameId) {
  541. string sql = "INSERT INTO localGamePlayers (gameId, playerId) VALUES (" + gameId + ", " + playerId + ")";
  542. SqliteConnection conn2 = new SqliteConnection(databaseUrl);
  543. conn2.Open();
  544. IDbCommand cmd = conn2.CreateCommand();
  545. cmd.CommandText = sql;
  546. cmd.ExecuteNonQuery();
  547. cmd.Dispose();
  548. conn2.Close();
  549. }
  550. internal int GetWinCondition(int gameId, string gameMode) {
  551. if (gameMode.Equals(Constants.ONLINE)) {
  552. return OnlineDatabase.Instance.GetWinCondition(gameId);
  553. }
  554. if (winAmount == -1) {
  555. string sql = "SELECT winNumber FROM game WHERE id = " + gameId;
  556. IDbConnection conn = new SqliteConnection(databaseUrl);
  557. conn.Open();
  558. IDbCommand cmd = conn.CreateCommand();
  559. cmd.CommandText = sql;
  560. IDataReader reader = cmd.ExecuteReader();
  561. while (reader.Read()) {
  562. this.winAmount = reader.GetInt32(0);
  563. }
  564. reader.Close();
  565. cmd.Dispose();
  566. conn.Close();
  567. }
  568. return this.winAmount;
  569. }
  570. public int SetupNewLocalGame(int winNumber, int numberOfPlayers, int questionTimer) {
  571. string sql = "INSERT INTO game (winNumber, numberOfPlayers, answerTimer, gameMode, startedDate) VALUES (" + winNumber + "," + numberOfPlayers + "," + questionTimer + ", 'Local', DATE())";
  572. IDbConnection conn = new SqliteConnection(databaseUrl);
  573. conn.Open();
  574. IDbCommand cmd = conn.CreateCommand();
  575. cmd.CommandText = sql;
  576. int status = cmd.ExecuteNonQuery();
  577. cmd.CommandText = "SELECT last_insert_rowid()";
  578. Int64 lastInsert64 = (Int64)cmd.ExecuteScalar();
  579. return (int)lastInsert64;
  580. }
  581. public NewQuestionData GetNewQuestion(List<int> userAnsweredQuestions, KeyValuePair<int, String> user, string gameMode) {
  582. if (gameMode.Equals(Constants.ONLINE)) {
  583. return OnlineDatabase.Instance.GetNewQuestion(userAnsweredQuestions, user.Key);
  584. }
  585. int gameId = GameObject.Find("GameManager").GetComponent<GameManagerScript>().GameId;
  586. Color32 questionCategoryColor = new Color32(0, 0, 20, 20);
  587. if (connectionType == null) {
  588. SetLocalOrOnline(GetGameMode(gameId));
  589. }
  590. int id = -1;
  591. int categoryId = -1;
  592. string categoryName = "";
  593. if (connectionType == Constants.LOCAL) {
  594. IDbConnection conn = new SqliteConnection(databaseUrl);
  595. conn.Open();
  596. IDbCommand cmd = conn.CreateCommand();
  597. string answeredIds = String.Join(",", userAnsweredQuestions);
  598. string sql = "SELECT questions.id, question, answer, categoryId as category, name, category.R, category.G, category.B, category.A FROM questions INNER JOIN questionToCategory ON questions.id = questionToCategory.questionId INNER JOIN category on category.id = questionToCategory.categoryId WHERE questions.id NOT IN (" + answeredIds + ") AND questions.id NOT IN (SELECT questionId FROM questionsInGame WHERE gameId = " + gameId + " AND userId = (SELECT id from localUsers WHERE name = '" + user.Value + "')) ORDER BY RANDOM() limit 1";
  599. cmd.CommandText = sql;
  600. IDataReader reader = cmd.ExecuteReader();
  601. while (reader.Read()) {
  602. id = reader.GetInt32(0);
  603. string question = reader.GetString(1);
  604. int answer = reader.GetInt32(2);
  605. categoryId = reader.GetInt32(3);
  606. categoryName = reader.GetString(4);
  607. idString = id.ToString();
  608. questionString = question;
  609. categoryString = categoryId.ToString();
  610. answerString = answer.ToString();
  611. byte r = (byte)reader.GetInt32(5);
  612. byte g = (byte)reader.GetInt32(6);
  613. byte b = (byte)reader.GetInt32(7);
  614. byte a = (byte)reader.GetInt32(8);
  615. questionCategoryColor = new Color32(r, g, b, a);
  616. }
  617. reader.Close();
  618. string saveSentQuestionSql = "INSERT INTO questionsInGame (gameId, questionId, userId) VALUES (" + gameId + ", " + id + ", (SELECT id FROM localUsers WHERE name = '" + user.Value + "'))";
  619. cmd.CommandText = saveSentQuestionSql;
  620. cmd.ExecuteNonQuery();
  621. cmd.Dispose();
  622. conn.Close();
  623. }
  624. NewQuestionData q = new NewQuestionData(answerString, questionString, categoryName, categoryId, id, questionCategoryColor, false);
  625. return q;
  626. }
  627. public void SavePlayersQuestion(List<int> questionsToSave, string playerNameValue, int gameId, string gameMode) {
  628. if (gameMode.Equals(Constants.ONLINE)) {
  629. OnlineDatabase.Instance.SavePlayersQuestion(questionsToSave, playerNameValue, gameId);
  630. } else {
  631. SetLocalOrOnline(gameMode);
  632. string values = "";
  633. foreach (int questionId in questionsToSave) {
  634. values += "('" + playerNameValue + "'," + questionId + "," + gameId + "),";
  635. }
  636. values = values.Substring(0, values.Length - 1);
  637. string sql = "INSERT OR IGNORE INTO usersLockedQuestions (playerName, questionId, gameId) VALUES " + values;
  638. IDbConnection conn = new SqliteConnection(databaseUrl);
  639. conn.Open();
  640. IDbCommand cmd = conn.CreateCommand();
  641. cmd.CommandText = sql;
  642. cmd.ExecuteReader();
  643. cmd.Dispose();
  644. conn.Close();
  645. }
  646. }
  647. public List<NewQuestionData> GetPlayerQuestions(int gameId, string playerNameValue, string gameMode) {
  648. if (gameMode.Equals(Constants.ONLINE)) {
  649. return OnlineDatabase.Instance.GetPlayerQuestions(gameId, playerNameValue);
  650. }
  651. if (databaseUrl == null) {
  652. SetLocalOrOnline(GetGameMode(gameId));
  653. }
  654. List<NewQuestionData> questions = new List<NewQuestionData>();
  655. if (connectionType.Equals(Constants.LOCAL)) {
  656. string sql = "SELECT * FROM questions inner join questionToCategory on questions.id = questionToCategory.questionId INNER JOIN category ON category.id = questionToCategory.categoryId WHERE questions.id IN ( SELECT questionId FROM usersLockedQuestions WHERE gameId = " + gameId + " AND playerName = '" + playerNameValue + "') ORDER BY answer ASC";
  657. IDbConnection conn = new SqliteConnection(databaseUrl);
  658. conn.Open();
  659. IDbCommand cmd = conn.CreateCommand();
  660. cmd.CommandText = sql;
  661. IDataReader reader = cmd.ExecuteReader();
  662. while (reader.Read()) {
  663. Color32 questionCategoryColor = new Color32((byte)reader.GetInt32(7), (byte)reader.GetInt32(8), (byte)reader.GetInt32(9), (byte)reader.GetInt32(10));
  664. NewQuestionData questionData = new NewQuestionData(
  665. reader.GetInt32(2).ToString(),
  666. reader.GetString(1),
  667. reader.GetString(6),
  668. reader.GetInt32(5),
  669. reader.GetInt32(0),
  670. questionCategoryColor,
  671. true);
  672. questions.Add(questionData);
  673. }
  674. cmd.Dispose();
  675. conn.Close();
  676. }
  677. return questions;
  678. }
  679. private IEnumerator GetQuestionData(bool showAnswer) {
  680. UnityWebRequest www = UnityWebRequest.Get("narkampen.nordh.xyz/narKampen/dbFiles/Question.php");
  681. yield return www.SendWebRequest();
  682. if (www.isNetworkError || www.isHttpError) {
  683. Debug.Log(www.error);
  684. } else {
  685. while (!www.isDone) {
  686. yield return null;
  687. }
  688. // Show result
  689. string jsonData = www.downloadHandler.text;
  690. jsonData = "{\"questionsList\" : [ " + jsonData + " ]}";
  691. Questions qe = new Questions();
  692. JsonUtility.FromJsonOverwrite(jsonData, qe);
  693. questionString = qe.questionsList[0].question;
  694. answerString = qe.questionsList[0].answer;
  695. idString = qe.questionsList[0].id;
  696. categoryString = qe.questionsList[0].category;
  697. }
  698. }
  699. }