midsuit
/
core-jgi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

FR [ 2421313 ] Introduce Query.firstOnly convenient method

This commit is contained in:
teo_sarca 2008-12-12 15:10:24 +00:00
parent 2c01c9e374
commit 9ebeab9b0a
2 changed files with 77 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
base/src/org/compiere/model/Query.java
View File

@ -39,10 +39,11 @@ import org.compiere.util.Util;
* @author Low Heng Sin
* @author Teo Sarca, SC ARHIPAC SERVICE SRL
* <li>FR [ 1981760 ] Improve Query class
* <li>BF [ 2030280 ] org.compiere.model.Query apply access fielter issue
* <li>BF [ 2030280 ] org.compiere.model.Query apply access filter issue
* <li>FR [ 2041894 ] Add Query.match() method
* <li>FR [ 2107068 ] Query.setOrderBy should be more error tollerant
* <li>FR [ 2107068 ] Query.setOrderBy should be more error tolerant
* <li>FR [ 2107109 ] Add method Query.setOnlyActiveRecords
* <li>FR [ 2421313 ] Introduce Query.firstOnly convenient method
*/
public class Query
{
@ -227,6 +228,58 @@ public class Query
return po;
}
/**
* Return first PO that match query criteria.
* If there are more records that match criteria an exception will be throwed
* @return first PO
* @throws DBException
* @see {@link #first()}
*/
@SuppressWarnings("unchecked")
public <T extends PO> T firstOnly() throws DBException
{
T po = null;
String sql = buildSQL(null, true);
PreparedStatement pstmt = null;
ResultSet rs = null;
try
{
pstmt = DB.prepareStatement (sql, trxName);
rs = createResultSet(pstmt);
if (rs.next())
{
po = (T)table.getPO(rs, trxName);
}
if (rs.next())
{
throw new DBException("QueryMoreThanOneRecordsFound"); // TODO : translate
}
}
catch (SQLException e)
{
log.log(Level.SEVERE, sql, e);
throw new DBException(e);
}
finally
{
DB.close(rs, pstmt);
rs = null; pstmt = null;
}
return po;
}
/**
* red1 - returns full SQL string - for caller needs
* @return buildSQL(null,true)
*
*/
public String getSQL() throws DBException
{
return buildSQL(null, true);
}
/**
* Count items that match query criteria
* @return count

23
extend/src/test/functional/QueryTest.java
View File

@ -11,7 +11,6 @@ import org.compiere.model.MTable;
import org.compiere.model.POResultSet;
import org.compiere.model.Query;
import org.compiere.util.DB;
import org.compiere.util.Env;
import test.AdempiereTestCase;
@ -149,4 +148,26 @@ public class QueryTest extends AdempiereTestCase
.first();
assertEquals("Invalid object", "C_Invoice", t.getTableName());
}
public void testFirstOnly() throws Exception
{
MTable t = new Query(getCtx(), "AD_Table", "AD_Table_ID=?", getTrxName())
.setParameters(new Object[]{318})
.firstOnly();
assertEquals("Invalid table ID", 318, t.get_ID());
//
Exception ex = null;
try
{
t = new Query(getCtx(), "AD_Table", "TableName IN (?,?)", getTrxName())
.setParameters(new Object[]{"C_Invoice", "M_InOut"})
.setOrderBy("TableName")
.firstOnly();
}
catch (DBException e)
{
ex = e;
}
assertNotNull("Exception should be throwed", ex);
}
}