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

(cherry picked from commit 9a6751301d43b7314a32b0d3d5eb16e3020867bf)
This commit is contained in:
冷冷 committed 2024-08-27 13:13:57 +08:00
1 parent febefc144e
commit b6e685d83a
1 file changed
+8 -3
@@ -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,7 +102,8 @@ public class GenTableServiceImpl extends ServiceImpl<GenTableMapper, GenTable> i
public List<String> queryTableColumn(String dsName, String tableName) {
// 手动切换数据源
DynamicDataSourceContextHolder.push(dsName);
return ServiceProxy.metadata().columns(tableName).values().stream().map(Column::getName).collect(Collectors.toList());
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,7 +154,8 @@ public class GenTableServiceImpl extends ServiceImpl<GenTableMapper, GenTable> i
public List<String> queryTableList(String dsName) {
// 手动切换数据源
DynamicDataSourceContextHolder.push(dsName);
return ServiceProxy.metadata().tables().values().stream().map(Table::getName).collect(Collectors.toList());
CacheProxy.clear();
return ServiceProxy.metadata().tables().values().stream().map(Table::getName).toList();
}
/**
@@ -183,13 +187,14 @@ public class GenTableServiceImpl extends ServiceImpl<GenTableMapper, GenTable> i
}
@Transactional(rollbackFor = Exception.class)
public GenTable tableImport(String dsName, String tableName) {
protected GenTable tableImport(String dsName, String tableName) {
// 手动切换数据源
DynamicDataSourceContextHolder.push(dsName);
// 查询表是否存在
GenTable table = new GenTable();
// 从数据库获取表信息
CacheProxy.clear();
AnylineService service = ServiceProxy.service();
Table tableMetadata = service.metadata().table(tableName);
Database database = service.metadata().database();