UpdateController.class.php 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495
  1. <?php
  2. namespace Home\Controller;
  3. use Think\Controller;
  4. class UpdateController extends BaseController {
  5. //升级数据库
  6. public function db(){
  7. $this->_clear_runtime();
  8. if (strtolower(C("DB_TYPE")) == 'mysql' ) {
  9. //$this->mysql();
  10. echo 'ShowDoc does not support mysql any more . http://api.pkbigdata.com/help?page_id=31990 ';
  11. }
  12. elseif (strtolower(C("DB_TYPE")) == 'sqlite' ) {
  13. $this->sqlite();
  14. }
  15. $this->_clear_runtime();
  16. }
  17. public function sqlite(){
  18. //catalog表增加parent_cat_id字段
  19. $columns = M("catalog")->getDbFields();
  20. if ($columns) {
  21. $has_it = 0 ;//是否存在该字段
  22. foreach ($columns as $key => $value) {
  23. if ($value == 'parent_cat_id') {
  24. $has_it = 1 ;
  25. }
  26. }
  27. if ($has_it === 0) {
  28. $sql = "ALTER TABLE ".C('DB_PREFIX')."catalog ADD parent_cat_id INT( 10 ) NOT NULL DEFAULT '0' ;";
  29. D("catalog")->execute($sql);
  30. }
  31. }
  32. //catalog表增加level字段
  33. $columns = M("catalog")->getDbFields();
  34. if ($columns) {
  35. $has_it = 0 ;//是否存在该字段
  36. foreach ($columns as $key => $value) {
  37. if ($value == 'level') {
  38. $has_it = 1 ;
  39. }
  40. }
  41. if ($has_it === 0) {
  42. $sql = "ALTER TABLE ".C('DB_PREFIX')."catalog ADD level INT( 10 ) NOT NULL DEFAULT '2' ;";
  43. D("catalog")->execute($sql);
  44. }
  45. }
  46. //item表增加item_domain字段
  47. $columns = M("item")->getDbFields();
  48. if ($columns) {
  49. $has_it = 0 ;//是否存在该字段
  50. foreach ($columns as $key => $value) {
  51. if ($value == 'item_domain') {
  52. $has_it = 1 ;
  53. }
  54. }
  55. if ($has_it === 0) {
  56. $sql = "ALTER TABLE ".C('DB_PREFIX')."item ADD item_domain text NOT NULL DEFAULT '';";
  57. D("item")->execute($sql);
  58. }
  59. }
  60. //创建user_token表
  61. $sql = "CREATE TABLE IF NOT EXISTS `user_token` (
  62. `id` INTEGER PRIMARY KEY ,
  63. `uid` int(10) NOT NULL DEFAULT '0',
  64. `token` CHAR(200) NOT NULL DEFAULT '',
  65. `token_expire` int(11) NOT NULL DEFAULT '0' ,
  66. `ip` CHAR(200) NOT NULL DEFAULT '',
  67. `addtime` int(11) NOT NULL DEFAULT '0'
  68. )";
  69. D("UserToken")->execute($sql);
  70. //创建template表
  71. $sql = "CREATE TABLE IF NOT EXISTS `template` (
  72. `id` INTEGER PRIMARY KEY ,
  73. `uid` int(10) NOT NULL DEFAULT '0',
  74. `username` CHAR(200) NOT NULL DEFAULT '',
  75. `template_title` CHAR(200) NOT NULL DEFAULT '' ,
  76. `template_content` text NOT NULL DEFAULT '',
  77. `addtime` int(11) NOT NULL DEFAULT '0'
  78. )";
  79. D("UserToken")->execute($sql);
  80. //page表增加page_comments字段
  81. $columns = D("Page")->getDbFields();
  82. if ($columns) {
  83. $has_it = 0 ;//是否存在该字段
  84. foreach ($columns as $key => $value) {
  85. if ($value == 'page_comments') {
  86. $has_it = 1 ;
  87. }
  88. }
  89. if ($has_it === 0) {
  90. $sql = "ALTER TABLE ".C('DB_PREFIX')."page ADD page_comments text NOT NULL DEFAULT '' ;";
  91. D("Page")->execute($sql);
  92. }
  93. }
  94. //page_history 表增加page_comments字段
  95. $columns = D("PageHistory")->getDbFields();
  96. if ($columns) {
  97. $has_it = 0 ;//是否存在该字段
  98. foreach ($columns as $key => $value) {
  99. if ($value == 'page_comments') {
  100. $has_it = 1 ;
  101. }
  102. }
  103. if ($has_it === 0) {
  104. $sql = "ALTER TABLE ".C('DB_PREFIX')."page_history ADD page_comments text NOT NULL DEFAULT '';";
  105. D("PageHistory")->execute($sql);
  106. }
  107. }
  108. //item_member表增加member_group_id字段
  109. $columns = M("ItemMember")->getDbFields();
  110. if ($columns) {
  111. $has_it = 0 ;//是否存在该字段
  112. foreach ($columns as $key => $value) {
  113. if ($value == 'member_group_id') {
  114. $has_it = 1 ;
  115. }
  116. }
  117. if ($has_it === 0) {
  118. $sql = "ALTER TABLE ".C('DB_PREFIX')."item_member ADD member_group_id INT( 1 ) NOT NULL DEFAULT '1' ;";
  119. D("ItemMember")->execute($sql);
  120. }
  121. }
  122. //item表增加item_type字段
  123. $columns = M("Item")->getDbFields();
  124. if ($columns) {
  125. $has_it = 0 ;//是否存在该字段
  126. foreach ($columns as $key => $value) {
  127. if ($value == 'item_type') {
  128. $has_it = 1 ;
  129. }
  130. }
  131. if ($has_it === 0) {
  132. $sql = "ALTER TABLE ".C('DB_PREFIX')."item ADD item_type INT( 1 ) NOT NULL DEFAULT '1' ;";
  133. D("Item")->execute($sql);
  134. }
  135. }
  136. //创建options表
  137. $sql = "CREATE TABLE IF NOT EXISTS `options` (
  138. `option_id` INTEGER PRIMARY KEY ,
  139. `option_name` CHAR(200) NOT NULL UNIQUE ,
  140. `option_value` CHAR(200) NOT NULL
  141. )";
  142. D("UserToken")->execute($sql);
  143. //创建item_token表
  144. $sql = "CREATE TABLE IF NOT EXISTS `item_token` (
  145. `id` INTEGER PRIMARY KEY ,
  146. `item_id` int(11) NOT NULL DEFAULT '0' ,
  147. `api_key` CHAR(200) NOT NULL UNIQUE ,
  148. `api_token` CHAR(200) NOT NULL ,
  149. `addtime` int(11) NOT NULL DEFAULT '0' ,
  150. `last_check_time` int(11) NOT NULL DEFAULT '0'
  151. )";
  152. D("UserToken")->execute($sql);
  153. //创建item_top表
  154. $sql = "CREATE TABLE IF NOT EXISTS `item_top` (
  155. `id` INTEGER PRIMARY KEY ,
  156. `item_id` int(11) NOT NULL DEFAULT '0' ,
  157. `uid` int(11) NOT NULL DEFAULT '0' ,
  158. `addtime` int(11) NOT NULL DEFAULT '0'
  159. )";
  160. D("UserToken")->execute($sql);
  161. //item表增加is_archived字段
  162. $columns = M("Item")->getDbFields();
  163. if ($columns) {
  164. $has_it = 0 ;//是否存在该字段
  165. foreach ($columns as $key => $value) {
  166. if ($value == 'is_archived') {
  167. $has_it = 1 ;
  168. }
  169. }
  170. if ($has_it === 0) {
  171. $sql = "ALTER TABLE ".C('DB_PREFIX')."item ADD is_archived INT( 1 ) NOT NULL DEFAULT '0' ;";
  172. D("Item")->execute($sql);
  173. }
  174. }
  175. echo 'OK!';
  176. }
  177. private function _clear_runtime($path = RUNTIME_PATH){
  178. //给定的目录不是一个文件夹
  179. if(!is_dir($path)){
  180. return null;
  181. }
  182. $fh = opendir($path);
  183. while(($row = readdir($fh)) !== false){
  184. //过滤掉虚拟目录
  185. if($row == '.' || $row == '..'|| $row == 'index.html'){
  186. continue;
  187. }
  188. if(!is_dir($path.'/'.$row)){
  189. unlink($path.'/'.$row);
  190. }
  191. $this->_clear_runtime($path.'/'.$row);
  192. }
  193. //关闭目录句柄,否则出Permission denied
  194. closedir($fh);
  195. return true;
  196. }
  197. //转移mysql的数据到sqlite
  198. public function toSqlite(){
  199. $this->_clear_runtime();
  200. if (strtolower(C("DB_TYPE")) == 'mysql' ) {
  201. $this->mysql();
  202. $this->_moveTable("catalog");
  203. $this->_moveTable("item");
  204. $this->_moveTable("item_member");
  205. $this->_moveTable("page");
  206. $this->_moveTable("page_history");
  207. $this->_moveTable("template");
  208. $this->_moveTable("user");
  209. $this->_moveTable("user_token");
  210. $db_config = array(
  211. 'DB_TYPE' => 'Sqlite',
  212. 'DB_NAME' => 'Sqlite/showdoc.db.php',
  213. );
  214. $array = M("item")->db(2,$db_config)->select();
  215. if ($array) {
  216. echo "ok";
  217. }else{
  218. echo 'fail';
  219. }
  220. }
  221. else{
  222. echo "mysql not found";
  223. }
  224. $this->_clear_runtime();
  225. }
  226. //升级mysql数据库
  227. public function mysql(){
  228. //user表的username字段增大了长度,防止长邮箱的用户名注册不了
  229. $sql = "alter table ".C('DB_PREFIX')."user modify column username varchar(50) CHARACTER SET utf8 NOT NULL DEFAULT '' ";
  230. M("Catalog")->execute($sql);
  231. //item表增加last_update_time字段
  232. $columns = M("item")->getDbFields();
  233. if ($columns) {
  234. $has_it = 0 ;//是否存在该字段
  235. foreach ($columns as $key => $value) {
  236. if ($value == 'last_update_time') {
  237. $has_it = 1 ;
  238. }
  239. }
  240. if ($has_it === 0) {
  241. $sql = "ALTER TABLE ".C('DB_PREFIX')."item ADD last_update_time INT( 11 ) NOT NULL DEFAULT '0' COMMENT '最后更新时间';";
  242. D("Item")->execute($sql);
  243. }
  244. }
  245. //更改catalog表的order字段名为s_number
  246. $columns = M("Catalog")->getDbFields();
  247. if ($columns) {
  248. foreach ($columns as $key => $value) {
  249. if ($value == 'order') {
  250. $sql = "ALTER TABLE `".C('DB_PREFIX')."catalog` CHANGE `order` `s_number` INT( 10 ) NOT NULL DEFAULT '99' COMMENT '顺序号。数字越小越靠前。若此值全部相等时则按id排序';";
  251. M("Catalog")->execute($sql);
  252. }
  253. }
  254. }
  255. //更改page表的order字段名为s_number
  256. $columns = M("Page")->getDbFields();
  257. if ($columns) {
  258. foreach ($columns as $key => $value) {
  259. if ($value == 'order') {
  260. $sql = "ALTER TABLE `".C('DB_PREFIX')."page` CHANGE `order` `s_number` INT( 10 ) NOT NULL DEFAULT '99' COMMENT '顺序号。数字越小越靠前。若此值全部相等时则按id排序';";
  261. M("Page")->execute($sql);
  262. }
  263. }
  264. }
  265. //更改page_history表的order字段名为s_number
  266. $columns = M("PageHistory")->getDbFields();
  267. if ($columns) {
  268. foreach ($columns as $key => $value) {
  269. if ($value == 'order') {
  270. $sql = "ALTER TABLE `".C('DB_PREFIX')."page_history` CHANGE `order` `s_number` INT( 10 ) NOT NULL DEFAULT '99' COMMENT '顺序号。数字越小越靠前。若此值全部相等时则按id排序';";
  271. M("PageHistory")->execute($sql);
  272. }
  273. }
  274. }
  275. //为catalog表增加addtime索引
  276. $indexs = M("Catalog")->query(" show index from ".C('DB_PREFIX')."catalog");
  277. if ($indexs) {
  278. $has_it = 0 ;//是否存在该索引
  279. foreach ($indexs as $key => $value) {
  280. if ($value['column_name'] =='addtime') {
  281. $has_it = 1 ;
  282. }
  283. }
  284. if ($has_it === 0 ) {
  285. M("Catalog")->execute("ALTER TABLE ".C('DB_PREFIX')."catalog ADD INDEX ( `addtime` ) ;");
  286. }
  287. }
  288. //为item表增加addtime索引
  289. $indexs = M("Item")->query(" show index from ".C('DB_PREFIX')."item");
  290. if ($indexs) {
  291. $has_it = 0 ;//是否存在该索引
  292. foreach ($indexs as $key => $value) {
  293. if ($value['column_name'] =='addtime') {
  294. $has_it = 1 ;
  295. }
  296. }
  297. if ($has_it === 0 ) {
  298. M("Item")->execute("ALTER TABLE ".C('DB_PREFIX')."item ADD INDEX ( `addtime` ) ;");
  299. }
  300. }
  301. //为page表增加addtime索引
  302. $indexs = M("Page")->query(" show index from ".C('DB_PREFIX')."page");
  303. if ($indexs) {
  304. $has_it = 0 ;//是否存在该索引
  305. foreach ($indexs as $key => $value) {
  306. if ($value['column_name'] =='addtime') {
  307. $has_it = 1 ;
  308. }
  309. }
  310. if ($has_it === 0 ) {
  311. M("page")->execute("ALTER TABLE ".C('DB_PREFIX')."page ADD INDEX ( `addtime` ) ;");
  312. }
  313. }
  314. //为page_history表增加addtime索引
  315. $indexs = M("PageHistory")->query(" show index from ".C('DB_PREFIX')."page_history");
  316. if ($indexs) {
  317. $has_it = 0 ;//是否存在该索引
  318. foreach ($indexs as $key => $value) {
  319. if ($value['column_name'] =='addtime') {
  320. $has_it = 1 ;
  321. }
  322. }
  323. if ($has_it === 0 ) {
  324. M("PageHistory")->execute("ALTER TABLE ".C('DB_PREFIX')."page_history ADD INDEX ( `addtime` ) ;");
  325. }
  326. }
  327. //为page_history表增加page_id索引
  328. $indexs = M("PageHistory")->query(" show index from ".C('DB_PREFIX')."page_history");
  329. if ($indexs) {
  330. $has_it = 0 ;//是否存在该索引
  331. foreach ($indexs as $key => $value) {
  332. if ($value['column_name'] =='page_id') {
  333. $has_it = 1 ;
  334. }
  335. }
  336. if ($has_it === 0 ) {
  337. M("PageHistory")->execute("ALTER TABLE ".C('DB_PREFIX')."page_history ADD INDEX ( `page_id` ) ;");
  338. }
  339. }
  340. //catalog表增加parent_cat_id字段
  341. $columns = M("catalog")->getDbFields();
  342. if ($columns) {
  343. $has_it = 0 ;//是否存在该字段
  344. foreach ($columns as $key => $value) {
  345. if ($value == 'parent_cat_id') {
  346. $has_it = 1 ;
  347. }
  348. }
  349. if ($has_it === 0) {
  350. $sql = "ALTER TABLE ".C('DB_PREFIX')."catalog ADD parent_cat_id INT( 10 ) NOT NULL DEFAULT '0' COMMENT '上一级目录的id';";
  351. D("catalog")->execute($sql);
  352. }
  353. }
  354. //catalog表增加level字段
  355. $columns = M("catalog")->getDbFields();
  356. if ($columns) {
  357. $has_it = 0 ;//是否存在该字段
  358. foreach ($columns as $key => $value) {
  359. if ($value == 'level') {
  360. $has_it = 1 ;
  361. }
  362. }
  363. if ($has_it === 0) {
  364. $sql = "ALTER TABLE ".C('DB_PREFIX')."catalog ADD level INT( 10 ) NOT NULL DEFAULT '2' COMMENT '2为二级目录,3为三级目录';";
  365. D("catalog")->execute($sql);
  366. }
  367. }
  368. //item表增加item_domain字段
  369. $columns = M("item")->getDbFields();
  370. if ($columns) {
  371. $has_it = 0 ;//是否存在该字段
  372. foreach ($columns as $key => $value) {
  373. if ($value == 'item_domain') {
  374. $has_it = 1 ;
  375. }
  376. }
  377. if ($has_it === 0) {
  378. $sql = "ALTER TABLE ".C('DB_PREFIX')."item ADD item_domain varchar( 50 ) NOT NULL DEFAULT '' COMMENT 'item的个性域名';";
  379. D("item")->execute($sql);
  380. }
  381. }
  382. $sql = "CREATE TABLE IF NOT EXISTS `".C('DB_PREFIX')."user_token` (
  383. `id` int(10) NOT NULL AUTO_INCREMENT,
  384. `uid` int(10) NOT NULL DEFAULT '0',
  385. `token` varchar(200) NOT NULL DEFAULT '',
  386. `token_expire` int(11) NOT NULL DEFAULT '0' ,
  387. `ip` varchar(200) NOT NULL DEFAULT '',
  388. `addtime` int(11) NOT NULL DEFAULT '0',
  389. PRIMARY KEY (`id`),
  390. KEY `token` (`token`)
  391. ) ENGINE=MyISAM DEFAULT CHARSET=utf8 COMMENT='' AUTO_INCREMENT=1 ";
  392. D("User")->execute($sql);
  393. //创建template表
  394. $sql = "CREATE TABLE IF NOT EXISTS `".C('DB_PREFIX')."template` (
  395. `id` int(10) NOT NULL AUTO_INCREMENT,
  396. `uid` int(10) NOT NULL DEFAULT '0',
  397. `username` varchar(200) NOT NULL DEFAULT '',
  398. `template_title` varchar(200) NOT NULL DEFAULT '' ,
  399. `template_content` text NOT NULL ,
  400. `addtime` int(11) NOT NULL DEFAULT '0',
  401. PRIMARY KEY (`id`),
  402. KEY `uid` (`uid`)
  403. )ENGINE=MyISAM DEFAULT CHARSET=utf8 COMMENT='' AUTO_INCREMENT=1";
  404. D("UserToken")->execute($sql);
  405. //page表增加page_comments字段
  406. $columns = M("Page")->getDbFields();
  407. if ($columns) {
  408. $has_it = 0 ;//是否存在该字段
  409. foreach ($columns as $key => $value) {
  410. if ($value == 'page_comments') {
  411. $has_it = 1 ;
  412. }
  413. }
  414. if ($has_it === 0) {
  415. $sql = "ALTER TABLE ".C('DB_PREFIX')."page ADD page_comments varchar( 255 ) NOT NULL DEFAULT '' COMMENT '页面注释';";
  416. D("Page")->execute($sql);
  417. }
  418. }
  419. //page_history表增加page_comments字段
  420. $columns = M("PageHistory")->getDbFields();
  421. if ($columns) {
  422. $has_it = 0 ;//是否存在该字段
  423. foreach ($columns as $key => $value) {
  424. if ($value == 'page_comments') {
  425. $has_it = 1 ;
  426. }
  427. }
  428. if ($has_it === 0) {
  429. $sql = "ALTER TABLE ".C('DB_PREFIX')."page_history ADD page_comments varchar( 255 ) NOT NULL DEFAULT '' COMMENT '页面注释';";
  430. D("PageHistory")->execute($sql);
  431. }
  432. }
  433. if(D("User")->where("uid = 1 ")->find()){
  434. $db_config = array(
  435. 'DB_TYPE' => 'Sqlite',
  436. 'DB_NAME' => 'Sqlite/showdoc.db.php',
  437. );
  438. M("User")->db(2,$db_config)->where("uid = 1 ")->delete();
  439. }
  440. }
  441. private function _moveTable($table){
  442. $db_config = array(
  443. 'DB_TYPE' => 'Sqlite',
  444. 'DB_NAME' => 'Sqlite/showdoc.db.php',
  445. );
  446. $array = M($table)->select();
  447. if ($array) {
  448. foreach ($array as $key => $value) {
  449. M($table)->db(2,$db_config)->add($value);
  450. }
  451. }
  452. }
  453. }