Browse Source

update

pull/47/head
xiaoz 3 years ago
parent
commit
fdf3f7da58
  1. 30
      class/Api.php
  2. 2
      db/sql/on_db_logs.sql

30
class/Api.php

@ -666,6 +666,25 @@ class Api {
"data" => ['on_db_logs'] "data" => ['on_db_logs']
]; ];
exit(json_encode($data)); exit(json_encode($data));
}else{
//如果不为0,则需要进行比对
$get_on_db_logs = $this->db->select("on_db_logs",[
"sql_name"
],[
"status" => "TRUE"
]);
//声明一个空数组,存储已更新的数据库
$already_dbs = [];
foreach ($get_on_db_logs as $key => $value) {
array_push($already_dbs,$value['sql_name']);
}
//array_diff() 函数返回两个数组的差集数组
$diff_result = array_diff($sql_files_all,$already_dbs);
$data = [
"code" => 0,
"data" => $diff_result
];
exit(json_encode($data));
} }
} }
@ -687,12 +706,23 @@ class Api {
$result = $this->db->query($sql_content); $result = $this->db->query($sql_content);
//如果SQL执行成功,则返回 //如果SQL执行成功,则返回
if( $result ) { if( $result ) {
//将更新信息写入数据库
$insert_re = $this->db->insert("on_db_logs",[
"sql_name" => $name.'.sql',
"update_time" => time()
]);
if( $insert_re ) {
$data = [ $data = [
"code" => 0, "code" => 0,
"data" => $name.".sql更新完成!" "data" => $name.".sql更新完成!"
]; ];
exit(json_encode($data)); exit(json_encode($data));
} }
else {
$this->err_msg(-2000,$name.".sql更新失败,请人工检查!");
}
}
else{ else{
//如果执行失败 //如果执行失败
$this->err_msg(-2000,$name.".sql更新失败,请人工检查!"); $this->err_msg(-2000,$name.".sql更新失败,请人工检查!");

2
db/sql/on_db_logs.sql

@ -4,7 +4,7 @@ CREATE TABLE on_db_logs (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT, id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
sql_name TEXT(32) NOT NULL, sql_name TEXT(32) NOT NULL,
update_time NUMERIC NOT NULL, update_time NUMERIC NOT NULL,
status TEXT(5) DEFAULT true NOT NULL, status TEXT(5) DEFAULT "TRUE" NOT NULL,
extra TEXT(512), extra TEXT(512),
CONSTRAINT on_db_logs_UN UNIQUE (sql_name) CONSTRAINT on_db_logs_UN UNIQUE (sql_name)
); );

Loading…
Cancel
Save