admin/mybatis-flex
1
0
Fork 0
mirror of https://gitee.com/mybatis-flex/mybatis-flex.git synced 2025-12-08 01:28:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

remove: 移除 TableDef 类。

Browse Source
This commit is contained in:
Suomm 2024-03-11 15:22:44 +08:00
parent 1ea36328ff
commit 999fc959d8
2 changed files with 0 additions and 149 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
mybatis-flex-core/src/main/java/com/mybatisflex/core/table/TableDef.java
View File

@ -1,52 +0,0 @@
/*
* Copyright (c) 2022-2023, Mybatis-Flex (fuhai999@gmail.com).
* <p>
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
* <p>
* http://www.apache.org/licenses/LICENSE-2.0
* <p>
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.mybatisflex.core.table;
import com.mybatisflex.core.query.QueryTable;
import java.io.Serializable;
/**
* @author michael
*/
public class TableDef implements Serializable {
private String schema;
private final String tableName;
public TableDef(String schema, String tableName) {
this.schema = schema;
this.tableName = tableName;
}
public TableDef(String tableName) {
this.tableName = tableName;
}
public String getTableName() {
return tableName;
}
public String getSchema() {
return schema;
}
public QueryTable as(String alias) {
return new QueryTable(schema, tableName, alias);
}
}

97
mybatis-flex-core/src/main/java/com/mybatisflex/core/table/TableDefs.java
View File

@ -1,97 +0,0 @@
/*
* Copyright (c) 2022-2023, Mybatis-Flex (fuhai999@gmail.com).
* <p>
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
* <p>
* http://www.apache.org/licenses/LICENSE-2.0
* <p>
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.mybatisflex.core.table;
import com.mybatisflex.core.query.QueryColumn;
import com.mybatisflex.core.util.ClassUtil;
import com.mybatisflex.core.util.StringUtil;
import org.apache.ibatis.io.ResolverUtil;
import java.io.Serializable;
import java.lang.reflect.Field;
import java.lang.reflect.Modifier;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* @author michael
*/
public class TableDefs implements Serializable {
private static final Map<String, TableDef> TABLE_DEF_MAP = new HashMap<>();
private static final Map<String, Map<String, QueryColumn>> QUERY_COLUMN_MAP = new HashMap<>();
public static void init(String packageName) {
ResolverUtil<Class<?>> resolverUtil = new ResolverUtil<>();
resolverUtil.find(new ResolverUtil.IsA(TableDef.class), packageName);
Set<Class<? extends Class<?>>> typeSet = resolverUtil.getClasses();
for (Class<?> type : typeSet) {
if (!type.isAnonymousClass() && !type.isInterface() && !type.isMemberClass()) {
try {
registerTableDef(type);
} catch (IllegalAccessException e) {
e.printStackTrace();
}
}
}
}
public static TableDef getTableDef(Class<?> entityClass, String tableNameWithSchema) {
TableDef tableDef = TABLE_DEF_MAP.get(tableNameWithSchema);
if (tableDef == null) {
init(entityClass.getPackage().getName());
tableDef = TABLE_DEF_MAP.get(tableNameWithSchema);
}
return tableDef;
}
public static QueryColumn getQueryColumn(Class<?> entityClass, String tableNameWithSchema, String column) {
Map<String, QueryColumn> queryColumnMap = QUERY_COLUMN_MAP.get(tableNameWithSchema);
if (queryColumnMap == null) {
init(entityClass.getPackage().getName());
queryColumnMap = QUERY_COLUMN_MAP.get(tableNameWithSchema);
}
return queryColumnMap != null ? queryColumnMap.get(column) : null;
}
public static void registerTableDef(Class<?> tableDefClass) throws IllegalAccessException {
TableDef tableDef = (TableDef) ClassUtil.getFirstField(tableDefClass, field -> {
int mod = Modifier.fieldModifiers();
return Modifier.isPublic(mod) && Modifier.isStatic(mod);
}).get(null);
String key = StringUtil.buildSchemaWithTable(tableDef.getSchema(), tableDef.getTableName());
TABLE_DEF_MAP.put(key, tableDef);
List<Field> allFields = ClassUtil.getAllFields(tableDef.getClass(), field -> field.getType() == QueryColumn.class);
Map<String, QueryColumn> columnMap = new HashMap<>(allFields.size());
for (Field field : allFields) {
QueryColumn queryColumn = (QueryColumn) field.get(tableDef);
columnMap.put(queryColumn.getName(), queryColumn);
}
QUERY_COLUMN_MAP.put(key, columnMap);
}
}