710 lines
27 KiB
PHP
710 lines
27 KiB
PHP
<?php
|
||
|
||
namespace app\admin\controller\famysql;
|
||
|
||
use app\common\controller\Backend;
|
||
use think\Db;
|
||
use think\Config;
|
||
|
||
/**
|
||
* 字段管理
|
||
*/
|
||
class Field extends Backend
|
||
{
|
||
protected $dbName = '';
|
||
|
||
protected $noNeedRight = ['selectfields', 'getType', 'getSuffix'];
|
||
|
||
public function _initialize()
|
||
{
|
||
parent::_initialize();
|
||
if (!config("app_debug")) {
|
||
$this->error("数据库管理插件只允许在开发环境下使用");
|
||
}
|
||
if (!$this->auth->isSuperAdmin()) {
|
||
$this->error(__('Access is allowed only to the super management group'));
|
||
}
|
||
$this->dbName = Config::get("database.database");
|
||
$this->view->assign("suffixList", $this->getSuffixList());
|
||
}
|
||
|
||
/**
|
||
* 字段首页
|
||
*/
|
||
public function fields()
|
||
{
|
||
$name = $this->request->get('name');
|
||
$is_admin = (int) $this->request->get('is_admin');
|
||
$offset = $this->request->get("offset");
|
||
$limit = $this->request->get("limit");
|
||
if ($name == NULL) {
|
||
$this->error(__('Parameter %s can not be empty', 'name'));
|
||
}
|
||
|
||
$ints = ["int", "tinyint", "smallint", "mediumint", "bigint", "float", "double", "decimal"];
|
||
|
||
if ($this->request->isAjax()) {
|
||
$tableFields = Db::table("information_schema.COLUMNS")->field("*")->where(['TABLE_SCHEMA' => $this->dbName, 'TABLE_NAME' => $name])->select();
|
||
|
||
$list = [];
|
||
foreach ($tableFields as $key => $tableField) {
|
||
$list[$key]['id'] = $tableField['ORDINAL_POSITION'];
|
||
$list[$key]['name'] = $tableField['COLUMN_NAME'];
|
||
$list[$key]['type'] = $tableField['DATA_TYPE'];
|
||
$list[$key]['length'] = $tableField['COLUMN_TYPE'];
|
||
$list[$key]['default'] = $tableField['COLUMN_DEFAULT'];
|
||
$list[$key]['primary_key'] = $tableField['COLUMN_KEY'] == 'PRI' ? 1 : 0;
|
||
$list[$key]['index'] = $tableField['COLUMN_KEY'] == 'MUL' ? 1 : 0;
|
||
$list[$key]['is_null'] = $tableField['IS_NULLABLE'] == 'YES' ? '否' : '是';
|
||
$list[$key]['unsigned'] = strpos($tableField['COLUMN_TYPE'], 'unsigned') !== false ? '是' : (in_array($tableField['DATA_TYPE'], $ints) ? '否' : '-');
|
||
$list[$key]['auto_increment'] = strpos($tableField['EXTRA'], 'auto_increment') !== false ? 1 : 0;
|
||
$list[$key]['comment'] = $tableField['COLUMN_COMMENT'];
|
||
$list[$key]['is_admin'] = $is_admin;
|
||
}
|
||
$result = array("total" => count($list), "rows" => array_slice($list, $offset, $limit));
|
||
return json($result);
|
||
}
|
||
$this->view->assign("name", $name);
|
||
$this->view->assign("is_admin", $is_admin);
|
||
return $this->view->fetch();
|
||
}
|
||
|
||
/**
|
||
* 快速建表
|
||
*/
|
||
public function create()
|
||
{
|
||
$name = $this->request->get('name');
|
||
$is_admin = (int) $this->request->get('is_admin');
|
||
if ($name == NULL) {
|
||
$this->error(__('Parameter %s can not be empty', 'name'));
|
||
}
|
||
|
||
if ($this->request->isPost()) {
|
||
$params = $this->request->post("row/a");
|
||
if ($params) {
|
||
$result = false;
|
||
$sql = "ALTER TABLE `{$name}`";
|
||
$column_name = explode(',', $params['column_name']);
|
||
foreach ($column_name as $column) {
|
||
$sql .= $this->getCommonFields($column);
|
||
}
|
||
$sql = rtrim($sql, ',');
|
||
|
||
Db::startTrans();
|
||
try {
|
||
$result = Db::execute($sql);
|
||
Db::commit();
|
||
|
||
} catch (\think\exception\PDOException $e) {
|
||
Db::rollback();
|
||
$this->error($e->getMessage());
|
||
} catch (\think\Exception $e) {
|
||
Db::rollback();
|
||
$this->error($e->getMessage());
|
||
}
|
||
if ($result !== false) {
|
||
$this->success();
|
||
} else {
|
||
$this->error(__('No rows were inserted'));
|
||
}
|
||
}
|
||
$this->error(__('Parameter %s can not be empty', ''));
|
||
}
|
||
$this->view->assign("name", $name);
|
||
$this->view->assign("is_admin", $is_admin);
|
||
return $this->view->fetch();
|
||
}
|
||
|
||
/**
|
||
* 添加字段
|
||
*/
|
||
public function field_add()
|
||
{
|
||
if ($this->request->isPost()) {
|
||
$name = $this->request->param('name');
|
||
$params = $this->request->post("row/a");
|
||
$column_name = $params['suffix'] == '无' ? $params['name'] : $params['name'] . $params['suffix'];
|
||
if ($params) {
|
||
$result = false;
|
||
$sql = "ALTER TABLE `{$name}` ADD COLUMN `{$column_name}` ";
|
||
Db::startTrans();
|
||
try {
|
||
if (in_array($params['type'], ['enum', 'set'])) {
|
||
$length_arr = json_decode($params['length'], true);
|
||
$default_arr = [];
|
||
foreach ($length_arr as $value) {
|
||
$default_arr[] = $value['vo'];
|
||
}
|
||
$params['length'] = $default_arr;
|
||
}
|
||
$sql .= $this->getFieldSql($column_name, $params);
|
||
|
||
$result = Db::execute($sql);
|
||
Db::commit();
|
||
} catch (\think\exception\PDOException $e) {
|
||
Db::rollback();
|
||
$this->error($e->getMessage());
|
||
} catch (\think\Exception $e) {
|
||
Db::rollback();
|
||
$this->error($e->getMessage());
|
||
}
|
||
if ($result !== false) {
|
||
$this->success();
|
||
} else {
|
||
$this->error(__('No rows were updated'));
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
return $this->view->fetch();
|
||
}
|
||
|
||
/**
|
||
* 修改字段
|
||
*/
|
||
public function field_edit()
|
||
{
|
||
$table = $this->request->param("table");
|
||
if ($table == NULL) {
|
||
$this->error(__('Parameter %s can not be empty', 'table'));
|
||
}
|
||
$field = $this->request->param("field");
|
||
if ($field == NULL) {
|
||
$this->error(__('Parameter %s can not be empty', 'field'));
|
||
}
|
||
|
||
$properties = Db::query("SHOW FULL COLUMNS FROM `{$table}` WHERE Field = '{$field}'");
|
||
|
||
$type_arr = explode(" ", $properties[0]["Type"]);
|
||
$type = strstr($type_arr[0], "(", true) !== false ? strstr($type_arr[0], "(", true) : $type_arr[0];
|
||
$length = preg_match('/\((.*?)\)/', $type_arr[0], $matches) ? $matches[1] : 0;
|
||
|
||
$row['name'] = $properties[0]["Field"];
|
||
$row['type'] = $type;
|
||
$row['collate'] = $properties[0]["Collation"];
|
||
if (in_array($type, ["enum", "set"])) {
|
||
$length_arr = explode(",", $length);
|
||
$length_res = [];
|
||
foreach ($length_arr as $key => $value) {
|
||
preg_match("/\'(.*?)\'/", $value, $matches);
|
||
$length_res[$key]['vo'] = $matches[1];
|
||
}
|
||
$length = json_encode($length_res);
|
||
}
|
||
$row['length'] = $length;
|
||
$row['default'] = $properties[0]["Default"];
|
||
$row['is_null'] = $properties[0]["Null"];
|
||
$row['unsigned'] = in_array("unsigned", $type_arr) ? 1 : 0;
|
||
$row['zerofill'] = in_array("zerofill", $type_arr) ? 1 : 0;
|
||
$row['comment'] = $properties[0]["Comment"];
|
||
|
||
if ($this->request->isPost()) {
|
||
$params = $this->request->post("row/a");
|
||
if ($params) {
|
||
$result = false;
|
||
$sql = "ALTER TABLE `{$table}` MODIFY COLUMN `{$field}` ";
|
||
Db::startTrans();
|
||
try {
|
||
if ($params['name'] !== $row['name']) {
|
||
$sql = "ALTER TABLE `{$table}` CHANGE `{$row['name']}` `{$params['name']}`";
|
||
}
|
||
|
||
if (in_array($params['type'], ['enum', 'set'])) {
|
||
$length_arr = json_decode($params['length'], true);
|
||
$default_arr = [];
|
||
foreach ($length_arr as $value) {
|
||
$default_arr[] = $value['vo'];
|
||
}
|
||
$params['length'] = $default_arr;
|
||
}
|
||
$sql .= $this->getFieldSql($params['name'], $params);
|
||
|
||
// halt($sql);
|
||
|
||
$result = Db::execute($sql);
|
||
Db::commit();
|
||
} catch (\think\exception\PDOException $e) {
|
||
Db::rollback();
|
||
$this->error($e->getMessage());
|
||
} catch (\think\Exception $e) {
|
||
Db::rollback();
|
||
$this->error($e->getMessage());
|
||
}
|
||
if ($result !== false) {
|
||
$this->success();
|
||
} else {
|
||
$this->error(__('No rows were updated'));
|
||
}
|
||
}
|
||
$this->error(__('Parameter %s can not be empty', ''));
|
||
}
|
||
$ints = ["int", "tinyint", "smallint", "mediumint", "bigint", "float", "double", "decimal"];
|
||
|
||
$no_length = ['date', 'datetime', 'time', 'year', "mediumtext", "longtext", "text"];
|
||
|
||
$this->view->assign("row", $row);
|
||
$this->view->assign("is_int", in_array($row['type'], $ints));
|
||
$this->view->assign("is_enum", in_array($row['type'], ['enum', 'set']));
|
||
$this->view->assign("is_length", in_array($row['type'], $no_length));
|
||
return $this->view->fetch();
|
||
}
|
||
|
||
/**
|
||
* 删除
|
||
*/
|
||
public function field_del()
|
||
{
|
||
$table = $this->request->param("table");
|
||
if ($table == NULL) {
|
||
$this->error(__('Parameter %s can not be empty', 'table'));
|
||
}
|
||
$field = $this->request->param("field");
|
||
if ($field == NULL) {
|
||
$this->error(__('Parameter %s can not be empty', 'field'));
|
||
}
|
||
|
||
$result = false;
|
||
Db::startTrans();
|
||
try {
|
||
$sql = "ALTER TABLE `{$table}` DROP COLUMN `{$field}`;";
|
||
$result = Db::execute($sql);
|
||
Db::commit();
|
||
} catch (\think\exception\PDOException $e) {
|
||
Db::rollback();
|
||
$this->error($e->getMessage());
|
||
} catch (\think\Exception $e) {
|
||
Db::rollback();
|
||
$this->error($e->getMessage());
|
||
}
|
||
if ($result !== false) {
|
||
$this->success();
|
||
} else {
|
||
$this->error(__('No rows were deleted'));
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 字段排序
|
||
*/
|
||
public function field_drag()
|
||
{
|
||
$name = $this->request->get('name');
|
||
|
||
if ($name == NULL) {
|
||
$this->error(__('Parameter %s can not be empty', 'name'));
|
||
}
|
||
|
||
$fields = Db::getTableFields($name);
|
||
|
||
//排序的数组
|
||
$ids = $this->request->post("ids");
|
||
//拖动的记录ID
|
||
$changeid = (int) $this->request->post("changeid");
|
||
|
||
$ids = explode(',', $ids);
|
||
|
||
$position = array_search($changeid, $ids);
|
||
switch ($position) {
|
||
case 0:
|
||
if ($ids[array_search($changeid, $ids) + 1] > 1) {
|
||
$changeField = $fields[$changeid - 1];
|
||
$afterField = $fields[$ids[1] - 2];
|
||
$properties = $this->getProperties($name, $changeField);
|
||
$sql = "ALTER TABLE `{$name}` MODIFY COLUMN `{$changeField}` {$properties} AFTER `{$afterField}`";
|
||
} else {
|
||
$afterField = $fields[$changeid - 1];
|
||
$properties = $this->getProperties($name, $afterField);
|
||
$sql = "ALTER TABLE `{$name}` MODIFY COLUMN `{$afterField}` {$properties} FIRST";
|
||
}
|
||
|
||
break;
|
||
default:
|
||
$changeField = $fields[$changeid - 1];
|
||
$afterField = $fields[($ids[array_search($changeid, $ids) - 1] - 1)];
|
||
$properties = $this->getProperties($name, $changeField);
|
||
$sql = "ALTER TABLE `{$name}` MODIFY COLUMN `{$changeField}` {$properties} AFTER `{$afterField}`";
|
||
|
||
}
|
||
$result = false;
|
||
Db::startTrans();
|
||
try {
|
||
$result = Db::execute($sql);
|
||
Db::commit();
|
||
} catch (\think\exception\PDOException $e) {
|
||
Db::rollback();
|
||
$this->error($e->getMessage());
|
||
} catch (\think\Exception $e) {
|
||
Db::rollback();
|
||
$this->error($e->getMessage());
|
||
}
|
||
if ($result !== false) {
|
||
$this->success();
|
||
} else {
|
||
$this->error(__('No rows were updated'));
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 查看
|
||
* @internal
|
||
*/
|
||
public function index()
|
||
{
|
||
$this->error('禁止访问');
|
||
}
|
||
|
||
/**
|
||
* 添加
|
||
* @internal
|
||
*/
|
||
public function add()
|
||
{
|
||
$this->error('禁止访问');
|
||
}
|
||
|
||
/**
|
||
* 编辑
|
||
* @param string $ids
|
||
* @internal
|
||
*/
|
||
public function edit($ids = null)
|
||
{
|
||
$this->error('禁止访问');
|
||
}
|
||
|
||
/**
|
||
* 删除
|
||
* @param string $ids
|
||
* @internal
|
||
*/
|
||
public function del($ids = null)
|
||
{
|
||
$this->error('禁止访问');
|
||
}
|
||
|
||
/**
|
||
* 批量更新
|
||
* @internal
|
||
* @param string $ids
|
||
* @return void
|
||
*/
|
||
public function multi($ids = null)
|
||
{
|
||
$this->error('禁止访问');
|
||
}
|
||
|
||
/**
|
||
* 字段选择
|
||
* @internal
|
||
*/
|
||
public function selectfields()
|
||
{
|
||
//当前页
|
||
$page = $this->request->request("pageNumber");
|
||
//分页大小
|
||
$pagesize = $this->request->request("pageSize");
|
||
|
||
$q_word = (array) $this->request->request("q_word/a");
|
||
|
||
$word = $q_word[0];
|
||
|
||
$custom = (array) $this->request->request("custom/a");
|
||
if ($custom && is_array($custom)) {
|
||
$table = $custom['table'];
|
||
}
|
||
|
||
$fields = $this->getFields($table, ['id']);
|
||
|
||
$commonFields = $this->getCommonFields();
|
||
|
||
$fieldLists = [];
|
||
foreach ($commonFields as $commonField) {
|
||
if (!in_array($commonField['column_name'], $fields)) {
|
||
$fieldLists[] = $commonField;
|
||
}
|
||
}
|
||
if (!empty($word)) {
|
||
$res_arr = [];
|
||
foreach ($fieldLists as $fieldList) {
|
||
$res_arr[] = $fieldList['column_name'] . '-' . $fieldList['comment'];
|
||
}
|
||
$res_arr = array_filter($res_arr, function ($v) use ($word) {
|
||
return stripos($v, $word) !== false;
|
||
});
|
||
$res_arrs = array_values($res_arr);
|
||
|
||
$fieldLists_arr = [];
|
||
foreach ($res_arrs as $res) {
|
||
$fieldLists_arr[] = [
|
||
'column_name' => explode('-', $res)[0],
|
||
'comment' => explode('-', $res)[1]
|
||
];
|
||
}
|
||
$fieldLists = $fieldLists_arr;
|
||
}
|
||
|
||
$result = array("total" => count($fieldLists), "list" => array_slice($fieldLists, ($page - 1) * $pagesize, $pagesize));
|
||
|
||
return json($result);
|
||
|
||
}
|
||
|
||
/**
|
||
* 字段类型
|
||
* @internal
|
||
*/
|
||
public function getType()
|
||
{
|
||
//当前页
|
||
$page = $this->request->request("pageNumber");
|
||
//分页大小
|
||
$pagesize = $this->request->request("pageSize");
|
||
|
||
$q_word = (array) $this->request->request("q_word/a");
|
||
|
||
$word = $q_word ? $q_word[0] : '';
|
||
|
||
$custom = (array) $this->request->request("custom/a");
|
||
$keyValue = $this->request->request('keyValue');
|
||
if (!$keyValue) {
|
||
$suffix = [];
|
||
$type = [];
|
||
if ($custom && is_array($custom)) {
|
||
$suffix = $custom['suffix'];
|
||
$suffixList = $this->getSuffixList($suffix);
|
||
$type = !is_array($suffixList['type']) ? [$suffixList['type']] : $suffixList['type'];
|
||
}
|
||
|
||
$typeList = $this->getTypeList($type);
|
||
$lists = [];
|
||
foreach ($typeList as $v) {
|
||
$lists[] = ['type' => $v];
|
||
}
|
||
if (!empty($word)) {
|
||
$res_arr = [];
|
||
foreach ($lists as $list) {
|
||
$res_arr[] = $list['type'];
|
||
}
|
||
$res_arr = array_filter($res_arr, function ($v) use ($word) {
|
||
return stripos($v, $word) !== false;
|
||
});
|
||
$res_arrs = array_values($res_arr);
|
||
|
||
$lists_arr = [];
|
||
foreach ($res_arrs as $res) {
|
||
$lists_arr[] = [
|
||
'type' => $res,
|
||
];
|
||
}
|
||
$lists = $lists_arr;
|
||
}
|
||
} else {
|
||
$lists[] = ['type' => $keyValue];
|
||
}
|
||
|
||
$result = array("total" => count($lists), "rows" => array_slice($lists, ($page - 1) * $pagesize, $pagesize));
|
||
return json($result);
|
||
}
|
||
|
||
/**
|
||
* 字段后缀
|
||
* @internal
|
||
*/
|
||
public function getSuffix()
|
||
{
|
||
$name = $this->request->request("name");
|
||
$suffix = $this->getSuffixList($name);
|
||
return json($suffix);
|
||
}
|
||
|
||
/**
|
||
* 读取后缀规则
|
||
* @return array
|
||
*/
|
||
protected function getSuffixList($suffix = '')
|
||
{
|
||
$suffixList = [];
|
||
$suffixList['time'] = ["type" => ["bigint", "datetime"], "length" => 16, "default" => NULL, "comment" => '时间', "remark" => '识别为日期时间型数据，自动创建选择时间的组件'];
|
||
$suffixList['image'] = ["type" => ["varchar"], "length" => 255, "default" => '', "comment" => '缩略图', "remark" => '识别为图片文件，自动生成可上传图片的组件，单图'];
|
||
$suffixList['images'] = ["type" => ["varchar"], "length" => 1500, "default" => '', "comment" => '组图', "remark" => '识别为图片文件，自动生成可上传图片的组件，多图'];
|
||
$suffixList['file'] = ["type" => ["varchar"], "length" => 100, "default" => '', "is_null" => 1, "comment" => '附件', "remark" => '识别为普通文件，自动生成可上传文件的组件，单文件'];
|
||
$suffixList['files'] = ["type" => ["varchar"], "length" => 1000, "default" => '', "is_null" => 1, "comment" => '附件', "remark" => '识别为普通文件，自动生成可上传文件的组件，多文件'];
|
||
$suffixList['avatar'] = ["type" => ["varchar"], "length" => 255, "default" => '', "is_null" => 1, "comment" => '头像', "remark" => '识别为头像，自动生成可上传图片的组件，单图'];
|
||
$suffixList['avatars'] = ["type" => ["varchar"], "length" => 1500, "default" => '', "is_null" => 1, "comment" => '头像', "remark" => '识别为头像，自动生成可上传图片的组件，多图'];
|
||
|
||
$suffixList['seconds'] = ["type" => ["int"], "length" => 10, "default" => NULL, "is_null" => 1, "comment" => '时长/分钟'];
|
||
|
||
$suffixList['price'] = ["type" => ["decimal"], "length" => '10,2', "default" => '0.00', "is_null" => 1, 'unsigned' => 1, "comment" => '价格'];
|
||
|
||
$suffixList['content'] = ["type" => ["text", "mediumtext", "longtext"], "is_null" => 1, "comment" => '内容', "remark" => '识别为内容，自动生成富文本编辑器(需安装富文本插件)'];
|
||
|
||
$suffixList['_id'] = ["type" => ["int"], "length" => 10, "default" => 0, "is_null" => 1, "unsigned" => 1, "zerofill" => 0, "comment" => 'ID', "remark" => '识别为关联字段，自动生成可自动完成的文本框，单选'];
|
||
$suffixList['_ids'] = ["type" => ["varchar"], "length" => 100, "default" => '', "comment" => 'ID集合', "remark" => '识别为关联字段，自动生成可自动完成的文本框，多选'];
|
||
|
||
$suffixList['list'] = ["type" => ["enum", "set"], "is_null" => 1, "remark" => ['识别为列表字段，自动生成单选下拉列表', '识别为列表字段，自动生成多选下拉列表']];
|
||
$suffixList['data'] = ["type" => ["enum", "set"], "is_null" => 1, "remark" => ['识别为选项字段，自动生成单选框', '识别为选项字段，自动生成复选框']];
|
||
|
||
if (version_compare(config('fastadmin.version'), '1.3.0', '<')) {
|
||
$suffixList['json'] = ["type" => ["varchar"], "length" => 255, "default" => '', "is_null" => 1, "comment" => '管理员ID', "remark" => '识别为键值组件，自动生成键值录入组件，仅支持1.2.0+'];
|
||
$suffixList['switch'] = ["type" => ["tinyint"], "length" => 1, "default" => 0, "is_null" => 1, "comment" => '开关', "remark" => '识别为开关字段，自动生成开关组件，默认值1为开，0为关，仅支持FastAdmin 1.2.0+'];
|
||
} else {
|
||
$suffixList['range'] = ["type" => ["varchar"], "length" => 100, "default" => '', "is_null" => 1, "comment" => '区间', "remark" => '识别为时间区间组件，自动生成时间区间组件，仅支持FastAdmin 1.3.0+'];
|
||
$suffixList['tag'] = ["type" => ["varchar"], "length" => 255, "default" => '', "is_null" => 1, "comment" => '标签', "remark" => '识别为Tagsinput，自动生成标签输入组件，仅支持FastAdmin 1.3.0+'];
|
||
$suffixList['tags'] = ["type" => ["varchar"], "length" => 255, "default" => '', "is_null" => 1, "comment" => '标签组', "remark" => '识别为Tagsinput，自动生成标签输入组件，仅支持FastAdmin 1.3.0+'];
|
||
}
|
||
return empty($suffix) ? array_keys($suffixList) : $suffixList[$suffix];
|
||
}
|
||
|
||
/**
|
||
* 读取类型规则
|
||
* @return array
|
||
*/
|
||
protected function getTypeList($types = [])
|
||
{
|
||
$typeList = [];
|
||
$sql = "SELECT DISTINCT DATA_TYPE FROM information_schema.COLUMNS";
|
||
$result = Db::query($sql);
|
||
foreach ($result as $key => $value) {
|
||
$typeList[$value['DATA_TYPE']] = $value['DATA_TYPE'];
|
||
if (!empty($types) && !in_array($value['DATA_TYPE'], $types)) {
|
||
unset($typeList[$value['DATA_TYPE']]);
|
||
}
|
||
}
|
||
|
||
return $typeList;
|
||
}
|
||
|
||
public function getCommonFields($fields = '')
|
||
{
|
||
$fieldList = include ADDON_PATH . 'famysql' . DS . 'data' . DS . 'fields.php';
|
||
|
||
$fields = $fields == '' ? [] : explode(',', $fields);
|
||
if (!empty($fields)) {
|
||
$sql = "";
|
||
foreach ($fieldList as $field => $fieldInfo) {
|
||
if (in_array($field, $fields)) {
|
||
$sql .= " ADD COLUMN `{$field}`" . $this->getFieldSql($field, $fieldInfo);
|
||
$sql .= ",";
|
||
}
|
||
}
|
||
return $sql;
|
||
} else {
|
||
$fields = array_keys($fieldList);
|
||
$result = [];
|
||
foreach ($fields as $key => $field) {
|
||
$result[$key] = [
|
||
"column_name" => $field,
|
||
"comment" => isset($fieldList[$field]['comment']) ? $fieldList[$field]['comment'] : ucwords($field)
|
||
];
|
||
}
|
||
return $result;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取表字段属性
|
||
*/
|
||
protected function getProperties($table, $field)
|
||
{
|
||
$all = Db::query("SHOW FULL COLUMNS FROM `{$table}` WHERE Field = '{$field}'");
|
||
|
||
$str = '';
|
||
$str .= "{$all[0]['Type']}";
|
||
|
||
if ($all[0]['Collation'] != NULL) {
|
||
$charset = substr($all[0]['Collation'], 0, strpos($all[0]['Collation'], '_'));
|
||
$str .= " CHARACTER SET {$charset} COLLATE {$all[0]['Collation']}";
|
||
}
|
||
|
||
if ($all[0]['Null'] == 'NO')
|
||
$str .= ' NOT NULL';
|
||
|
||
if ($all[0]['Default'] === '')
|
||
$str .= " DEFAULT ''";
|
||
if ($all[0]['Default'] != NULL && $all[0]['Default'] != '')
|
||
$str .= " DEFAULT '{$all[0]['Default']}'";
|
||
|
||
if ($all[0]['Extra'] == 'auto_increment')
|
||
$str .= ' AUTO_INCREMENT';
|
||
$str .= " Comment '{$all[0]['Comment']}'";
|
||
|
||
return $str;
|
||
}
|
||
|
||
protected function getFieldSql($field, $fieldInfo)
|
||
{
|
||
$sql = "";
|
||
if (isset($fieldInfo['type'])) {
|
||
$sql .= " {$fieldInfo['type']}";
|
||
}
|
||
if (!in_array($fieldInfo['type'], ["enum", "set"]) && isset($fieldInfo['length'])) {
|
||
$sql .= "(" . $fieldInfo['length'] . ")";
|
||
} elseif (in_array($fieldInfo['type'], ["enum", "set"])) {
|
||
$length = "";
|
||
foreach ($fieldInfo['length'] as $value) {
|
||
$length .= "'{$value}',";
|
||
}
|
||
$length = rtrim($length, ",");
|
||
$sql .= "(" . $length . ")";
|
||
}
|
||
if (isset($fieldInfo['unsigned']) && $fieldInfo['unsigned'] == 1) {
|
||
$sql .= " UNSIGNED";
|
||
}
|
||
if (isset($fieldInfo['zerofill']) && $fieldInfo['zerofill'] == 1) {
|
||
$sql .= " ZEROFILL";
|
||
}
|
||
if (isset($fieldInfo['is_null']) && $fieldInfo['is_null'] == 0) {
|
||
$sql .= " NOT NULL";
|
||
}
|
||
if (isset($fieldInfo['default'])) {
|
||
if (in_array($fieldInfo['type'], ["int", "tinyint", "smallint", "mediumint", "bigint"])) {
|
||
if ($fieldInfo['default'] == "") {
|
||
$sql .= "";
|
||
} elseif ($fieldInfo['default'] == 0) {
|
||
$sql .= " DEFAULT 0";
|
||
} else {
|
||
$sql .= empty($fieldInfo['default']) ? "" : " DEFAULT {$fieldInfo['default']}";
|
||
}
|
||
} elseif (in_array($fieldInfo['type'], ["float", "double", "decimal"])) {
|
||
if ($fieldInfo['default'] == "") {
|
||
$sql .= "";
|
||
} elseif ($fieldInfo['default'] == 0) {
|
||
$sql .= " DEFAULT '0.00'";
|
||
} else {
|
||
$sql .= empty($fieldInfo['default']) ? "" : " DEFAULT '{$fieldInfo['default']}'";
|
||
}
|
||
} elseif (in_array($fieldInfo['type'], ["text", "longtext", "mediumtext"])) {
|
||
$sql .= empty($fieldInfo['default']) ? "" : " DEFAULT '{$fieldInfo['default']}'";
|
||
} elseif (in_array($fieldInfo['type'], ["enum", "set"])) {
|
||
$sql .= (empty($fieldInfo['default']) && $fieldInfo['default'] !== '0') ? "" : " DEFAULT '{$fieldInfo['default']}'";
|
||
} else {
|
||
if ($fieldInfo['default'] === '0') {
|
||
$sql .= " DEFAULT '0'";
|
||
} elseif (empty($fieldInfo['default'])) {
|
||
} else {
|
||
$sql .= " DEFAULT '{$fieldInfo['default']}'";
|
||
}
|
||
}
|
||
|
||
}
|
||
$comment = isset($fieldInfo['comment']) ? $fieldInfo['comment'] : ucwords($field);
|
||
$sql .= " COMMENT '{$comment}'";
|
||
|
||
return $sql;
|
||
}
|
||
|
||
protected function getFields($table, $excludeFields = [])
|
||
{
|
||
$fields = Db::getFields($table);
|
||
$result = [];
|
||
foreach ($fields as $field => $fieldInfo) {
|
||
if (!in_array($field, $excludeFields)) {
|
||
$result[] = $field;
|
||
}
|
||
}
|
||
return $result;
|
||
}
|
||
}
|