package foundation.data.object;
|
|
import foundation.dao.Filter;
|
import foundation.persist.NamedSQL;
|
import foundation.persist.source.NamedDataSource;
|
import foundation.util.Util;
|
import foundation.variant.provider.IVariantsProvider;
|
|
public class SQLGuide {
|
|
private DataObject dataObject;
|
private NamedDataSource dataSource;
|
private String batchName;
|
private String oneName;
|
private NamedSQL batchSQL;
|
private NamedSQL oneSQL;
|
private NamedSQL tableCountSQL;
|
private NamedSQL expendCountSQL;
|
private String commaSeparator;
|
private String joinSelectFields;
|
private String joinSQL;
|
private boolean standard_batch;
|
private boolean standard_one;
|
private boolean standard_count;
|
|
|
public SQLGuide(DataObject dataObject) throws Exception {
|
this.dataObject = dataObject;
|
this.dataSource = dataObject.getDataSource();
|
tableCountSQL = NamedSQL.getInstance(dataSource.getDBaseType(), NamedSQL.Code_GetCount);
|
}
|
|
public void build() {
|
DataJoins dataJoins = dataObject.getDataJoins();
|
|
if (dataJoins == null) {
|
return;
|
}
|
|
commaSeparator = dataJoins.getCommaSeparator();
|
joinSelectFields = dataJoins.getJoinSelectFields();
|
joinSQL = dataJoins.getJoinSQL();
|
}
|
|
public NamedSQL getBrowseBatchSQL() throws Exception {
|
NamedSQL result = batchSQL.createInstance();
|
|
//1. 如果不是自定义SQL和JoinSQL，就选取ViewName或TableName
|
if (standard_batch) {
|
result.setTableName(dataObject.getTableOrViewName());
|
return result;
|
}
|
|
//2. 如果是自定义SQL和JoinSQL，选取TableName
|
result.setTableName(dataObject.getTableOrViewName());
|
result.setParam("commaSeparator", commaSeparator);
|
result.setParam("joinSelectFields", joinSelectFields);
|
result.setParam("joinSQL", joinSQL);
|
|
//3. 返回
|
return result;
|
}
|
|
public NamedSQL getBrowseOneSQL() throws Exception {
|
NamedSQL result = oneSQL.createInstance();
|
|
//1. 如果不是自定义SQL和JoinSQL，就选取ViewName或TableName
|
if (standard_one) {
|
result.setTableName(dataObject.getTableOrViewName());
|
return result;
|
}
|
|
//2. 如果是自定义SQL和JoinSQL，选取TableName
|
result.setTableName(dataObject.getTableName());
|
result.setParam("commaSeparator", commaSeparator);
|
result.setParam("joinSelectFields", joinSelectFields);
|
result.setParam("joinSQL", joinSQL);
|
|
//3. 返回
|
return result;
|
}
|
|
public NamedSQL getCountSQL(IVariantsProvider[] providers) throws Exception {
|
NamedSQL namedSQL;
|
Filter filter = findFilter(providers);
|
//1. 没有过滤条件
|
if (filter == null) {
|
namedSQL = tableCountSQL.createInstance();
|
namedSQL.setTableName(dataObject.getTableOrViewName());
|
return namedSQL;
|
}
|
|
//2. 过滤条件没有超出主表范围
|
if (!filter.containsSlaveTables(dataObject.getJoinTables())) {
|
namedSQL = tableCountSQL.createInstance();
|
namedSQL.setTableName(dataObject.getTableOrViewName());
|
}
|
//3.
|
else {
|
namedSQL = expendCountSQL.createInstance();
|
|
namedSQL.setTableName(dataObject.getTableName());
|
namedSQL.setParam("commaSeparator", commaSeparator);
|
namedSQL.setParam("joinSelectFields", joinSelectFields);
|
namedSQL.setParam("joinSQL", joinSQL);
|
|
namedSQL.setOrderBy("");
|
namedSQL.setPage(null);
|
}
|
|
return namedSQL;
|
}
|
|
public void setBatchSQL(String sqlName) throws Exception {
|
this.batchName = sqlName;
|
|
//1. 先检查 自定义SQL 是否可用
|
if (!Util.isEmpty(sqlName)) {
|
batchSQL = NamedSQL.getInstance(dataSource.getDBaseType(), sqlName);
|
standard_batch = false;
|
return;
|
}
|
|
//2. 检查 Join SQL 是否可用
|
DataJoins dataJoins = dataObject.getDataJoins();
|
|
if (dataJoins != null && !dataJoins.isEmpty()) {
|
batchSQL = NamedSQL.getInstance(dataSource.getDBaseType(), NamedSQL.Code_GetJoinEntity);
|
standard_batch = false;
|
return;
|
}
|
|
//3. 默认 SQL
|
batchSQL = NamedSQL.getInstance(dataSource.getDBaseType(), NamedSQL.Code_GetEntity);
|
standard_batch = true;
|
}
|
|
public void setOneSQL(String sqlName) throws Exception {
|
this.oneName = sqlName;
|
|
//1. 先检查 自定义SQL 是否可用
|
if (!Util.isEmpty(sqlName)) {
|
oneSQL = NamedSQL.getInstance(dataSource.getDBaseType(), sqlName);
|
standard_one = false;
|
return;
|
}
|
|
//2. 检查 Join SQL 是否可用
|
DataJoins dataJoins = dataObject.getDataJoins();
|
|
if (dataJoins != null && !dataJoins.isEmpty()) {
|
oneSQL = NamedSQL.getInstance(dataSource.getDBaseType(), NamedSQL.Code_GetJoinEntity);
|
standard_one = false;
|
return;
|
}
|
|
//3. 默认 SQL
|
oneSQL = NamedSQL.getInstance(dataSource.getDBaseType(), NamedSQL.Code_GetEntity);
|
standard_one = true;
|
}
|
|
public void setCountSQL(String sqlName) throws Exception {
|
//1. 先检查 自定义SQL 是否可用
|
if (!Util.isEmpty(sqlName)) {
|
expendCountSQL = NamedSQL.getInstance(dataSource.getDBaseType(), sqlName);
|
standard_count = false;
|
return;
|
}
|
|
//2. 检查 Join Count SQL 是否可用
|
DataJoins dataJoins = dataObject.getDataJoins();
|
|
if (dataJoins != null && !dataJoins.isEmpty()) {
|
expendCountSQL = NamedSQL.getInstance(dataSource.getDBaseType(), NamedSQL.Code_GetJoinCount);
|
standard_count = false;
|
return;
|
}
|
|
//3. 如果不是Join，但是有特殊的BatchSQL，用特殊的SQL做为Count SQL
|
if (!standard_batch) {
|
String sqlText = " select count(1) from ( " + batchSQL.toString() + " ) a ";
|
expendCountSQL = new NamedSQL("expendCountSQL", sqlText);
|
standard_count = false;
|
return;
|
}
|
|
|
//4. 默认情况
|
expendCountSQL = tableCountSQL;
|
standard_count = true;
|
}
|
|
private Filter findFilter(IVariantsProvider[] providers) {
|
if (providers == null) {
|
return null;
|
}
|
|
for (int i = 0; i < providers.length; i++) {
|
IVariantsProvider provider = providers[i];
|
|
if (provider == null) {
|
continue;
|
}
|
|
if (Filter.ProviderName.equals(provider.getProviderName())) {
|
return (Filter) provider;
|
}
|
}
|
|
return null;
|
}
|
|
public boolean isStandard_batch() {
|
return standard_batch;
|
}
|
|
public boolean isStandard_one() {
|
return standard_one;
|
}
|
|
public boolean isStandard_count() {
|
return standard_count;
|
}
|
|
public boolean isBatchAndOneSame() {
|
boolean result = Util.equals(batchName, oneName);
|
return result;
|
}
|
}
|
