diff --git a/src/main/java/com/sondertara/joya/annotation/TableAlias.java b/src/main/java/com/sondertara/joya/annotation/TableAlias.java
index f22db35..9cb9dc3 100644
--- a/src/main/java/com/sondertara/joya/annotation/TableAlias.java
+++ b/src/main/java/com/sondertara/joya/annotation/TableAlias.java
@@ -6,21 +6,16 @@
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
-
/**
* 表别名
*
* @author huangxiaohu
*/
-
@Documented
@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface TableAlias {
- /**
- * 表的别名 数据权限使用,应该与模板查询中的别名一致, 默认: a
- */
- String value() default "a";
-
-}
\ No newline at end of file
+ /** 表的别名 数据权限使用,应该与模板查询中的别名一致, 默认: a */
+ String value() default "a";
+}
diff --git a/src/main/java/com/sondertara/joya/cache/AliasThreadLocalCache.java b/src/main/java/com/sondertara/joya/cache/AliasThreadLocalCache.java
index b49e7bb..e34df37 100644
--- a/src/main/java/com/sondertara/joya/cache/AliasThreadLocalCache.java
+++ b/src/main/java/com/sondertara/joya/cache/AliasThreadLocalCache.java
@@ -1,6 +1,5 @@
package com.sondertara.joya.cache;
-
import com.sondertara.common.exception.TaraException;
import com.sondertara.common.function.TaraFunction;
import com.sondertara.common.lang.Assert;
@@ -26,178 +25,194 @@
/**
* (non-Javadoc)
- *
- * Alias cache based on ThreadLocal
- * Save the relationship of query table name and table alias
+ *
+ *
Alias cache based on ThreadLocal Save the relationship of query table name and table alias
*
* @author huangxiaohu
*/
public final class AliasThreadLocalCache {
- /**
- * The pattern for get part of method
- */
- private static final Pattern GET_PATTERN = Pattern.compile("^get[A-Z].*");
- /**
- * The pattern for set part of method
- */
- private static final Pattern IS_PATTERN = Pattern.compile("^is[A-Z].*");
-
- /**
- * (non-Javadoc)
- * set table alias
- *
- * the table alias will be like t0,t1...
- *
- * @param aClass the entity class
- */
- @SuppressWarnings("unchecked")
- public static void generateTableAlias(Class aClass) {
-
- TableStruct tableStruct = LocalEntityCache.getInstance().get(aClass.getName()).orElseThrow(() -> new TaraException("No entity found with class:{}", aClass.getName()));
- LinkedHashMap aliasMap = (LinkedHashMap) ThreadLocalUtil.get(JOYA_SQL);
-
- TableAlias aliasDTO = new TableAlias();
- aliasDTO.setClassName(aClass.getName());
- aliasDTO.setTableName(tableStruct.getTableName());
- aliasDTO.setAliasName(StringFormatter.format("t{}", aliasMap.size()));
- aliasMap.putIfAbsent(aClass.getName(), aliasDTO);
- }
-
- @SuppressWarnings("unchecked")
- public static void generateTableAlias(String tableAndAlias) {
- Assert.notBlank(tableAndAlias);
- String[] strings = tableAndAlias.split(" ");
-
- LocalEntityCache.getInstance().get(strings[0].toLowerCase()).ifPresent(t -> {
- LinkedHashMap aliasMap = (LinkedHashMap) ThreadLocalUtil.get(JOYA_SQL);
-
- TableAlias aliasDTO = new TableAlias();
- aliasDTO.setClassName(t.getClassName());
- aliasDTO.setTableName(t.getTableName());
- aliasDTO.setAliasName(StringFormatter.format("t{}", aliasMap.size()));
- aliasMap.putIfAbsent(t.getClassName(), aliasDTO);
- });
- }
-
- /**
- * (non-Javadoc)
- * Get the column information
- *
- * @param taraSqlFn the apply function
- * @param generic
- * @return Object contain
- */
- @SuppressWarnings("unchecked")
- public static ColumnAlias getColumn(TaraFunction taraSqlFn) {
- try {
- Method method = taraSqlFn.getClass().getDeclaredMethod("writeReplace");
- method.setAccessible(Boolean.TRUE);
- SerializedLambda serializedLambda = (SerializedLambda) method.invoke(taraSqlFn);
- String implClass = serializedLambda.getImplClass();
- String getter = serializedLambda.getImplMethodName();
-
- String className = implClass.replace("/", ".");
-
- Optional optional = LocalEntityCache.getInstance().get(className);
- // get the field name
- if (GET_PATTERN.matcher(getter).matches()) {
- getter = getter.substring(3);
- } else if (IS_PATTERN.matcher(getter).matches()) {
- getter = getter.substring(2);
- }
- String finalGetter = getter;
- AtomicReference tableName = new AtomicReference<>();
- String columnName = optional.map(tableDTO -> {
- Map map = tableDTO.getFields();
- tableName.set(tableDTO.getTableName());
-
- String fieldName = StringUtils.lowerFirst(finalGetter);
- if (map.containsKey(fieldName)) {
- return map.get(fieldName);
- }
- throw new EntityNotFoundException("No column found by " + finalGetter);
- }).orElseThrow(() -> new EntityNotFoundException("no entity found for " + implClass));
- LinkedHashMap aliasMap = (LinkedHashMap) ThreadLocalUtil.get(JOYA_SQL);
- TableAlias tableAlias = aliasMap.computeIfAbsent(className, k -> {
+ /** The pattern for get part of method */
+ private static final Pattern GET_PATTERN = Pattern.compile("^get[A-Z].*");
+ /** The pattern for set part of method */
+ private static final Pattern IS_PATTERN = Pattern.compile("^is[A-Z].*");
+
+ /**
+ * (non-Javadoc) set table alias
+ *
+ * the table alias will be like t0,t1...
+ *
+ * @param aClass the entity class
+ */
+ @SuppressWarnings("unchecked")
+ public static void generateTableAlias(Class aClass) {
+
+ TableStruct tableStruct =
+ LocalEntityCache.getInstance()
+ .get(aClass.getName())
+ .orElseThrow(
+ () -> new TaraException("No entity found with class:{}", aClass.getName()));
+ LinkedHashMap aliasMap =
+ (LinkedHashMap) ThreadLocalUtil.get(JOYA_SQL);
+
+ TableAlias aliasDTO = new TableAlias();
+ aliasDTO.setClassName(aClass.getName());
+ aliasDTO.setTableName(tableStruct.getTableName());
+ aliasDTO.setAliasName(StringFormatter.format("t{}", aliasMap.size()));
+ aliasMap.putIfAbsent(aClass.getName(), aliasDTO);
+ }
+
+ @SuppressWarnings("unchecked")
+ public static void generateTableAlias(String tableAndAlias) {
+ Assert.notBlank(tableAndAlias);
+ String[] strings = tableAndAlias.split(" ");
+
+ LocalEntityCache.getInstance()
+ .get(strings[0].toLowerCase())
+ .ifPresent(
+ t -> {
+ LinkedHashMap aliasMap =
+ (LinkedHashMap) ThreadLocalUtil.get(JOYA_SQL);
+
+ TableAlias aliasDTO = new TableAlias();
+ aliasDTO.setClassName(t.getClassName());
+ aliasDTO.setTableName(t.getTableName());
+ aliasDTO.setAliasName(StringFormatter.format("t{}", aliasMap.size()));
+ aliasMap.putIfAbsent(t.getClassName(), aliasDTO);
+ });
+ }
+
+ /**
+ * (non-Javadoc) Get the column information
+ *
+ * @param taraSqlFn the apply function
+ * @param generic
+ * @return Object contain
+ */
+ @SuppressWarnings("unchecked")
+ public static ColumnAlias getColumn(TaraFunction taraSqlFn) {
+ try {
+ Method method = taraSqlFn.getClass().getDeclaredMethod("writeReplace");
+ method.setAccessible(Boolean.TRUE);
+ SerializedLambda serializedLambda = (SerializedLambda) method.invoke(taraSqlFn);
+ String implClass = serializedLambda.getImplClass();
+ String getter = serializedLambda.getImplMethodName();
+
+ String className = implClass.replace("/", ".");
+
+ Optional optional = LocalEntityCache.getInstance().get(className);
+ // get the field name
+ if (GET_PATTERN.matcher(getter).matches()) {
+ getter = getter.substring(3);
+ } else if (IS_PATTERN.matcher(getter).matches()) {
+ getter = getter.substring(2);
+ }
+ String finalGetter = getter;
+ AtomicReference tableName = new AtomicReference<>();
+ String columnName =
+ optional
+ .map(
+ tableDTO -> {
+ Map map = tableDTO.getFields();
+ tableName.set(tableDTO.getTableName());
+
+ String fieldName = StringUtils.lowerFirst(finalGetter);
+ if (map.containsKey(fieldName)) {
+ return map.get(fieldName);
+ }
+ throw new EntityNotFoundException("No column found by " + finalGetter);
+ })
+ .orElseThrow(() -> new EntityNotFoundException("no entity found for " + implClass));
+ LinkedHashMap aliasMap =
+ (LinkedHashMap) ThreadLocalUtil.get(JOYA_SQL);
+ TableAlias tableAlias =
+ aliasMap.computeIfAbsent(
+ className,
+ k -> {
TableAlias aliasDTO = new TableAlias();
aliasDTO.setTableName(tableName.get());
aliasDTO.setClassName(className);
aliasDTO.setAliasName(StringFormatter.format("t{}", aliasMap.size()));
return aliasDTO;
- });
- ColumnAlias columnAlias = new ColumnAlias();
- columnAlias.setTableName(tableName.get());
- columnAlias.setColumnName(columnName);
- columnAlias.setTableAlias(tableAlias.getAliasName());
- columnAlias.setColumnAlias(StringFormatter.format("{}.{}", tableAlias.getAliasName(), columnName));
- return columnAlias;
- } catch (ReflectiveOperationException e) {
- throw new TaraException(e);
- }
-
+ });
+ ColumnAlias columnAlias = new ColumnAlias();
+ columnAlias.setTableName(tableName.get());
+ columnAlias.setColumnName(columnName);
+ columnAlias.setTableAlias(tableAlias.getAliasName());
+ columnAlias.setColumnAlias(
+ StringFormatter.format("{}.{}", tableAlias.getAliasName(), columnName));
+ return columnAlias;
+ } catch (ReflectiveOperationException e) {
+ throw new TaraException(e);
}
-
- /**
- * (non-Javadoc)
- * get all relation tables for the query
- *
- * @return Object of table
- */
- @SuppressWarnings("unchecked")
- public static List getTables() {
- LinkedHashMap aliasMap = (LinkedHashMap) ThreadLocalUtil.get(JOYA_SQL);
- return new ArrayList<>(aliasMap.values());
-
+ }
+
+ /**
+ * (non-Javadoc) get all relation tables for the query
+ *
+ * @return Object of table
+ */
+ @SuppressWarnings("unchecked")
+ public static List getTables() {
+ LinkedHashMap aliasMap =
+ (LinkedHashMap) ThreadLocalUtil.get(JOYA_SQL);
+ return new ArrayList<>(aliasMap.values());
+ }
+
+ public static TableStruct getTable(String className) {
+ Optional optional = LocalEntityCache.getInstance().get(className);
+ return optional.orElseThrow(
+ () -> new TaraException("No Table found by className:" + className));
+ }
+
+ /**
+ * 获取数据库中的列明名
+ *
+ * @param column 表别名
+ * @return 列名
+ */
+ public static String getColumnName(String column) {
+
+ if (null == column) {
+ return null;
}
-
- public static TableStruct getTable(String className) {
- Optional optional = LocalEntityCache.getInstance().get(className);
- return optional.orElseThrow(() -> new TaraException("No Table found by className:" + className));
+ int index = column.indexOf(".");
+ if (index < 0) {
+ throw new TaraException("The column is incorrect,it should like 't0.userName.'");
}
-
-
- /**
- * 获取数据库中的列明名
- *
- * @param column 表别名
- * @return 列名
- */
- public static String getColumnName(String column) {
-
- if (null == column) {
- return null;
- }
- int index = column.indexOf(".");
- if (index < 0) {
- throw new TaraException("The column is incorrect,it should like 't0.userName.'");
- }
- String tableAlias = column.substring(0, index);
- String fieldName = column.substring(index + 1);
- String s = null;
- List tables = getTables();
- for (TableAlias table : tables) {
- if (tableAlias.equals(table.getAliasName())) {
- String className = table.getClassName();
- s = LocalEntityCache.getInstance().get(className).map(t -> {
-
- Map fields = t.getFields();
- // if the column is entity field
- if (fields.containsKey(StringUtils.toCamelCase(fieldName))) {
+ String tableAlias = column.substring(0, index);
+ String fieldName = column.substring(index + 1);
+ String s = null;
+ List tables = getTables();
+ for (TableAlias table : tables) {
+ if (tableAlias.equals(table.getAliasName())) {
+ String className = table.getClassName();
+ s =
+ LocalEntityCache.getInstance()
+ .get(className)
+ .map(
+ t -> {
+ Map fields = t.getFields();
+ // if the column is entity field
+ if (fields.containsKey(StringUtils.toCamelCase(fieldName))) {
return fields.get(StringUtils.toCamelCase(fieldName));
- } else {
+ } else {
// if the column is table column
for (String value : fields.values()) {
- if (value.equalsIgnoreCase(StringUtils.toUnderlineCase(fieldName))) {
- return value;
- }
+ if (value.equalsIgnoreCase(StringUtils.toUnderlineCase(fieldName))) {
+ return value;
+ }
}
- }
- throw new TaraException("No column found for table [{}] by name [{}]", table.getTableName(), fieldName);
- }).orElseThrow(() -> new TaraException("No table found by className [{}]", className));
- }
- }
- return StringFormatter.format("{}.{}", tableAlias, s);
+ }
+ throw new TaraException(
+ "No column found for table [{}] by name [{}]",
+ table.getTableName(),
+ fieldName);
+ })
+ .orElseThrow(
+ () -> new TaraException("No table found by className [{}]", className));
+ }
}
-
+ return StringFormatter.format("{}.{}", tableAlias, s);
+ }
}
diff --git a/src/main/java/com/sondertara/joya/cache/LocalEntityCache.java b/src/main/java/com/sondertara/joya/cache/LocalEntityCache.java
index 34c07cd..7605098 100644
--- a/src/main/java/com/sondertara/joya/cache/LocalEntityCache.java
+++ b/src/main/java/com/sondertara/joya/cache/LocalEntityCache.java
@@ -11,80 +11,75 @@
import java.util.List;
import java.util.Optional;
-
/**
* local cache for five min
*
* @author huangxiaohu
*/
-public class LocalEntityCache extends GuavaAbstractLoadingCache implements ILocalCache {
+public class LocalEntityCache extends GuavaAbstractLoadingCache
+ implements ILocalCache {
- private static final Logger log = LoggerFactory.getLogger(LocalEntityCache.class);
+ private static final Logger log = LoggerFactory.getLogger(LocalEntityCache.class);
- private static volatile LocalEntityCache cache = null;
+ private static volatile LocalEntityCache cache = null;
- private LocalEntityCache() {
- setMaximumSize(1000);
- setExpireAfterWriteDuration(60 * 5);
- }
+ private LocalEntityCache() {
+ setMaximumSize(1000);
+ setExpireAfterWriteDuration(60 * 5);
+ }
- private AbstractTableResult tableResult;
+ private AbstractTableResult tableResult;
- public synchronized static LocalEntityCache getInstance() {
+ public static synchronized LocalEntityCache getInstance() {
+ if (null == cache) {
+ synchronized (LocalEntityCache.class) {
if (null == cache) {
- synchronized (LocalEntityCache.class) {
- if (null == cache) {
- cache = new LocalEntityCache();
- cache.setTableResult(new EntityManagerTableResultAdapter());
- }
- }
- }
- return cache;
- }
-
- public void setTableResult(AbstractTableResult tableResult) {
- this.tableResult = tableResult;
- }
-
- @Override
- protected TableStruct fetchData(String key) {
-
- List list = tableResult.load();
- for (TableStruct tableStruct : list) {
- if (tableStruct.getTableName().equalsIgnoreCase(key)) {
- put(tableStruct.getClassName(), tableStruct);
- return tableStruct;
- } else if (tableStruct.getClassName().equalsIgnoreCase(key)) {
- put(tableStruct.getTableName(), tableStruct);
- return tableStruct;
- }
- }
- log.warn("no data to load by key=[{}]", key);
- return null;
-
-
- }
-
- @Override
- public Optional get(String key) {
- TableStruct value = null;
- try {
- value = getValue(key);
- } catch (Exception e) {
- log.error("key={}获取数据异常", key, e);
+ cache = new LocalEntityCache();
+ cache.setTableResult(new EntityManagerTableResultAdapter());
}
- return Optional.ofNullable(value);
+ }
}
-
- @Override
- public void remove(String key) {
- invalidate(key);
-
+ return cache;
+ }
+
+ public void setTableResult(AbstractTableResult tableResult) {
+ this.tableResult = tableResult;
+ }
+
+ @Override
+ protected TableStruct fetchData(String key) {
+
+ List list = tableResult.load();
+ for (TableStruct tableStruct : list) {
+ if (tableStruct.getTableName().equalsIgnoreCase(key)) {
+ put(tableStruct.getClassName(), tableStruct);
+ return tableStruct;
+ } else if (tableStruct.getClassName().equalsIgnoreCase(key)) {
+ put(tableStruct.getTableName(), tableStruct);
+ return tableStruct;
+ }
}
-
-
- public void removeAll() {
- invalidateAll();
-
+ log.warn("no data to load by key=[{}]", key);
+ return null;
+ }
+
+ @Override
+ public Optional get(String key) {
+ TableStruct value = null;
+ try {
+ value = getValue(key);
+ } catch (Exception e) {
+ log.error("key={}获取数据异常", key, e);
}
-}
\ No newline at end of file
+ return Optional.ofNullable(value);
+ }
+
+ @Override
+ public void remove(String key) {
+ invalidate(key);
+ }
+
+ public void removeAll() {
+ invalidateAll();
+ }
+}
diff --git a/src/main/java/com/sondertara/joya/cache/TableClassCache.java b/src/main/java/com/sondertara/joya/cache/TableClassCache.java
index f37ff6a..7823195 100644
--- a/src/main/java/com/sondertara/joya/cache/TableClassCache.java
+++ b/src/main/java/com/sondertara/joya/cache/TableClassCache.java
@@ -26,212 +26,211 @@
/**
* @author skydu
*/
-public class TableClassCache extends GuavaAbstractLoadingCache, Map> implements ILocalCache, Map> {
+public class TableClassCache extends GuavaAbstractLoadingCache, Map>
+ implements ILocalCache, Map> {
- private static volatile TableClassCache cache = null;
-
- private TableClassCache() {
- setMaximumSize(1000);
- setExpireAfterWriteDuration(60 * 60);
- }
+ private static volatile TableClassCache cache = null;
+ private TableClassCache() {
+ setMaximumSize(1000);
+ setExpireAfterWriteDuration(60 * 60);
+ }
- public synchronized static TableClassCache getInstance() {
+ public static synchronized TableClassCache getInstance() {
+ if (null == cache) {
+ synchronized (TableClassCache.class) {
if (null == cache) {
- synchronized (TableClassCache.class) {
- if (null == cache) {
- cache = new TableClassCache();
- }
- }
+ cache = new TableClassCache();
}
- return cache;
+ }
}
-
- /**
- * @return get current classloader
- */
- public static ClassLoader getDefaultClassLoader() {
- ClassLoader cl = null;
+ return cache;
+ }
+
+ /**
+ * @return get current classloader
+ */
+ public static ClassLoader getDefaultClassLoader() {
+ ClassLoader cl = null;
+ try {
+ cl = Thread.currentThread().getContextClassLoader();
+ } catch (Throwable ex) {
+ // Cannot access thread context ClassLoader - falling back...
+ }
+ if (cl == null) {
+ // No thread context class loader -> use class loader of this class.
+ cl = TableClassCache.class.getClassLoader();
+ if (cl == null) {
+ // getClassLoader() returning null indicates the bootstrap ClassLoader
try {
- cl = Thread.currentThread().getContextClassLoader();
+ cl = ClassLoader.getSystemClassLoader();
} catch (Throwable ex) {
- // Cannot access thread context ClassLoader - falling back...
+ // Cannot access system ClassLoader - oh well, maybe the caller can live with
+ // null...
}
- if (cl == null) {
- // No thread context class loader -> use class loader of this class.
- cl = TableClassCache.class.getClassLoader();
- if (cl == null) {
- // getClassLoader() returning null indicates the bootstrap ClassLoader
- try {
- cl = ClassLoader.getSystemClassLoader();
- } catch (Throwable ex) {
- // Cannot access system ClassLoader - oh well, maybe the caller can live with
- // null...
- }
- }
- }
- return cl;
+ }
}
-
- /**
- * 获取类的所有字段(包括父类的)
- *
- * @param clazz class
- * @return field
- */
- public static Map getAllFields(Class clazz) {
- Map fields = Maps.newLinkedHashMap();
- Set filedNames = new HashSet<>();
- for (Class c = clazz; c != Object.class; c = c.getSuperclass()) {
- try {
- Field[] list = c.getDeclaredFields();
- for (Field field : list) {
- String name = field.getName();
- if (filedNames.contains(name)) {
- continue;
- }
- filedNames.add(field.getName());
- fields.put(field.getName(), field);
- }
- } catch (Exception e) {
- throw new TaraException(e);
- }
+ return cl;
+ }
+
+ /**
+ * 获取类的所有字段(包括父类的)
+ *
+ * @param clazz class
+ * @return field
+ */
+ public static Map getAllFields(Class clazz) {
+ Map fields = Maps.newLinkedHashMap();
+ Set filedNames = new HashSet<>();
+ for (Class c = clazz; c != Object.class; c = c.getSuperclass()) {
+ try {
+ Field[] list = c.getDeclaredFields();
+ for (Field field : list) {
+ String name = field.getName();
+ if (filedNames.contains(name)) {
+ continue;
+ }
+ filedNames.add(field.getName());
+ fields.put(field.getName(), field);
}
- return fields;
+ } catch (Exception e) {
+ throw new TaraException(e);
+ }
}
-
-
- /**
- * 获取一个实体类对应数据库字段
- *
- * @param bean java pojo
- * @param the class type of bean
- * @return the table data
- */
- public TableEntity getTable(T bean, boolean readData) {
- Map filedNames = new LinkedHashMap<>();
- Map relation = Maps.newHashMap();
- Class clazz = bean.getClass();
- Table table = clazz.getAnnotation(Table.class);
- String tableName = null;
- if (null != table) {
- tableName = table.name();
- } else {
- Entity entity = clazz.getAnnotation(Entity.class);
- if (null != entity) {
- tableName = entity.name();
- }
- }
- if (null == tableName) {
- throw new TaraException("No [@Table] or [@Entity] annotation found for class->" + clazz);
- }
- TableEntity tableDTO = new TableEntity();
- tableDTO.setTableName(tableName);
- Optional> optional = get(clazz);
- return optional.map(fields -> {
- for (Field field : fields.values()) {
+ return fields;
+ }
+
+ /**
+ * 获取一个实体类对应数据库字段
+ *
+ * @param bean java pojo
+ * @param the class type of bean
+ * @return the table data
+ */
+ public TableEntity getTable(T bean, boolean readData) {
+ Map filedNames = new LinkedHashMap<>();
+ Map relation = Maps.newHashMap();
+ Class clazz = bean.getClass();
+ Table table = clazz.getAnnotation(Table.class);
+ String tableName = null;
+ if (null != table) {
+ tableName = table.name();
+ } else {
+ Entity entity = clazz.getAnnotation(Entity.class);
+ if (null != entity) {
+ tableName = entity.name();
+ }
+ }
+ if (null == tableName) {
+ throw new TaraException("No [@Table] or [@Entity] annotation found for class->" + clazz);
+ }
+ TableEntity tableDTO = new TableEntity();
+ tableDTO.setTableName(tableName);
+ Optional> optional = get(clazz);
+ return optional
+ .map(
+ fields -> {
+ for (Field field : fields.values()) {
if (Modifier.isStatic(field.getModifiers())) {
- continue;
+ continue;
}
- if (field.isAnnotationPresent(Transient.class) || field.isAnnotationPresent(org.springframework.data.annotation.Transient.class)) {
- continue;
+ if (field.isAnnotationPresent(Transient.class)
+ || field.isAnnotationPresent(
+ org.springframework.data.annotation.Transient.class)) {
+ continue;
}
String name = field.getName();
name = StringUtils.toUnderlineCase(name);
Column column = field.getAnnotation(Column.class);
if (null != column) {
- name = column.name();
+ name = column.name();
}
Id id = field.getAnnotation(Id.class);
if (null != id) {
- tableDTO.setPrimaryKey(name);
- tableDTO.setPrimaryKeyType(field.getType());
+ tableDTO.setPrimaryKey(name);
+ tableDTO.setPrimaryKeyType(field.getType());
}
if (filedNames.containsKey(name)) {
- continue;
+ continue;
}
if (readData) {
- try {
- Object o;
- if (field.isAccessible()) {
- o = field.get(bean);
- } else {
- field.setAccessible(true);
- o = field.get(bean);
- field.setAccessible(false);
- }
- filedNames.put(name, o);
- } catch (Exception e) {
- e.printStackTrace();
+ try {
+ Object o;
+ if (field.isAccessible()) {
+ o = field.get(bean);
+ } else {
+ field.setAccessible(true);
+ o = field.get(bean);
+ field.setAccessible(false);
}
+ filedNames.put(name, o);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
}
relation.put(name, field.getName());
-
- }
- tableDTO.setData(filedNames);
- tableDTO.setRelation(relation);
- return tableDTO;
- }).orElseThrow(() -> new TaraException("Get Class definition error"));
-
+ }
+ tableDTO.setData(filedNames);
+ tableDTO.setRelation(relation);
+ return tableDTO;
+ })
+ .orElseThrow(() -> new TaraException("Get Class definition error"));
+ }
+
+ /**
+ * @param clazz
+ * @return the super class
+ */
+ public static Class getSuperClassGenricType(Class clazz) {
+ Type genType = clazz.getGenericSuperclass();
+ if (!(genType instanceof ParameterizedType)) {
+ if (genType instanceof Class) {
+ return getSuperClassGenricType((Class) genType);
+ }
+ return Object.class;
}
-
- /**
- * @param clazz
- * @return the super class
- */
- public static Class getSuperClassGenricType(Class clazz) {
- Type genType = clazz.getGenericSuperclass();
- if (!(genType instanceof ParameterizedType)) {
- if (genType instanceof Class) {
- return getSuperClassGenricType((Class) genType);
- }
- return Object.class;
- }
- Type[] params = ((ParameterizedType) genType).getActualTypeArguments();
- if (params.length == 0) {
- return Object.class;
- }
- return (Class) params[0];
+ Type[] params = ((ParameterizedType) genType).getActualTypeArguments();
+ if (params.length == 0) {
+ return Object.class;
}
-
-
- /**
- * @param clazz the class
- * @param fieldName field name
- * @return the current Field
- */
- public static Field getField(Class clazz, String fieldName) {
- Map map = getAllFields(clazz);
- return map.get(fieldName);
+ return (Class) params[0];
+ }
+
+ /**
+ * @param clazz the class
+ * @param fieldName field name
+ * @return the current Field
+ */
+ public static Field getField(Class clazz, String fieldName) {
+ Map map = getAllFields(clazz);
+ return map.get(fieldName);
+ }
+
+ public static Class classForName(String name) throws ClassNotFoundException {
+ try {
+ ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
+ if (classLoader != null) {
+ return classLoader.loadClass(name);
+ }
+ } catch (Throwable ignore) {
}
-
- public static Class classForName(String name) throws ClassNotFoundException {
- try {
- ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
- if (classLoader != null) {
- return classLoader.loadClass(name);
- }
- } catch (Throwable ignore) {
- }
- return Class.forName(name);
+ return Class.forName(name);
+ }
+
+ @Override
+ protected Map fetchData(Class key) {
+ return getAllFields(key);
+ }
+
+ @Override
+ public Optional> get(Class key) {
+ try {
+ return Optional.ofNullable(getValue(key));
+ } catch (ExecutionException e) {
+ throw new TaraException(e);
}
+ }
- @Override
- protected Map fetchData(Class key) {
- return getAllFields(key);
- }
-
- @Override
- public Optional> get(Class key) {
- try {
- return Optional.ofNullable(getValue(key));
- } catch (ExecutionException e) {
- throw new TaraException(e);
- }
- }
-
- @Override
- public void remove(Class key) {
-
- }
+ @Override
+ public void remove(Class key) {}
}
diff --git a/src/main/java/com/sondertara/joya/core/builder/ExtPartBuilder.java b/src/main/java/com/sondertara/joya/core/builder/ExtPartBuilder.java
index f039cad..97069d0 100644
--- a/src/main/java/com/sondertara/joya/core/builder/ExtPartBuilder.java
+++ b/src/main/java/com/sondertara/joya/core/builder/ExtPartBuilder.java
@@ -11,41 +11,41 @@
*/
public interface ExtPartBuilder extends SetupBuilder {
- /**
- * group by
- *
- * @param groupBySegment param
- * @return the builder
- */
- ExtPartBuilder groupBy(String groupBySegment);
+ /**
+ * group by
+ *
+ * @param groupBySegment param
+ * @return the builder
+ */
+ ExtPartBuilder groupBy(String groupBySegment);
- /**
- * having
- *
- * example:nativeSql.having(h -> h.eq().ne().in())
- *
- * @param func the function
- * @return the builder
- */
- ExtPartBuilder having(UnaryOperator func);
+ /**
+ * having
+ *
+ * example:nativeSql.having(h -> h.eq().ne().in())
+ *
+ * @param func the function
+ * @return the builder
+ */
+ ExtPartBuilder having(UnaryOperator func);
- /**
- * order by with function
- *
- * example: nativeSql.orderBy("su.age asc")
- *
- * @param fn the column function
- * @param orderBy the order type
- * @param the type of table class
- * @return the builder
- */
- ExtPartBuilder orderBy(TaraFunction fn, OrderParam.OrderBy orderBy);
+ /**
+ * order by with function
+ *
+ * example: nativeSql.orderBy("su.age asc")
+ *
+ * @param fn the column function
+ * @param orderBy the order type
+ * @param the type of table class
+ * @return the builder
+ */
+ ExtPartBuilder orderBy(TaraFunction fn, OrderParam.OrderBy orderBy);
- /**
- * order by with string
- *
- * @param orderBySegment order by params
- * @return the builder
- */
- ExtPartBuilder orderBy(String... orderBySegment);
+ /**
+ * order by with string
+ *
+ * @param orderBySegment order by params
+ * @return the builder
+ */
+ ExtPartBuilder orderBy(String... orderBySegment);
}
diff --git a/src/main/java/com/sondertara/joya/core/builder/FromBuilder.java b/src/main/java/com/sondertara/joya/core/builder/FromBuilder.java
index bfe3f3b..ea1378b 100644
--- a/src/main/java/com/sondertara/joya/core/builder/FromBuilder.java
+++ b/src/main/java/com/sondertara/joya/core/builder/FromBuilder.java
@@ -9,34 +9,33 @@
*/
public interface FromBuilder {
- /**
- * sql from part with string
- *
- * @param tableAndJoinTable the sql from segment
- * @return the next builder
- */
- WhereBuilder from(String... tableAndJoinTable);
+ /**
+ * sql from part with string
+ *
+ * @param tableAndJoinTable the sql from segment
+ * @return the next builder
+ */
+ WhereBuilder from(String... tableAndJoinTable);
- /**
- * the table class
- *
- * when use it the table alias will set to default like t0,t1...
- * 根据class获取表，别名为表的顺序t0,t1,t2,t2
- *
- * @param clazz form entity class
- * @return query
- */
- WhereBuilder from(Class... clazz);
+ /**
+ * the table class
+ *
+ *
when use it the table alias will set to default like t0,t1... 根据class获取表，别名为表的顺序t0,t1,t2,t2
+ *
+ * @param clazz form entity class
+ * @return query
+ */
+ WhereBuilder from(Class... clazz);
- /**
- * the table class with join params
- *
- * the limit is only support join tree table,if there is complicated sql query just use the native sql
- * when use it the table alias will set to default like t0,t1...
- * 根据class获取表，别名为表的顺序t0,t1,t2,t2
- *
- * @param func join param
- * @return query
- */
- WhereBuilder from(UnaryOperator func);
-}
\ No newline at end of file
+ /**
+ * the table class with join params
+ *
+ * the limit is only support join tree table,if there is complicated sql query just use the
+ * native sql when use it the table alias will set to default like t0,t1...
+ * 根据class获取表，别名为表的顺序t0,t1,t2,t2
+ *
+ * @param func join param
+ * @return query
+ */
+ WhereBuilder from(UnaryOperator func);
+}
diff --git a/src/main/java/com/sondertara/joya/core/builder/SelectBuilder.java b/src/main/java/com/sondertara/joya/core/builder/SelectBuilder.java
index cdf79d6..f09cbdf 100644
--- a/src/main/java/com/sondertara/joya/core/builder/SelectBuilder.java
+++ b/src/main/java/com/sondertara/joya/core/builder/SelectBuilder.java
@@ -6,123 +6,174 @@
import java.util.function.UnaryOperator;
/**
- * (non-javadoc)
- * the select builder
+ * (non-javadoc) the select builder
*
* @author huangxiaohu
*/
public interface SelectBuilder {
- /**
- * sql select part
- *
- * example: [t0.user_name] or [t0.usr_name AS userName]
- * select 要查询的列 格式为[t0.user_name] 或者[t0.usr_name AS userName]
- *
- * @param columns the query columns
- * @return the next builder
- */
- FromBuilder select(String... columns);
-
- /**
- * sql select part
- *
- * this function will query all columns (select *),you can use {@link #wrapColumn(String...)} together to assign alias
- *
- * 查询表的全部列,对于联表查询 如果字段名字有重复,只保留前面一个字段,可以配置specificS来指定字段别名
- *
- * @return the next builder
- */
- FromBuilder select();
-
- /**
- * the special query column like as alias.
- *
- * 特殊select 字段 搭配select(),指定字段的别名
- *
- * @param selectFields the special column,usually is the column alias
- * @return this builder
- */
- SelectBuilder wrapColumn(String... selectFields);
-
- /**
- * select single column
- * 选择一个字段
- *
- * @param f1 column
- * @param entity
- * @return the next builder
- */
- FromBuilder select(TaraFunction f1);
-
- /**
- * select two column
- *
- * @param f1 column1
- * @param f2 column2
- * @param entity1
- * @param entity2
- * @return query
- */
- FromBuilder select(TaraFunction f1, TaraFunction f2);
-
- /**
- * (non-javadoc)
- */
- FromBuilder select(TaraFunction f1, TaraFunction f2, TaraFunction f3);
-
- /**
- * (non-javadoc)
- */
- FromBuilder select(TaraFunction f1, TaraFunction f2, TaraFunction f3, TaraFunction f4);
-
- /**
- * (non-javadoc)
- */
- FromBuilder select(TaraFunction f1, TaraFunction f2, TaraFunction f3, TaraFunction f4, TaraFunction f5);
-
- /**
- * (non-javadoc)
- */
- FromBuilder select(TaraFunction f1, TaraFunction f2, TaraFunction f3, TaraFunction f4, TaraFunction f5, TaraFunction f6);
-
- /**
- * (non-javadoc)
- */
- FromBuilder select(TaraFunction f1, TaraFunction f2, TaraFunction f3, TaraFunction f4, TaraFunction f5, TaraFunction f6, TaraFunction f7);
-
- /**
- * (non-javadoc)
- */
- FromBuilder select(TaraFunction f1, TaraFunction f2, TaraFunction f3, TaraFunction f4, TaraFunction f5, TaraFunction f6, TaraFunction f7, TaraFunction f8);
-
- /**
- * (non-javadoc)
- */
- FromBuilder select(TaraFunction f1, TaraFunction f2, TaraFunction f3, TaraFunction f4, TaraFunction f5, TaraFunction f6, TaraFunction f7, TaraFunction f8, TaraFunction f9);
-
- /**
- * (non-javadoc)
- */
- FromBuilder select(TaraFunction f1, TaraFunction f2, TaraFunction f3, TaraFunction f4, TaraFunction f5, TaraFunction f6, TaraFunction f7, TaraFunction f8, TaraFunction f9, TaraFunction f10);
-
- /**
- * (non-javadoc)
- */
- FromBuilder select(TaraFunction f1, TaraFunction f2, TaraFunction f3, TaraFunction f4, TaraFunction f5, TaraFunction f6, TaraFunction f7, TaraFunction f8, TaraFunction f9, TaraFunction f10, TaraFunction f11);
-
- /**
- * (non-javadoc)
- */
- FromBuilder select(TaraFunction f1, TaraFunction f2, TaraFunction f3, TaraFunction f4, TaraFunction f5, TaraFunction f6, TaraFunction f7, TaraFunction f8, TaraFunction f9, TaraFunction f10, TaraFunction f11, TaraFunction f12);
-
- /**
- * the lambda select, use {@link #wrapColumn(String...)} (String...)} the resolve alias
- * lambda select 同样冲突字段需要调用specificS()
- *
- * @param func select field
- * @return query
- */
- FromBuilder select(UnaryOperator func);
-
-}
\ No newline at end of file
+ /**
+ * sql select part
+ *
+ * example: [t0.user_name] or [t0.usr_name AS userName] select 要查询的列 格式为[t0.user_name]
+ * 或者[t0.usr_name AS userName]
+ *
+ * @param columns the query columns
+ * @return the next builder
+ */
+ FromBuilder select(String... columns);
+
+ /**
+ * sql select part
+ *
+ *
this function will query all columns (select *),you can use {@link #wrapColumn(String...)}
+ * together to assign alias
+ *
+ *
查询表的全部列,对于联表查询 如果字段名字有重复,只保留前面一个字段,可以配置specificS来指定字段别名
+ *
+ * @return the next builder
+ */
+ FromBuilder select();
+
+ /**
+ * the special query column like as alias.
+ *
+ *
特殊select 字段 搭配select(),指定字段的别名
+ *
+ * @param selectFields the special column,usually is the column alias
+ * @return this builder
+ */
+ SelectBuilder wrapColumn(String... selectFields);
+
+ /**
+ * select single column 选择一个字段
+ *
+ * @param f1 column
+ * @param entity
+ * @return the next builder
+ */
+ FromBuilder select(TaraFunction f1);
+
+ /**
+ * select two column
+ *
+ * @param f1 column1
+ * @param f2 column2
+ * @param entity1
+ * @param entity2
+ * @return query
+ */
+ FromBuilder select(TaraFunction f1, TaraFunction f2);
+
+ /** (non-javadoc) */
+ FromBuilder select(
+ TaraFunction f1, TaraFunction f2, TaraFunction f3);
+
+ /** (non-javadoc) */
+ FromBuilder select(
+ TaraFunction f1,
+ TaraFunction f2,
+ TaraFunction f3,
+ TaraFunction f4);
+
+ /** (non-javadoc) */
+ FromBuilder select(
+ TaraFunction f1,
+ TaraFunction f2,
+ TaraFunction f3,
+ TaraFunction f4,
+ TaraFunction f5);
+
+ /** (non-javadoc) */
+ FromBuilder select(
+ TaraFunction f1,
+ TaraFunction f2,
+ TaraFunction f3,
+ TaraFunction f4,
+ TaraFunction f5,
+ TaraFunction f6);
+
+ /** (non-javadoc) */
+ FromBuilder select(
+ TaraFunction f1,
+ TaraFunction f2,
+ TaraFunction f3,
+ TaraFunction f4,
+ TaraFunction f5,
+ TaraFunction f6,
+ TaraFunction f7);
+
+ /** (non-javadoc) */
+ FromBuilder select(
+ TaraFunction f1,
+ TaraFunction f2,
+ TaraFunction f3,
+ TaraFunction f4,
+ TaraFunction f5,
+ TaraFunction f6,
+ TaraFunction f7,
+ TaraFunction f8);
+
+ /** (non-javadoc) */
+ FromBuilder select(
+ TaraFunction f1,
+ TaraFunction f2,
+ TaraFunction f3,
+ TaraFunction f4,
+ TaraFunction f5,
+ TaraFunction f6,
+ TaraFunction f7,
+ TaraFunction f8,
+ TaraFunction f9);
+
+ /** (non-javadoc) */
+ FromBuilder select(
+ TaraFunction f1,
+ TaraFunction f2,
+ TaraFunction f3,
+ TaraFunction f4,
+ TaraFunction f5,
+ TaraFunction f6,
+ TaraFunction