fix(代码生成): 数据库表、字段缓存元数据不更新

(cherry picked from commit 9a6751301d43b7314a32b0d3d5eb16e3020867bf)
This commit is contained in:
冷冷 committed 2024-08-27 13:09:47 +08:00
1 parent b87a0839e0
commit 43fed57a86
1 file changed
+5
@@ -42,6 +42,7 @@ import lombok.RequiredArgsConstructor;
import org.anyline.metadata.Column;
import org.anyline.metadata.Database;
import org.anyline.metadata.Table;
import org.anyline.proxy.CacheProxy;
import org.anyline.proxy.ServiceProxy;
import org.anyline.service.AnylineService;
import org.jetbrains.annotations.NotNull;
@@ -101,6 +102,7 @@ public class GenTableServiceImpl extends ServiceImpl<GenTableMapper, GenTable> i
public List<String> queryTableColumn(String dsName, String tableName) {
// 手动切换数据源
DynamicDataSourceContextHolder.push(dsName);
CacheProxy.clear();
return ServiceProxy.metadata().columns(tableName).values().stream().map(Column::getName).toList();
}
@@ -115,6 +117,7 @@ public class GenTableServiceImpl extends ServiceImpl<GenTableMapper, GenTable> i
public IPage queryTablePage(Page<Table> page, GenTable table) {
// 手动切换数据源
DynamicDataSourceContextHolder.push(table.getDsName());
CacheProxy.clear();
List<Table> tableList = ServiceProxy.metadata().tables()
.values().stream().filter(t -> {
if (StrUtil.isBlank(table.getTableName())) {
@@ -151,6 +154,7 @@ public class GenTableServiceImpl extends ServiceImpl<GenTableMapper, GenTable> i
public List<String> queryTableList(String dsName) {
// 手动切换数据源
DynamicDataSourceContextHolder.push(dsName);
CacheProxy.clear();
return ServiceProxy.metadata().tables().values().stream().map(Table::getName).toList();
}
@@ -190,6 +194,7 @@ public class GenTableServiceImpl extends ServiceImpl<GenTableMapper, GenTable> i
// 查询表是否存在
GenTable table = new GenTable();
// 从数据库获取表信息
CacheProxy.clear();
AnylineService service = ServiceProxy.service();
Table tableMetadata = service.metadata().table(tableName);
Database database = service.metadata().database();