init_db.inc.php 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596
  1. <?php
  2. function init_db_schema() {
  3. try {
  4. global $pdo;
  5. $db_version = "20042017_1926";
  6. $stmt = $pdo->query("SHOW TABLES LIKE 'versions'");
  7. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  8. if ($num_results != 0) {
  9. $stmt = $pdo->query("SELECT `version` FROM `versions`");
  10. if ($stmt->fetch(PDO::FETCH_ASSOC)['version'] == $db_version) {
  11. return true;
  12. }
  13. }
  14. $views = array(
  15. "grouped_mail_aliases" => "CREATE VIEW grouped_mail_aliases (username, aliases) AS
  16. SELECT goto, IFNULL(GROUP_CONCAT(address SEPARATOR ' '), '') AS address FROM alias
  17. WHERE address!=goto
  18. AND active = '1'
  19. AND address NOT LIKE '@%'
  20. GROUP BY goto;",
  21. "grouped_sender_acl" => "CREATE VIEW grouped_sender_acl (username, send_as) AS
  22. SELECT logged_in_as, IFNULL(GROUP_CONCAT(send_as SEPARATOR ' '), '') AS send_as FROM sender_acl
  23. WHERE send_as NOT LIKE '@%'
  24. GROUP BY logged_in_as;",
  25. "grouped_domain_alias_address" => "CREATE VIEW grouped_domain_alias_address (username, ad_alias) AS
  26. SELECT username, IFNULL(GROUP_CONCAT(local_part, '@', alias_domain SEPARATOR ' '), '') AS ad_alias FROM mailbox
  27. LEFT OUTER JOIN alias_domain on target_domain=domain GROUP BY username;"
  28. );
  29. $tables = array(
  30. "versions" => array(
  31. "cols" => array(
  32. "application" => "VARCHAR(255) NOT NULL",
  33. "version" => "VARCHAR(100) NOT NULL",
  34. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  35. ),
  36. "keys" => array(
  37. "primary" => array(
  38. "" => array("application")
  39. )
  40. ),
  41. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  42. ),
  43. "admin" => array(
  44. "cols" => array(
  45. "username" => "VARCHAR(255) NOT NULL",
  46. "password" => "VARCHAR(255) NOT NULL",
  47. "superadmin" => "TINYINT(1) NOT NULL DEFAULT '0'",
  48. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  49. "modified" => "DATETIME ON UPDATE NOW(0)",
  50. "active" => "TINYINT(1) NOT NULL DEFAULT '1'"
  51. ),
  52. "keys" => array(
  53. "primary" => array(
  54. "" => array("username")
  55. )
  56. ),
  57. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  58. ),
  59. "alias" => array(
  60. "cols" => array(
  61. "address" => "VARCHAR(255) NOT NULL",
  62. "goto" => "TEXT NOT NULL",
  63. "domain" => "VARCHAR(255) NOT NULL",
  64. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  65. "modified" => "DATETIME ON UPDATE CURRENT_TIMESTAMP",
  66. "active" => "TINYINT(1) NOT NULL DEFAULT '1'"
  67. ),
  68. "keys" => array(
  69. "primary" => array(
  70. "" => array("address")
  71. ),
  72. "key" => array(
  73. "domain" => array("domain")
  74. )
  75. ),
  76. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  77. ),
  78. "sender_acl" => array(
  79. "cols" => array(
  80. "logged_in_as" => "VARCHAR(255) NOT NULL",
  81. "send_as" => "VARCHAR(255) NOT NULL"
  82. ),
  83. "keys" => array(),
  84. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  85. ),
  86. "domain" => array(
  87. "cols" => array(
  88. "domain" => "VARCHAR(255) NOT NULL",
  89. "description" => "VARCHAR(255)",
  90. "aliases" => "INT(10) NOT NULL DEFAULT '0'",
  91. "mailboxes" => "INT(10) NOT NULL DEFAULT '0'",
  92. "maxquota" => "BIGINT(20) NOT NULL DEFAULT '0'",
  93. "quota" => "BIGINT(20) NOT NULL DEFAULT '0'",
  94. "transport" => "VARCHAR(255) NOT NULL",
  95. "backupmx" => "TINYINT(1) NOT NULL DEFAULT '0'",
  96. "relay_all_recipients" => "TINYINT(1) NOT NULL DEFAULT '0'",
  97. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  98. "modified" => "DATETIME ON UPDATE CURRENT_TIMESTAMP",
  99. "active" => "TINYINT(1) NOT NULL DEFAULT '1'"
  100. ),
  101. "keys" => array(
  102. "primary" => array(
  103. "" => array("domain")
  104. )
  105. ),
  106. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  107. ),
  108. "alias_domain" => array(
  109. "cols" => array(
  110. "alias_domain" => "VARCHAR(255) NOT NULL",
  111. "target_domain" => "VARCHAR(255) NOT NULL",
  112. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  113. "modified" => "DATETIME ON UPDATE CURRENT_TIMESTAMP",
  114. "active" => "TINYINT(1) NOT NULL DEFAULT '1'"
  115. ),
  116. "keys" => array(
  117. "primary" => array(
  118. "" => array("alias_domain")
  119. ),
  120. "key" => array(
  121. "active" => array("active"),
  122. "target_domain" => array("target_domain")
  123. )
  124. ),
  125. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  126. ),
  127. "spamalias" => array(
  128. "cols" => array(
  129. "address" => "VARCHAR(255) NOT NULL",
  130. "goto" => "TEXT NOT NULL",
  131. "validity" => "INT(11) NOT NULL"
  132. ),
  133. "keys" => array(
  134. "primary" => array(
  135. "" => array("address")
  136. ),
  137. ),
  138. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  139. ),
  140. "filterconf" => array(
  141. "cols" => array(
  142. "object" => "VARCHAR(255) NOT NULL DEFAULT ''",
  143. "option" => "VARCHAR(50) NOT NULL DEFAULT ''",
  144. "value" => "VARCHAR(100) NOT NULL DEFAULT ''",
  145. "prefid" => "INT(11) NOT NULL AUTO_INCREMENT"
  146. ),
  147. "keys" => array(
  148. "primary" => array(
  149. "" => array("prefid")
  150. ),
  151. "key" => array(
  152. "object" => array("object")
  153. )
  154. ),
  155. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  156. ),
  157. "quota2" => array(
  158. "cols" => array(
  159. "username" => "VARCHAR(255) NOT NULL",
  160. "bytes" => "BIGINT(20) NOT NULL DEFAULT '0'",
  161. "messages" => "BIGINT(20) NOT NULL DEFAULT '0'"
  162. ),
  163. "keys" => array(
  164. "primary" => array(
  165. "" => array("username")
  166. )
  167. ),
  168. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  169. ),
  170. "mailbox" => array(
  171. "cols" => array(
  172. "username" => "VARCHAR(255) NOT NULL",
  173. "password" => "VARCHAR(255) NOT NULL",
  174. "name" => "VARCHAR(255)",
  175. "maildir" => "VARCHAR(255) NOT NULL",
  176. "quota" => "BIGINT(20) NOT NULL DEFAULT '0'",
  177. "local_part" => "VARCHAR(255) NOT NULL",
  178. "domain" => "VARCHAR(255) NOT NULL",
  179. "tls_enforce_in" => "TINYINT(1) NOT NULL DEFAULT '0'",
  180. "tls_enforce_out" => "TINYINT(1) NOT NULL DEFAULT '0'",
  181. "kind" => "VARCHAR(100) NOT NULL DEFAULT ''",
  182. "multiple_bookings" => "TINYINT(1) NOT NULL DEFAULT '0'",
  183. "wants_tagged_subject" => "TINYINT(1) NOT NULL DEFAULT '0'",
  184. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  185. "modified" => "DATETIME ON UPDATE CURRENT_TIMESTAMP",
  186. "active" => "TINYINT(1) NOT NULL DEFAULT '1'"
  187. ),
  188. "keys" => array(
  189. "primary" => array(
  190. "" => array("username")
  191. ),
  192. "key" => array(
  193. "domain" => array("domain")
  194. )
  195. ),
  196. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  197. ),
  198. "domain_admins" => array(
  199. "cols" => array(
  200. "username" => "VARCHAR(255) NOT NULL",
  201. "domain" => "VARCHAR(255) NOT NULL",
  202. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  203. "active" => "TINYINT(1) NOT NULL DEFAULT '1'"
  204. ),
  205. "keys" => array(
  206. "key" => array(
  207. "username" => array("username")
  208. )
  209. ),
  210. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  211. ),
  212. "imapsync" => array(
  213. "cols" => array(
  214. "id" => "INT NOT NULL AUTO_INCREMENT",
  215. "user2" => "VARCHAR(255) NOT NULL",
  216. "host1" => "VARCHAR(255) NOT NULL",
  217. "authmech1" => "ENUM('PLAIN','LOGIN','CRAM-MD5') DEFAULT 'PLAIN'",
  218. "regextrans2" => "VARCHAR(255) DEFAULT ''",
  219. "authmd51" => "TINYINT(1) NOT NULL DEFAULT 0",
  220. "domain2" => "VARCHAR(255) NOT NULL DEFAULT ''",
  221. "subfolder2" => "VARCHAR(255) NOT NULL DEFAULT ''",
  222. "user1" => "VARCHAR(255) NOT NULL",
  223. "password1" => "VARCHAR(255) NOT NULL",
  224. "exclude" => "VARCHAR(500) NOT NULL DEFAULT ''",
  225. "maxage" => "SMALLINT NOT NULL DEFAULT '0'",
  226. "mins_interval" => "VARCHAR(50) NOT NULL",
  227. "port1" => "SMALLINT NOT NULL",
  228. "enc1" => "ENUM('TLS','SSL','PLAIN') DEFAULT 'TLS'",
  229. "delete2duplicates" => "TINYINT(1) NOT NULL DEFAULT '1'",
  230. "returned_text" => "TEXT",
  231. "last_run" => "TIMESTAMP NULL DEFAULT NULL",
  232. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  233. "modified" => "DATETIME ON UPDATE CURRENT_TIMESTAMP",
  234. "active" => "TINYINT(1) NOT NULL DEFAULT '0'"
  235. ),
  236. "keys" => array(
  237. "primary" => array(
  238. "" => array("id")
  239. )
  240. ),
  241. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  242. ),
  243. "tfa" => array(
  244. "cols" => array(
  245. "id" => "INT NOT NULL AUTO_INCREMENT",
  246. "username" => "VARCHAR(255) NOT NULL",
  247. "authmech" => "ENUM('yubi_otp', 'u2f', 'hotp', 'totp')",
  248. "secret" => "VARCHAR(255) DEFAULT NULL",
  249. "keyHandle" => "VARCHAR(255) DEFAULT NULL",
  250. "publicKey" => "VARCHAR(255) DEFAULT NULL",
  251. "counter" => "INT NOT NULL DEFAULT '0'",
  252. "certificate" => "TEXT",
  253. "active" => "TINYINT(1) NOT NULL DEFAULT '0'"
  254. ),
  255. "keys" => array(
  256. "primary" => array(
  257. "" => array("id")
  258. )
  259. ),
  260. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  261. ),
  262. "forwarding_hosts" => array(
  263. "cols" => array(
  264. "host" => "VARCHAR(255) NOT NULL",
  265. "source" => "VARCHAR(255) NOT NULL"
  266. ),
  267. "keys" => array(
  268. "primary" => array(
  269. "" => array("host")
  270. ),
  271. ),
  272. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  273. ),
  274. "sogo_acl" => array(
  275. "cols" => array(
  276. "c_folder_id" => "INT NOT NULL",
  277. "c_object" => "VARCHAR(255) NOT NULL",
  278. "c_uid" => "VARCHAR(255) NOT NULL",
  279. "c_role" => "VARCHAR(80) NOT NULL"
  280. ),
  281. "keys" => array(
  282. "key" => array(
  283. "sogo_acl_c_folder_id_idx" => array("c_folder_id"),
  284. "sogo_acl_c_uid_idx" => array("c_uid")
  285. )
  286. ),
  287. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  288. ),
  289. "sogo_alarms_folder" => array(
  290. "cols" => array(
  291. "c_path" => "VARCHAR(255) NOT NULL",
  292. "c_name" => "VARCHAR(255) NOT NULL",
  293. "c_uid" => "VARCHAR(255) NOT NULL",
  294. "c_recurrence_id" => "INT(11) DEFAULT NULL",
  295. "c_alarm_number" => "INT(11) NOT NULL",
  296. "c_alarm_date" => "INT(11) NOT NULL"
  297. ),
  298. "keys" => array(),
  299. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  300. ),
  301. "sogo_cache_folder" => array(
  302. "cols" => array(
  303. "c_uid" => "VARCHAR(255) NOT NULL",
  304. "c_path" => "VARCHAR(255) NOT NULL",
  305. "c_parent_path" => "VARCHAR(255) DEFAULT NULL",
  306. "c_type" => "TINYINT(3) unsigned NOT NULL",
  307. "c_creationdate" => "INT(11) NOT NULL",
  308. "c_lastmodified" => "INT(11) NOT NULL",
  309. "c_version" => "INT(11) NOT NULL DEFAULT '0'",
  310. "c_deleted" => "TINYINT(4) NOT NULL DEFAULT '0'",
  311. "c_content" => "LONGTEXT"
  312. ),
  313. "keys" => array(
  314. "primary" => array(
  315. "" => array("c_uid", "c_path")
  316. ),
  317. ),
  318. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  319. ),
  320. "sogo_folder_info" => array(
  321. "cols" => array(
  322. "c_folder_id" => "BIGINT(20) unsigned NOT NULL AUTO_INCREMENT",
  323. "c_path" => "VARCHAR(255) NOT NULL",
  324. "c_path1" => "VARCHAR(255) NOT NULL",
  325. "c_path2" => "VARCHAR(255) DEFAULT NULL",
  326. "c_path3" => "VARCHAR(255) DEFAULT NULL",
  327. "c_path4" => "VARCHAR(255) DEFAULT NULL",
  328. "c_foldername" => "VARCHAR(255) NOT NULL",
  329. "c_location" => "INT NULL",
  330. "c_quick_location" => "VARCHAR(2048) DEFAULT NULL",
  331. "c_acl_location" => "VARCHAR(2048) DEFAULT NULL",
  332. "c_folder_type" => "VARCHAR(255) NOT NULL"
  333. ),
  334. "keys" => array(
  335. "primary" => array(
  336. "" => array("c_path")
  337. ),
  338. "unique" => array(
  339. "c_folder_id" => array("c_folder_id")
  340. )
  341. ),
  342. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  343. ),
  344. "sogo_quick_appointment" => array(
  345. "cols" => array(
  346. "c_folder_id" => "INT NOT NULL",
  347. "c_name" => "VARCHAR(255) NOT NULL",
  348. "c_uid" => "VARCHAR(255) NOT NULL",
  349. "c_startdate" => "INT",
  350. "c_enddate" => "INT",
  351. "c_cycleenddate" => "INT",
  352. "c_title" => "VARCHAR(1000) NOT NULL",
  353. "c_participants" => "TEXT",
  354. "c_isallday" => "INT",
  355. "c_iscycle" => "INT",
  356. "c_cycleinfo" => "TEXT",
  357. "c_classification" => "INT NOT NULL",
  358. "c_isopaque" => "INT NOT NULL",
  359. "c_status" => "INT NOT NULL",
  360. "c_priority" => "INT",
  361. "c_location" => "VARCHAR(255)",
  362. "c_orgmail" => "VARCHAR(255)",
  363. "c_partmails" => "TEXT",
  364. "c_partstates" => "TEXT",
  365. "c_category" => "VARCHAR(255)",
  366. "c_sequence" => "INT",
  367. "c_component" => "VARCHAR(10) NOT NULL",
  368. "c_nextalarm" => "INT",
  369. "c_description" => "TEXT"
  370. ),
  371. "keys" => array(
  372. "primary" => array(
  373. "" => array("c_folder_id", "c_name")
  374. )
  375. ),
  376. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  377. ),
  378. "sogo_quick_contact" => array(
  379. "cols" => array(
  380. "c_folder_id" => "INT NOT NULL",
  381. "c_name" => "VARCHAR(255) NOT NULL",
  382. "c_givenname" => "VARCHAR(255)",
  383. "c_cn" => "VARCHAR(255)",
  384. "c_sn" => "VARCHAR(255)",
  385. "c_screenname" => "VARCHAR(255)",
  386. "c_l" => "VARCHAR(255)",
  387. "c_mail" => "VARCHAR(255)",
  388. "c_o" => "VARCHAR(255)",
  389. "c_ou" => "VARCHAR(255)",
  390. "c_telephonenumber" => "VARCHAR(255)",
  391. "c_categories" => "VARCHAR(255)",
  392. "c_component" => "VARCHAR(10) NOT NULL"
  393. ),
  394. "keys" => array(
  395. "primary" => array(
  396. "" => array("c_folder_id", "c_name")
  397. )
  398. ),
  399. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  400. ),
  401. "sogo_sessions_folder" => array(
  402. "cols" => array(
  403. "c_id" => "VARCHAR(255) NOT NULL",
  404. "c_value" => "VARCHAR(255) NOT NULL",
  405. "c_creationdate" => "INT(11) NOT NULL",
  406. "c_lastseen" => "INT(11) NOT NULL"
  407. ),
  408. "keys" => array(
  409. "primary" => array(
  410. "" => array("c_id")
  411. )
  412. ),
  413. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  414. ),
  415. "sogo_store" => array(
  416. "cols" => array(
  417. "c_folder_id" => "INT NOT NULL",
  418. "c_name" => "VARCHAR(255) NOT NULL",
  419. "c_content" => "MEDIUMTEXT NOT NULL",
  420. "c_creationdate" => "INT NOT NULL",
  421. "c_lastmodified" => "INT NOT NULL",
  422. "c_version" => "INT NOT NULL",
  423. "c_deleted" => "INT"
  424. ),
  425. "keys" => array(
  426. "primary" => array(
  427. "" => array("c_folder_id", "c_name")
  428. )
  429. ),
  430. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  431. ),
  432. "sogo_user_profile" => array(
  433. "cols" => array(
  434. "c_uid" => "VARCHAR(255) NOT NULL",
  435. "c_defaults" => "TEXT",
  436. "c_settings" => "TEXT"
  437. ),
  438. "keys" => array(
  439. "primary" => array(
  440. "" => array("c_uid")
  441. )
  442. ),
  443. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  444. )
  445. );
  446. foreach ($tables as $table => $properties) {
  447. $stmt = $pdo->query("SHOW TABLES LIKE '" . $table . "'");
  448. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  449. if ($num_results != 0) {
  450. foreach($properties['cols'] as $column => $type) {
  451. $stmt = $pdo->query("SHOW COLUMNS FROM `" . $table . "` LIKE '" . $column . "'");
  452. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  453. if ($num_results == 0) {
  454. $pdo->query("ALTER TABLE `" . $table . "` ADD `" . $column . "` " . $type);
  455. }
  456. else {
  457. $pdo->query("ALTER TABLE `" . $table . "` MODIFY COLUMN `" . $column . "` " . $type);
  458. }
  459. }
  460. foreach($properties['keys'] as $key_type => $key_content) {
  461. if (strtolower($key_type) == 'primary') {
  462. foreach ($key_content as $key_values) {
  463. $fields = "`" . implode("`, `", $key_values) . "`";
  464. $stmt = $pdo->query("SHOW KEYS FROM `" . $table . "` WHERE Key_name = 'PRIMARY'");
  465. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  466. $is_drop = ($num_results != 0) ? "DROP PRIMARY KEY, " : "";
  467. $pdo->query("ALTER TABLE `" . $table . "` " . $is_drop . "ADD PRIMARY KEY (" . $fields . ")");
  468. }
  469. }
  470. if (strtolower($key_type) == 'key') {
  471. foreach ($key_content as $key_name => $key_values) {
  472. $fields = "`" . implode("`, `", $key_values) . "`";
  473. $stmt = $pdo->query("SHOW KEYS FROM `" . $table . "` WHERE Key_name = '" . $key_name . "'");
  474. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  475. $is_drop = ($num_results != 0) ? "DROP INDEX `" . $key_name . "`, " : "";
  476. $pdo->query("ALTER TABLE `" . $table . "` " . $is_drop . "ADD KEY `" . $key_name . "` (" . $fields . ")");
  477. }
  478. }
  479. if (strtolower($key_type) == 'unique') {
  480. foreach ($key_content as $key_name => $key_values) {
  481. $fields = "`" . implode("`, `", $key_values) . "`";
  482. $stmt = $pdo->query("SHOW KEYS FROM `" . $table . "` WHERE Key_name = '" . $key_name . "'");
  483. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  484. $is_drop = ($num_results != 0) ? "DROP INDEX `" . $key_name . "`, " : "";
  485. $pdo->query("ALTER TABLE `" . $table . "` " . $is_drop . "ADD UNIQUE KEY `" . $key_name . "` (" . $fields . ")");
  486. }
  487. }
  488. }
  489. // Drop all vanished columns
  490. $stmt = $pdo->query("SHOW COLUMNS FROM `" . $table . "`");
  491. $cols_in_table = $stmt->fetchAll(PDO::FETCH_ASSOC);
  492. while ($row = array_shift($cols_in_table)) {
  493. if (!array_key_exists($row['Field'], $properties['cols'])) {
  494. $pdo->query("ALTER TABLE `" . $table . "` DROP COLUMN `" . $row['Field'] . "`;");
  495. }
  496. }
  497. // Step 1: Get all non-primary keys, that currently exist and those that should exist
  498. $stmt = $pdo->query("SHOW KEYS FROM `" . $table . "` WHERE `Key_name` != 'PRIMARY'");
  499. $keys_in_table = $stmt->fetchAll(PDO::FETCH_ASSOC);
  500. $keys_to_exist = array();
  501. if (isset($properties['keys']['unique']) && is_array($properties['keys']['unique'])) {
  502. foreach ($properties['keys']['unique'] as $key_name => $key_values) {
  503. $keys_to_exist[] = $key_name;
  504. }
  505. }
  506. if (isset($properties['keys']['key']) && is_array($properties['keys']['key'])) {
  507. foreach ($properties['keys']['key'] as $key_name => $key_values) {
  508. $keys_to_exist[] = $key_name;
  509. }
  510. }
  511. // Step 2: Drop all vanished indexes
  512. while ($row = array_shift($keys_in_table)) {
  513. if (!in_array($row['Key_name'], $keys_to_exist)) {
  514. $pdo->query("ALTER TABLE `" . $table . "` DROP INDEX `" . $row['Key_name'] . "`");
  515. }
  516. }
  517. // Step 3: Drop all vanished primary keys
  518. if (!isset($properties['keys']['primary'])) {
  519. $stmt = $pdo->query("SHOW KEYS FROM `" . $table . "` WHERE Key_name = 'PRIMARY'");
  520. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  521. if ($num_results != 0) {
  522. $pdo->query("ALTER TABLE `" . $table . "` DROP PRIMARY KEY");
  523. }
  524. }
  525. }
  526. else {
  527. // Create table if it is missing
  528. $sql = "CREATE TABLE IF NOT EXISTS `" . $table . "` (";
  529. foreach($properties['cols'] as $column => $type) {
  530. $sql .= $column . " " . $type . ",";
  531. }
  532. foreach($properties['keys'] as $key_type => $key_content) {
  533. if (strtolower($key_type) == 'primary') {
  534. foreach ($key_content as $key_values) {
  535. $fields = "`" . implode("`, `", $key_values) . "`";
  536. $sql .= "PRIMARY KEY (" . $fields . ")" . ",";
  537. }
  538. }
  539. elseif (strtolower($key_type) == 'key') {
  540. foreach ($key_content as $key_name => $key_values) {
  541. $fields = "`" . implode("`, `", $key_values) . "`";
  542. $sql .= "KEY `" . $key_name . "` (" . $fields . ")" . ",";
  543. }
  544. }
  545. elseif (strtolower($key_type) == 'unique') {
  546. foreach ($key_content as $key_name => $key_values) {
  547. $fields = "`" . implode("`, `", $key_values) . "`";
  548. $sql .= "UNIQUE KEY `" . $key_name . "` (" . $fields . ")" . ",";
  549. }
  550. }
  551. }
  552. $sql = rtrim($sql, ",");
  553. $sql .= ") " . $properties['attr'];
  554. $pdo->query($sql);
  555. }
  556. // Reset table attributes
  557. $pdo->query("ALTER TABLE `" . $table . "` " . $properties['attr'] . ";");
  558. }
  559. // Recreate SQL views
  560. foreach ($views as $view => $create) {
  561. $pdo->query("DROP VIEW IF EXISTS `" . $view . "`;");
  562. $pdo->query($create);
  563. }
  564. // Inject admin if not exists
  565. $stmt = $pdo->query("INSERT INTO `admin` (`username`, `password`, `superadmin`, `created`, `modified`, `active`)
  566. SELECT 'admin', '{SSHA256}K8eVJ6YsZbQCfuJvSUbaQRLr0HPLz5rC9IAp0PAFl0tmNDBkMDc0NDAyOTAxN2Rk', 1, NOW(), NOW(), 1
  567. WHERE NOT EXISTS (SELECT * FROM `admin`);");
  568. $stmt = $pdo->query("DELETE FROM `domain_admins`;");
  569. $stmt = $pdo->query("INSERT INTO `domain_admins` (`username`, `domain`, `created`, `active`)
  570. SELECT `username`, 'ALL', NOW(), 1 FROM `admin`
  571. WHERE superadmin='1' AND `username` NOT IN (SELECT `username` FROM `domain_admins`);");
  572. // Insert new DB schema version
  573. $stmt = $pdo->query("REPLACE INTO `versions` (`application`, `version`) VALUES ('db_schema', '" . $db_version . "');");
  574. $_SESSION['return'] = array(
  575. 'type' => 'success',
  576. 'msg' => 'Database initialisation completed'
  577. );
  578. }
  579. catch (PDOException $e) {
  580. $_SESSION['return'] = array(
  581. 'type' => 'danger',
  582. 'msg' => 'Database initialisation failed: ' . $e->getMessage()
  583. );
  584. }
  585. }
  586. ?>