package frame.object.data;
|
|
import java.util.List;
|
import java.util.Set;
|
|
import frame.data.DataLink;
|
import frame.data.DataType;
|
import frame.data.Entity;
|
import frame.data.EntitySet;
|
import frame.data.IDataProvider;
|
import frame.data.Page;
|
import frame.expression.VariantRequestParams;
|
import frame.object.http.HttpObject;
|
import frame.persist.NamedSQL;
|
import frame.persist.Result;
|
import frame.persist.SQLCreator;
|
import frame.persist.SQLRunner;
|
|
|
public class DataObject extends HttpObject implements IDataProvider {
|
|
protected String dataName;
|
private String operator;
|
|
|
@Override
|
protected void publishMethod() {
|
addMethod("getDataSet");
|
addMethod("getSetByPage");
|
addMethod("getComboboxDataSet");
|
addMethod("procedure");
|
addMethod("getLine");
|
addMethod("newObject");
|
addMethod("addLine");
|
addMethod("deleteById");
|
addMethod("getCount");
|
}
|
|
public void getDataSet() throws Exception {
|
Filter filter = new Filter(onlineUser.getUserRight(), dataPool);
|
OrderBy orderBy = new OrderBy(dataPool);
|
|
EntitySet entitySet = new EntitySet(dataName);
|
entitySet.loadDB(filter, orderBy);
|
|
resultPool.addValue(entitySet);
|
}
|
|
public void getSetByPage() throws Exception {
|
Filter filter = new Filter(onlineUser.getUserRight(), dataPool);
|
OrderBy orderBy = new OrderBy(dataPool);
|
|
EntitySet entitySet = new EntitySet(dataName);
|
|
int totalCount = entitySet.getDBCount(filter);
|
Page page = new Page(totalCount, dataPool);
|
|
entitySet.loadDB(filter, page, orderBy);
|
|
resultPool.addValue("page", page);
|
resultPool.addValue(entitySet);
|
}
|
|
public void getComboboxDataSet() throws Exception {
|
Filter filter = new Filter(onlineUser.getUserRight(), dataPool);
|
OrderBy orderBy = new OrderBy(dataPool);
|
|
EntitySet entitySet = new EntitySet(dataName);
|
entitySet.loadDB(filter, orderBy);
|
|
resultPool.addValue(entitySet);
|
}
|
|
public void procedure() throws Exception {
|
DataType returnType = path.getReturnType();
|
|
NamedSQL namedSQL = NamedSQL.getInstance(operator);
|
namedSQL.setReturnType(returnType);
|
|
//set parameter for first time
|
Set<String> pageVariants = Page.getVarinatNameSet();
|
boolean reset = DataLink.moveOnConsumer(this, namedSQL, pageVariants);
|
|
//set parameter for second time
|
Page page = null;
|
if (reset) {
|
int count = getProcedureDataCount(namedSQL);
|
page = new Page(count, dataPool);
|
|
DataLink.moveOnProvider(page, namedSQL);
|
}
|
|
Result result = namedSQL.exec();
|
resultPool.addValue(result.getValue());
|
|
if (page != null) {
|
resultPool.addValue("page", page);
|
}
|
}
|
|
public void getLine() throws Exception {
|
Id id = getId();
|
|
if (id.isEmpty()) {
|
resultPool.error("empty id");
|
return;
|
}
|
|
Entity entity = new Entity(dataName);
|
entity.loadDB(id);
|
|
resultPool.addValue(entity);
|
}
|
|
public void newObject() throws Exception {
|
Entity entity = new Entity(dataName);
|
|
Initializer initializer = InitializerContainer.get(dataName);
|
initializer.exec(new VariantRequestParams(request), entity);
|
|
resultPool.addValue("line", entity);
|
}
|
|
public void addLine() throws Exception {
|
Entity entity = new Entity(dataName);
|
|
Initializer initializer = InitializerContainer.get(dataName);
|
initializer.exec(new VariantRequestParams(request), entity);
|
DataLink.moveOnConsumer(dataPool, entity);
|
|
entity.insertDB();
|
|
resultPool.addValue("line", entity);
|
}
|
|
public void saveLine() throws Exception {
|
Entity entity = new Entity(dataName);
|
DataLink.moveOnConsumer(dataPool, entity);
|
|
entity.saveDB();
|
}
|
|
public void deleteById() throws Exception {
|
Id id = getId();
|
|
if (id.isEmpty()) {
|
resultPool.error("empty id");
|
return;
|
}
|
|
Entity entity = new Entity(dataName);
|
entity.set("id", id.getValue());
|
|
entity.deleteDB();
|
}
|
|
public void getCount() throws Exception {
|
Filter filter = new Filter(onlineUser.getUserRight(), dataPool);
|
|
Entity entity = new Entity(dataName);
|
int count = entity.getDBCount(filter);
|
|
resultPool.addValue(count);
|
}
|
|
protected Filter getFilter() {
|
Filter filter = new Filter(onlineUser.getUserRight(), dataPool);
|
return filter;
|
}
|
|
protected OrderBy getOrderBy() {
|
OrderBy orderBy = new OrderBy(dataPool);
|
return orderBy;
|
}
|
|
protected Id getId() {
|
Id id = new Id(dataPool);
|
return id;
|
}
|
|
private int getProcedureDataCount(NamedSQL namedSQL) throws Exception {
|
String sql = namedSQL.getSQL();
|
sql = SQLCreator.deletePageLimit(sql);
|
sql = "select count(1) from (" + sql + ") tempTbl";
|
|
namedSQL = new NamedSQL("getCount", sql);
|
int count = SQLRunner.getInteger(namedSQL);
|
|
return count;
|
}
|
|
@Override
|
public List<String> getDataNameList() {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
@Override
|
public boolean containsData(String name) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
|
@Override
|
public Object getDataValue(String name) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
}
|
