|
@@ -125,212 +125,192 @@ public abstract class BaseServiceImpl<PK extends Serializable, T> implements Bas
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
- @Override
|
|
|
|
- public <K extends Collection, Y, Z> Map<Y,Z> getMap(String tableName, String columnKey, String columnValue, K ids,Integer tenantId, Class<Y> keyType, Class<Z> valueType){
|
|
|
|
- if(CollectionUtils.isEmpty(ids)){
|
|
|
|
- return Collections.emptyMap();
|
|
|
|
- }
|
|
|
|
- StringBuffer sql=new StringBuffer();
|
|
|
|
- Map<Y,Z> result=new HashMap();
|
|
|
|
- SqlSession sqlSession = null;
|
|
|
|
- Connection connection = null;
|
|
|
|
- PreparedStatement ps = null;
|
|
|
|
- try {
|
|
|
|
- sqlSession = sqlSessionFactory.openSession();
|
|
|
|
- connection = sqlSession.getConnection();
|
|
|
|
- sql.append("SELECT ").append(columnKey).append(",").append(columnValue).append(" FROM ").append(tableName).append(" WHERE ").append(columnKey).append(" IN (").append(StringUtils.join(ids, ",")).append(")");
|
|
|
|
- if(tenantId != null){
|
|
|
|
- sql.append(" AND tenant_id_ = ").append(tenantId);
|
|
|
|
- }
|
|
|
|
- ps = connection.prepareStatement(sql.toString());
|
|
|
|
- ResultSet resultSet = ps.executeQuery();
|
|
|
|
- while (resultSet.next()){
|
|
|
|
- Y key;
|
|
|
|
- Z value;
|
|
|
|
- if(keyType.isAssignableFrom(BigDecimal.class)){
|
|
|
|
- key = (Y) BigDecimal.class.getDeclaredConstructor(String.class).newInstance(resultSet.getString(1));
|
|
|
|
- }else if(keyType.isAssignableFrom(String.class)){
|
|
|
|
- key = (Y) resultSet.getString(1);
|
|
|
|
- }else{
|
|
|
|
- key = (Y) keyType.getMethod("valueOf", String.class).invoke(null,resultSet.getString(1));
|
|
|
|
- }
|
|
|
|
- if(valueType.isAssignableFrom(BigDecimal.class)){
|
|
|
|
- value = (Z) BigDecimal.class.getDeclaredConstructor(String.class).newInstance(resultSet.getString(2));
|
|
|
|
- }else if(valueType.isAssignableFrom(String.class)){
|
|
|
|
- value = (Z) resultSet.getString(2);
|
|
|
|
- }else{
|
|
|
|
- value = (Z) valueType.getMethod("valueOf", String.class).invoke(null,resultSet.getString(2));
|
|
|
|
- }
|
|
|
|
- result.put(key, value);
|
|
|
|
- }
|
|
|
|
- if(resultSet!=null){
|
|
|
|
- resultSet.close();
|
|
|
|
- }
|
|
|
|
- if(ps!=null){
|
|
|
|
- ps.close();
|
|
|
|
- }
|
|
|
|
- if(sqlSession!=null){
|
|
|
|
- sqlSession.close();
|
|
|
|
- }
|
|
|
|
- } catch (Exception e) {
|
|
|
|
- e.printStackTrace();
|
|
|
|
- } finally {
|
|
|
|
- if(ps!=null){
|
|
|
|
- try {
|
|
|
|
- ps.close();
|
|
|
|
- } catch (SQLException e) {
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
- if(sqlSession!=null){
|
|
|
|
- sqlSession.close();
|
|
|
|
- }
|
|
|
|
- if(connection!=null){
|
|
|
|
- try {
|
|
|
|
- connection.close();
|
|
|
|
- } catch (SQLException e) {
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
|
|
+ @Override
|
|
|
|
+ public <K extends Collection, Y, Z> Map<Y,Z> getMap(String tableName, String columnKey, String columnValue, K ids,Integer tenantId, Class<Y> keyType, Class<Z> valueType){
|
|
|
|
+ if(CollectionUtils.isEmpty(ids)){
|
|
|
|
+ return Collections.emptyMap();
|
|
|
|
+ }
|
|
|
|
+ StringBuffer sql=new StringBuffer();
|
|
|
|
+ Map<Y,Z> result=new HashMap();
|
|
|
|
+ SqlSession sqlSession = null;
|
|
|
|
+ Connection connection = null;
|
|
|
|
+ PreparedStatement ps = null;
|
|
|
|
+ ResultSet resultSet = null;
|
|
|
|
+ try {
|
|
|
|
+ sqlSession = sqlSessionFactory.openSession();
|
|
|
|
+ connection = sqlSession.getConnection();
|
|
|
|
+ sql.append("SELECT ").append(columnKey).append(",").append(columnValue).append(" FROM ").append(tableName).append(" WHERE ").append(columnKey).append(" IN (").append(StringUtils.join(ids, ",")).append(")");
|
|
|
|
+ if(tenantId != null){
|
|
|
|
+ sql.append(" AND tenant_id_ = ").append(tenantId);
|
|
|
|
+ }
|
|
|
|
+ ps = connection.prepareStatement(sql.toString());
|
|
|
|
+ resultSet = ps.executeQuery();
|
|
|
|
+ while (resultSet.next()){
|
|
|
|
+ Y key;
|
|
|
|
+ Z value;
|
|
|
|
+ if(keyType.isAssignableFrom(BigDecimal.class)){
|
|
|
|
+ key = (Y) BigDecimal.class.getDeclaredConstructor(String.class).newInstance(resultSet.getString(1));
|
|
|
|
+ }else if(keyType.isAssignableFrom(String.class)){
|
|
|
|
+ key = (Y) resultSet.getString(1);
|
|
|
|
+ }else{
|
|
|
|
+ key = (Y) keyType.getMethod("valueOf", String.class).invoke(null,resultSet.getString(1));
|
|
|
|
+ }
|
|
|
|
+ if(valueType.isAssignableFrom(BigDecimal.class)){
|
|
|
|
+ value = (Z) BigDecimal.class.getDeclaredConstructor(String.class).newInstance(resultSet.getString(2));
|
|
|
|
+ }else if(valueType.isAssignableFrom(String.class)){
|
|
|
|
+ value = (Z) resultSet.getString(2);
|
|
|
|
+ }else{
|
|
|
|
+ value = (Z) valueType.getMethod("valueOf", String.class).invoke(null,resultSet.getString(2));
|
|
|
|
+ }
|
|
|
|
+ result.put(key, value);
|
|
|
|
+ }
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
+ e.printStackTrace();
|
|
|
|
+ }finally {
|
|
|
|
+ if(resultSet!=null){
|
|
|
|
+ try {
|
|
|
|
+ resultSet.close();
|
|
|
|
+ } catch (SQLException e) {
|
|
|
|
+ e.printStackTrace();
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if(ps!=null){
|
|
|
|
+ try {
|
|
|
|
+ ps.close();
|
|
|
|
+ } catch (SQLException e) {
|
|
|
|
+ e.printStackTrace();
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if(sqlSession!=null){
|
|
|
|
+ sqlSession.close();
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
|
|
return result;
|
|
return result;
|
|
}
|
|
}
|
|
|
|
|
|
- @Override
|
|
|
|
- public <K extends List, Y, Z> Map<Y,Z> getMap(String tableName, String columnKey, String columnValue, String ids, Class<Y> keyType, Class<Z> valueType){
|
|
|
|
- if(StringUtils.isEmpty(ids)){
|
|
|
|
- return Collections.emptyMap();
|
|
|
|
- }
|
|
|
|
- StringBuffer sql=new StringBuffer();
|
|
|
|
- Map<Y,Z> result=new HashMap();
|
|
|
|
-
|
|
|
|
- SqlSession sqlSession = null;
|
|
|
|
- Connection connection = null;
|
|
|
|
- PreparedStatement ps = null;
|
|
|
|
- try {
|
|
|
|
- sqlSession = sqlSessionFactory.openSession();
|
|
|
|
- connection = sqlSession.getConnection();
|
|
|
|
- sql.append("SELECT ").append(columnKey).append(",").append(columnValue).append(" FROM ").append(tableName).append(" WHERE ").append(columnKey).append(" IN (").append(ids).append(")");
|
|
|
|
- ps = connection.prepareStatement(sql.toString());
|
|
|
|
- ResultSet resultSet = ps.executeQuery();
|
|
|
|
- while (resultSet.next()){
|
|
|
|
- Y key;
|
|
|
|
- Z value;
|
|
|
|
- if(keyType.isAssignableFrom(BigDecimal.class)){
|
|
|
|
- key = (Y) BigDecimal.class.getDeclaredConstructor(String.class).newInstance(resultSet.getString(1));
|
|
|
|
- }else if(keyType.isAssignableFrom(String.class)){
|
|
|
|
- key = (Y) resultSet.getString(1);
|
|
|
|
- }else{
|
|
|
|
- key = (Y) keyType.getMethod("valueOf", String.class).invoke(null,resultSet.getString(1));
|
|
|
|
- }
|
|
|
|
- if(valueType.isAssignableFrom(BigDecimal.class)){
|
|
|
|
- value = (Z) BigDecimal.class.getDeclaredConstructor(String.class).newInstance(resultSet.getString(2));
|
|
|
|
- }else if(valueType.isAssignableFrom(String.class)){
|
|
|
|
- value = (Z) resultSet.getString(2);
|
|
|
|
- }else{
|
|
|
|
- value = (Z) valueType.getMethod("valueOf", String.class).invoke(null,resultSet.getString(2));
|
|
|
|
- }
|
|
|
|
- result.put(key, value);
|
|
|
|
- }
|
|
|
|
- if(resultSet!=null){
|
|
|
|
- resultSet.close();
|
|
|
|
- }
|
|
|
|
- if(ps!=null){
|
|
|
|
- ps.close();
|
|
|
|
- }
|
|
|
|
- if(sqlSession!=null){
|
|
|
|
- sqlSession.close();
|
|
|
|
- }
|
|
|
|
- } catch (Exception e) {
|
|
|
|
- e.printStackTrace();
|
|
|
|
- }finally {
|
|
|
|
- if(ps!=null){
|
|
|
|
- try {
|
|
|
|
- ps.close();
|
|
|
|
- } catch (SQLException e) {
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
- if(sqlSession!=null){
|
|
|
|
- sqlSession.close();
|
|
|
|
- }
|
|
|
|
- if(connection!=null){
|
|
|
|
- try {
|
|
|
|
- connection.close();
|
|
|
|
- } catch (SQLException e) {
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
|
|
+ @Override
|
|
|
|
+ public <K extends List, Y, Z> Map<Y,Z> getMap(String tableName, String columnKey, String columnValue, String ids, Class<Y> keyType, Class<Z> valueType){
|
|
|
|
+ if(StringUtils.isEmpty(ids)){
|
|
|
|
+ return Collections.emptyMap();
|
|
|
|
+ }
|
|
|
|
+ StringBuffer sql=new StringBuffer();
|
|
|
|
+ Map<Y,Z> result=new HashMap();
|
|
|
|
+ SqlSession sqlSession = null;
|
|
|
|
+ Connection connection = null;
|
|
|
|
+ PreparedStatement ps = null;
|
|
|
|
+ ResultSet resultSet = null;
|
|
|
|
+ try {
|
|
|
|
+ sqlSession = sqlSessionFactory.openSession();
|
|
|
|
+ connection = sqlSession.getConnection();
|
|
|
|
+ sql.append("SELECT ").append(columnKey).append(",").append(columnValue).append(" FROM ").append(tableName).append(" WHERE ").append(columnKey).append(" IN (").append(ids).append(")");
|
|
|
|
+ ps = connection.prepareStatement(sql.toString());
|
|
|
|
+ resultSet = ps.executeQuery();
|
|
|
|
+ while (resultSet.next()){
|
|
|
|
+ Y key;
|
|
|
|
+ Z value;
|
|
|
|
+ if(keyType.isAssignableFrom(BigDecimal.class)){
|
|
|
|
+ key = (Y) BigDecimal.class.getDeclaredConstructor(String.class).newInstance(resultSet.getString(1));
|
|
|
|
+ }else if(keyType.isAssignableFrom(String.class)){
|
|
|
|
+ key = (Y) resultSet.getString(1);
|
|
|
|
+ }else{
|
|
|
|
+ key = (Y) keyType.getMethod("valueOf", String.class).invoke(null,resultSet.getString(1));
|
|
|
|
+ }
|
|
|
|
+ if(valueType.isAssignableFrom(BigDecimal.class)){
|
|
|
|
+ value = (Z) BigDecimal.class.getDeclaredConstructor(String.class).newInstance(resultSet.getString(2));
|
|
|
|
+ }else if(valueType.isAssignableFrom(String.class)){
|
|
|
|
+ value = (Z) resultSet.getString(2);
|
|
|
|
+ }else{
|
|
|
|
+ value = (Z) valueType.getMethod("valueOf", String.class).invoke(null,resultSet.getString(2));
|
|
|
|
+ }
|
|
|
|
+ result.put(key, value);
|
|
|
|
+ }
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
+ e.printStackTrace();
|
|
|
|
+ }finally {
|
|
|
|
+ if(resultSet!=null){
|
|
|
|
+ try {
|
|
|
|
+ resultSet.close();
|
|
|
|
+ } catch (SQLException e) {
|
|
|
|
+ e.printStackTrace();
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if(ps!=null){
|
|
|
|
+ try {
|
|
|
|
+ ps.close();
|
|
|
|
+ } catch (SQLException e) {
|
|
|
|
+ e.printStackTrace();
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if(sqlSession!=null){
|
|
|
|
+ sqlSession.close();
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
|
|
return result;
|
|
return result;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
- @Override
|
|
|
|
- public <K extends List, Y, Z> Map<Y,Z> getMap(String tableName, String columnKey, String columnValue,Boolean hasDelFlag,Integer tenantId, Class<Y> keyType, Class<Z> valueType){
|
|
|
|
- StringBuffer sql=new StringBuffer();
|
|
|
|
- Map<Y,Z> result=new HashMap();
|
|
|
|
-
|
|
|
|
- SqlSession sqlSession = null;
|
|
|
|
- Connection connection = null;
|
|
|
|
- PreparedStatement ps = null;
|
|
|
|
- try {
|
|
|
|
- sqlSession = sqlSessionFactory.openSession();
|
|
|
|
- connection = sqlSession.getConnection();
|
|
|
|
- sql.append("SELECT ").append(columnKey).append(",").append(columnValue).append(" FROM ").append(tableName).append(" WHERE 1 = 1");
|
|
|
|
- if(hasDelFlag){
|
|
|
|
- sql.append(" AND del_flag_ = 0");
|
|
|
|
- }
|
|
|
|
- if(tenantId != null){
|
|
|
|
- sql.append(" AND tenant_id_ = ").append(tenantId);
|
|
|
|
- }
|
|
|
|
- ps = connection.prepareStatement(sql.toString());
|
|
|
|
- ResultSet resultSet = ps.executeQuery();
|
|
|
|
- while (resultSet.next()){
|
|
|
|
- Y key;
|
|
|
|
- Z value;
|
|
|
|
- if(keyType.isAssignableFrom(BigDecimal.class)){
|
|
|
|
- key = (Y) BigDecimal.class.getDeclaredConstructor(String.class).newInstance(resultSet.getString(1));
|
|
|
|
- }else if(keyType.isAssignableFrom(String.class)){
|
|
|
|
- key = (Y) resultSet.getString(1);
|
|
|
|
- }else{
|
|
|
|
- key = (Y) keyType.getMethod("valueOf", String.class).invoke(null,resultSet.getString(1));
|
|
|
|
- }
|
|
|
|
- if(valueType.isAssignableFrom(BigDecimal.class)){
|
|
|
|
- value = (Z) BigDecimal.class.getDeclaredConstructor(String.class).newInstance(resultSet.getString(2));
|
|
|
|
- }else if(valueType.isAssignableFrom(String.class)){
|
|
|
|
- value = (Z) resultSet.getString(2);
|
|
|
|
- }else{
|
|
|
|
- value = (Z) valueType.getMethod("valueOf", String.class).invoke(null,resultSet.getString(2));
|
|
|
|
- }
|
|
|
|
- result.put(key, value);
|
|
|
|
- }
|
|
|
|
- if(resultSet!=null){
|
|
|
|
- resultSet.close();
|
|
|
|
- }
|
|
|
|
- if(ps!=null){
|
|
|
|
- ps.close();
|
|
|
|
- }
|
|
|
|
- if(sqlSession!=null){
|
|
|
|
- sqlSession.close();
|
|
|
|
- }
|
|
|
|
- } catch (Exception e) {
|
|
|
|
- e.printStackTrace();
|
|
|
|
- }finally {
|
|
|
|
- if(ps!=null){
|
|
|
|
- try {
|
|
|
|
- ps.close();
|
|
|
|
- } catch (SQLException e) {
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
- if(sqlSession!=null){
|
|
|
|
- sqlSession.close();
|
|
|
|
- }
|
|
|
|
- if(connection!=null){
|
|
|
|
- try {
|
|
|
|
- connection.close();
|
|
|
|
- } catch (SQLException e) {
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
|
|
+ @Override
|
|
|
|
+ public <K extends List, Y, Z> Map<Y,Z> getMap(String tableName, String columnKey, String columnValue,Boolean hasDelFlag,Integer tenantId, Class<Y> keyType, Class<Z> valueType){
|
|
|
|
+ StringBuffer sql=new StringBuffer();
|
|
|
|
+ Map<Y,Z> result=new HashMap();
|
|
|
|
+ SqlSession sqlSession = null;
|
|
|
|
+ Connection connection = null;
|
|
|
|
+ PreparedStatement ps = null;
|
|
|
|
+ ResultSet resultSet = null;
|
|
|
|
+ try {
|
|
|
|
+ sqlSession = sqlSessionFactory.openSession();
|
|
|
|
+ connection = sqlSession.getConnection();
|
|
|
|
+ sql.append("SELECT ").append(columnKey).append(",").append(columnValue).append(" FROM ").append(tableName).append(" WHERE 1 = 1");
|
|
|
|
+ if(hasDelFlag){
|
|
|
|
+ sql.append(" AND del_flag_ = 0");
|
|
|
|
+ }
|
|
|
|
+ if(tenantId != null){
|
|
|
|
+ sql.append(" AND tenant_id_ = ").append(tenantId);
|
|
|
|
+ }
|
|
|
|
+ ps = connection.prepareStatement(sql.toString());
|
|
|
|
+ resultSet = ps.executeQuery();
|
|
|
|
+ while (resultSet.next()){
|
|
|
|
+ Y key;
|
|
|
|
+ Z value;
|
|
|
|
+ if(keyType.isAssignableFrom(BigDecimal.class)){
|
|
|
|
+ key = (Y) BigDecimal.class.getDeclaredConstructor(String.class).newInstance(resultSet.getString(1));
|
|
|
|
+ }else if(keyType.isAssignableFrom(String.class)){
|
|
|
|
+ key = (Y) resultSet.getString(1);
|
|
|
|
+ }else{
|
|
|
|
+ key = (Y) keyType.getMethod("valueOf", String.class).invoke(null,resultSet.getString(1));
|
|
|
|
+ }
|
|
|
|
+ if(valueType.isAssignableFrom(BigDecimal.class)){
|
|
|
|
+ value = (Z) BigDecimal.class.getDeclaredConstructor(String.class).newInstance(resultSet.getString(2));
|
|
|
|
+ }else if(valueType.isAssignableFrom(String.class)){
|
|
|
|
+ value = (Z) resultSet.getString(2);
|
|
|
|
+ }else{
|
|
|
|
+ value = (Z) valueType.getMethod("valueOf", String.class).invoke(null,resultSet.getString(2));
|
|
|
|
+ }
|
|
|
|
+ result.put(key, value);
|
|
|
|
+ }
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
+ e.printStackTrace();
|
|
|
|
+ }finally {
|
|
|
|
+ if(resultSet!=null){
|
|
|
|
+ try {
|
|
|
|
+ resultSet.close();
|
|
|
|
+ } catch (SQLException e) {
|
|
|
|
+ e.printStackTrace();
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if(ps!=null){
|
|
|
|
+ try {
|
|
|
|
+ ps.close();
|
|
|
|
+ } catch (SQLException e) {
|
|
|
|
+ e.printStackTrace();
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if(sqlSession!=null){
|
|
|
|
+ sqlSession.close();
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
|
|
return result;
|
|
return result;
|
|
}
|
|
}
|