ff-attic/imxmi
2
0
Fork 0
Code Activity

added interface override annotations.

Browse source
This commit is contained in:
Willem Cazander 2014-08-24 12:22:32 +02:00
parent fc4c568b18
commit 5bbd8e4ef3
189 changed files with 1458 additions and 319 deletions
Download patch file Download diff file Expand all files Collapse all files

18
vasc-backend/vasc-backend-api/src/main/java/net/forwardfire/vasc/backend/AbstractVascBackend.java
View file

@ -37,6 +37,7 @@ abstract public class AbstractVascBackend<DATA_OBJECT extends Serializable> impl
/**
* @see net.forwardfire.vasc.backend.VascBackend#getId()
*/
@Override
public String getId() {
return id;
}
@ -44,6 +45,7 @@ abstract public class AbstractVascBackend<DATA_OBJECT extends Serializable> impl
/**
* @see net.forwardfire.vasc.backend.VascBackend#setId(java.lang.String)
*/
@Override
public void setId(String id) {
if (id==null) {
throw new IllegalArgumentException("id may not be null");
@ -54,18 +56,21 @@ abstract public class AbstractVascBackend<DATA_OBJECT extends Serializable> impl
/**
* @see net.forwardfire.vasc.backend.VascBackend#startBackend()
*/
@Override
public void startBackend() {
}
/**
* @see net.forwardfire.vasc.backend.VascBackend#stopBackend()
*/
@Override
public void stopBackend() {
}
/**
* @see net.forwardfire.vasc.backend.VascBackend#isReadOnly()
*/
@Override
public boolean isReadOnly() {
return false;
}
@ -73,6 +78,7 @@ abstract public class AbstractVascBackend<DATA_OBJECT extends Serializable> impl
/**
* @see net.forwardfire.vasc.backend.VascBackend#isPageable()
*/
@Override
public boolean isPageable() {
return false;
}
@ -80,6 +86,7 @@ abstract public class AbstractVascBackend<DATA_OBJECT extends Serializable> impl
/**
* @see net.forwardfire.vasc.backend.VascBackend#fetchTotalExecuteSize(VascBackendState state)
*/
@Override
public long fetchTotalExecuteSize(VascBackendState state) {
return 0;
}
@ -87,6 +94,7 @@ abstract public class AbstractVascBackend<DATA_OBJECT extends Serializable> impl
/**
* @see net.forwardfire.vasc.backend.VascBackend#isSearchable()
*/
@Override
public boolean isSearchable() {
return false;
}
@ -94,13 +102,15 @@ abstract public class AbstractVascBackend<DATA_OBJECT extends Serializable> impl
/**
* @see net.forwardfire.vasc.backend.VascBackend#isSortable()
*/
@Override
public boolean isSortable() {
return false;
}
/**
* @see net.forwardfire.vasc.backend.VascBackend#isRecordMoveable()
*/
@Override
public boolean isRecordMoveable() {
return false;
}
@ -108,6 +118,7 @@ abstract public class AbstractVascBackend<DATA_OBJECT extends Serializable> impl
/**
* @see net.forwardfire.vasc.backend.VascBackend#doRecordMoveDownById(java.lang.Object)
*/
@Override
public long doRecordMoveDownById(VascBackendState state,Object primaryId) throws VascBackendException {
return 0l;
}
@ -115,6 +126,7 @@ abstract public class AbstractVascBackend<DATA_OBJECT extends Serializable> impl
/**
* @see net.forwardfire.vasc.backend.VascBackend#doRecordMoveUpById(java.lang.Object)
*/
@Override
public long doRecordMoveUpById(VascBackendState state,Object primaryId) throws VascBackendException {
return 0l;
}
@ -122,6 +134,7 @@ abstract public class AbstractVascBackend<DATA_OBJECT extends Serializable> impl
/**
* @see net.forwardfire.vasc.backend.VascBackend#executePageSummary()
*/
@Override
public Map<String, Object> executePageSummary() {
return null;
}
@ -129,6 +142,7 @@ abstract public class AbstractVascBackend<DATA_OBJECT extends Serializable> impl
/**
* @see net.forwardfire.vasc.backend.VascBackend#executeTotalSummary()
*/
@Override
public Map<String, Object> executeTotalSummary() {
return null;
}
@ -136,6 +150,7 @@ abstract public class AbstractVascBackend<DATA_OBJECT extends Serializable> impl
/**
* @see net.forwardfire.vasc.backend.VascBackend#hasPageSummary()
*/
@Override
public boolean hasPageSummary() {
return false;
}
@ -143,6 +158,7 @@ abstract public class AbstractVascBackend<DATA_OBJECT extends Serializable> impl
/**
* @see net.forwardfire.vasc.backend.VascBackend#hasTotalSummary()
*/
@Override
public boolean hasTotalSummary() {
return false;
}

9
vasc-backend/vasc-backend-api/src/main/java/net/forwardfire/vasc/backend/AbstractVascBackendControllerLocal.java
View file

@ -47,6 +47,7 @@ abstract public class AbstractVascBackendControllerLocal implements VascBackendC
/**
* @see net.forwardfire.vasc.backend.VascBackendController#getVascBackendById(java.lang.String)
*/
@Override
public VascBackend<Serializable> getVascBackendById(String id) {
return backends.get(id);
}
@ -54,6 +55,7 @@ abstract public class AbstractVascBackendControllerLocal implements VascBackendC
/**
* @see net.forwardfire.vasc.backend.VascBackendController#getVascBackendIds()
*/
@Override
public List<String> getVascBackendIds() {
List<String> result = new ArrayList<String>(50);
for (String id:backends.keySet()) {
@ -67,6 +69,7 @@ abstract public class AbstractVascBackendControllerLocal implements VascBackendC
* @see net.forwardfire.vasc.backend.VascBackendControllerLocal#addVascBackend(net.forwardfire.vasc.backend.VascBackend)
*/
@SuppressWarnings("unchecked")
@Override
public void addVascBackend(VascBackend<? extends Serializable> backend) {
if (backend==null) {
throw new NullPointerException("backend must not be null.");
@ -78,10 +81,11 @@ abstract public class AbstractVascBackendControllerLocal implements VascBackendC
VascBackend<Serializable> castedBackend = (VascBackend<Serializable>) backend;
backends.put(backend.getId(), castedBackend);
}
/**
* @see net.forwardfire.vasc.backend.VascBackendControllerLocal#removeVascBackendById(java.lang.String)
*/
@Override
public void removeVascBackendById(String backendId) {
VascBackend<? extends Serializable> backend = getVascBackendById(backendId);
if (backend==null) {
@ -90,10 +94,11 @@ abstract public class AbstractVascBackendControllerLocal implements VascBackendC
backend.stopBackend();
backends.remove(backendId);
}
/**
* @see net.forwardfire.vasc.backend.VascBackendControllerLocal#clearAndStopBackends()
*/
@Override
public void clearAndStopBackends() {
for (String backendId:getVascBackendIds()) {
removeVascBackendById(backendId);

17
vasc-backend/vasc-backend-api/src/main/java/net/forwardfire/vasc/backend/AbstractVascBackendState.java
View file

@ -50,6 +50,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @see net.forwardfire.vasc.backend.VascBackendState#setDataParameter(java.lang.String, java.lang.Object)
*/
@Override
public void setDataParameter(String key, Object data) {
parameters.put(key,data);
}
@ -57,6 +58,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @see net.forwardfire.vasc.backend.VascBackendState#removeDataParameter(java.lang.String)
*/
@Override
public void removeDataParameter(String key) {
parameters.remove(key);
}
@ -64,6 +66,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @see net.forwardfire.vasc.backend.VascBackendState#removeDataParameterAll()
*/
@Override
public void removeDataParameterAll() {
parameters.clear();
}
@ -71,6 +74,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @see net.forwardfire.vasc.backend.VascBackendState#getDataParameter(java.lang.String)
*/
@Override
public Object getDataParameter(String key) {
return parameters.get(key);
}
@ -78,6 +82,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @see net.forwardfire.vasc.backend.VascBackendState#getDataParameterKeys()
*/
@Override
public Set<String> getDataParameterKeys() {
return parameters.keySet();
}
@ -85,6 +90,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @see net.forwardfire.vasc.backend.VascBackend#getPageIndex()
*/
@Override
public int getPageIndex() {
return pageIndex;
}
@ -92,6 +98,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @see net.forwardfire.vasc.backend.VascBackend#setPageIndex(int)
*/
@Override
public void setPageIndex(int pageIndex) {
this.pageIndex=pageIndex;
}
@ -99,6 +106,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @see net.forwardfire.vasc.backend.VascBackend#getPageSize()
*/
@Override
public int getPageSize() {
return pageSize;
}
@ -106,6 +114,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @see net.forwardfire.vasc.backend.VascBackend#setPageSize(int)
*/
@Override
public void setPageSize(int pageSize) {
this.pageSize=pageSize;
}
@ -113,6 +122,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @see net.forwardfire.vasc.backend.VascBackend#getSearchString()
*/
@Override
public String getSearchString() {
return searchString;
}
@ -120,6 +130,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @see net.forwardfire.vasc.backend.VascBackend#setSearchString(java.lang.String)
*/
@Override
public void setSearchString(String searchString) {
this.searchString=searchString;
}
@ -127,6 +138,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @see net.forwardfire.vasc.backend.VascBackend#isSortAscending()
*/
@Override
public boolean isSortAscending() {
return ascending;
}
@ -134,6 +146,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @see net.forwardfire.vasc.backend.VascBackend#setSortAscending(boolean)
*/
@Override
public void setSortAscending(boolean ascending) {
this.ascending=ascending;
}
@ -141,6 +154,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @see net.forwardfire.vasc.backend.VascBackend#getSortField()
*/
@Override
public String getSortField() {
return sortField;
}
@ -148,6 +162,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @see net.forwardfire.vasc.backend.VascBackend#setSortField(java.lang.String)
*/
@Override
public void setSortField(String sortField) {
this.sortField=sortField;
}
@ -155,6 +170,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @return the pageSizeMax
*/
@Override
public int getPageSizeMax() {
return pageSizeMax;
}
@ -162,6 +178,7 @@ abstract public class AbstractVascBackendState implements VascBackendState {
/**
* @param pageSizeMax the pageSizeMax to set
*/
@Override
public void setPageSizeMax(int pageSizeMax) {
this.pageSizeMax = pageSizeMax;
}

3
vasc-backend/vasc-backend-api/src/main/java/net/forwardfire/vasc/backend/data/BeanVascEntryFieldValue.java
View file

@ -44,6 +44,7 @@ public class BeanVascEntryFieldValue<DATA_OBJECT extends Serializable> implement
/**
* @see net.forwardfire.vasc.core.entry.VascEntryFieldValue#getValue(java.lang.String, java.lang.Object)
*/
@Override
public Serializable getValue(String backendName, DATA_OBJECT record) throws VascBackendException {
if (backendName==null) {
throw new NullPointerException("Can't get value of null backendName.");
@ -62,6 +63,7 @@ public class BeanVascEntryFieldValue<DATA_OBJECT extends Serializable> implement
/**
* @see net.forwardfire.vasc.core.entry.VascEntryFieldValue#getDisplayValue(java.lang.String, java.lang.Object)
*/
@Override
public String getDisplayValue(String backendName, DATA_OBJECT record) throws VascBackendException {
Serializable value = getValue(backendName,record);
if (value==null) {
@ -91,6 +93,7 @@ public class BeanVascEntryFieldValue<DATA_OBJECT extends Serializable> implement
/**
* @see net.forwardfire.vasc.core.entry.VascEntryFieldValue#setValue(java.lang.String, java.lang.Object, java.lang.Object)
*/
@Override
public void setValue(String backendName, DATA_OBJECT record,Serializable value) throws VascBackendException {
if (backendName==null) {
throw new NullPointerException("Can't set value of null backendName.");

1
vasc-backend/vasc-backend-api/src/main/java/net/forwardfire/vasc/backend/data/BeanVascEntryRecordCreator.java
View file

@ -47,6 +47,7 @@ public class BeanVascEntryRecordCreator<DATA_OBJECT extends Serializable> implem
}
@SuppressWarnings("unchecked")
@Override
public DATA_OBJECT newRecord() throws VascBackendException {
try {
return (DATA_OBJECT)resultClass.newInstance();

3
vasc-backend/vasc-backend-api/src/main/java/net/forwardfire/vasc/backend/data/HashMapVascEntryFieldValue.java
View file

@ -41,6 +41,7 @@ public class HashMapVascEntryFieldValue implements VascEntryFieldValue<HashMap<S
/**
* @see net.forwardfire.vasc.core.entry.VascEntryFieldValue#getValue(java.lang.String, java.lang.Object)
*/
@Override
public Serializable getValue(String backendName,HashMap<String,Serializable> map) throws VascBackendException {
if (backendName==null) {
throw new NullPointerException("Can't get value of null backendName field.");
@ -55,6 +56,7 @@ public class HashMapVascEntryFieldValue implements VascEntryFieldValue<HashMap<S
/**
* @see net.forwardfire.vasc.core.entry.VascEntryFieldValue#getDisplayValue(net.forwardfire.vasc.core.VascEntryField, java.lang.Object)
*/
@Override
public String getDisplayValue(String field, HashMap<String,Serializable> record) throws VascBackendException {
Serializable fieldValue = getValue(field,record);
if (fieldValue==null) {
@ -66,6 +68,7 @@ public class HashMapVascEntryFieldValue implements VascEntryFieldValue<HashMap<S
/**
* @see net.forwardfire.vasc.core.entry.VascEntryFieldValue#setValue(java.lang.String, java.lang.Object, java.lang.Object)
*/
@Override
public void setValue(String backendName, HashMap<String,Serializable> map,Serializable value) throws VascBackendException {
map.put(backendName, value);
}

1
vasc-backend/vasc-backend-api/src/main/java/net/forwardfire/vasc/backend/data/HashMapVascEntryRecordCreator.java
View file

@ -38,6 +38,7 @@ public class HashMapVascEntryRecordCreator implements VascEntryRecordCreator<Has
private static final long serialVersionUID = 1L;
@Override
public HashMap<String,Serializable> newRecord() throws VascBackendException {
return new HashMap<String,Serializable>(10);
}

1
vasc-backend/vasc-backend-jdbc/src/main/java/net/forwardfire/vasc/backend/jdbc/JdbcConnectionProviderImpl.java
View file

@ -44,6 +44,7 @@ public class JdbcConnectionProviderImpl implements JdbcConnectionProvider {
/**
* @see net.forwardfire.vasc.backend.jdbc.JdbcConnectionProvider#getJdbcConnection()
*/
@Override
public Connection getJdbcConnection() throws SQLException {
if (loadedDriver==false) {
try {

1
vasc-backend/vasc-backend-jdbc/src/main/java/net/forwardfire/vasc/backend/jdbc/JdbcConnectionProviderJdniImpl.java
View file

@ -46,6 +46,7 @@ public class JdbcConnectionProviderJdniImpl implements JdbcConnectionProvider {
/**
* @see net.forwardfire.vasc.backend.jdbc.JdbcConnectionProvider#getJdbcConnection()
*/
@Override
public Connection getJdbcConnection() throws SQLException {
Connection connection = getDataSource(dataSourceName).getConnection();
return connection;

6
vasc-backend/vasc-backend-jdbc/src/main/java/net/forwardfire/vasc/backend/jdbc/JdbcVascBackend.java
View file

@ -81,6 +81,7 @@ public class JdbcVascBackend extends AbstractVascBackend<HashMap<String,Object>>
/**
* @see net.forwardfire.vasc.backend.VascBackend#execute(VascBackendState state)
*/
@Override
public VascBackendResult<HashMap<String,Object>> execute(VascBackendState state) throws VascBackendException {
JdbcConnectionProvider prov = getJdbcConnectionProvider();
List<HashMap<String,Object>> result = new ArrayList<HashMap<String,Object>>(50);
@ -117,6 +118,7 @@ public class JdbcVascBackend extends AbstractVascBackend<HashMap<String,Object>>
/**
* @see net.forwardfire.vasc.backend.VascBackend#merge(java.lang.Object)
*/
@Override
public HashMap<String,Object> merge(HashMap<String,Object> object) throws VascBackendException {
return object;
}
@ -124,18 +126,21 @@ public class JdbcVascBackend extends AbstractVascBackend<HashMap<String,Object>>
/**
* @see net.forwardfire.vasc.backend.VascBackend#persist(java.lang.Object)
*/
@Override
public void persist(HashMap<String,Object> object) throws VascBackendException {
}
/**
* @see net.forwardfire.vasc.backend.VascBackend#delete(java.lang.Object)
*/
@Override
public void delete(HashMap<String,Object> object) throws VascBackendException {
}
/**
* @see net.forwardfire.vasc.backend.VascBackend#provideVascEntryFieldValue(net.forwardfire.vasc.core.VascEntryField)
*/
@Override
public VascEntryFieldValue provideVascEntryFieldValue() {
return new HashMapVascEntryFieldValue();
}
@ -143,6 +148,7 @@ public class JdbcVascBackend extends AbstractVascBackend<HashMap<String,Object>>
/**
* @see net.forwardfire.vasc.backend.VascBackend#provideVascEntryRecordCreator(net.forwardfire.vasc.core.VascEntry)
*/
@Override
public VascEntryRecordCreator provideVascEntryRecordCreator() {
return new HashMapVascEntryRecordCreator();
}

6
vasc-backend/vasc-backend-jdbc/src/main/java/net/forwardfire/vasc/backend/jdbc/JdbcVascBackendXpql.java
View file

@ -92,6 +92,7 @@ public class JdbcVascBackendXpql extends AbstractVascBackend<HashMap<String,Obje
/**
* @see net.forwardfire.vasc.backend.VascBackend#execute(VascBackendState state)
*/
@Override
public VascBackendResult<HashMap<String,Object>> execute(VascBackendState state) throws VascBackendException {
// Copy parameters
for (String key:state.getDataParameterKeys()) {
@ -138,6 +139,7 @@ public class JdbcVascBackendXpql extends AbstractVascBackend<HashMap<String,Obje
/**
* @see net.forwardfire.vasc.backend.VascBackend#merge(java.lang.Object)
*/
@Override
public HashMap<String,Object> merge(HashMap<String,Object> object) throws VascBackendException {
return object;
}
@ -145,18 +147,21 @@ public class JdbcVascBackendXpql extends AbstractVascBackend<HashMap<String,Obje
/**
* @see net.forwardfire.vasc.backend.VascBackend#persist(java.lang.Object)
*/
@Override
public void persist(HashMap<String,Object> object) throws VascBackendException {
}
/**
* @see net.forwardfire.vasc.backend.VascBackend#delete(java.lang.Object)
*/
@Override
public void delete(HashMap<String,Object> object) throws VascBackendException {
}
/**
* @see net.forwardfire.vasc.backend.VascBackend#provideVascEntryFieldValue()
*/
@Override
public VascEntryFieldValue provideVascEntryFieldValue() {
return new HashMapVascEntryFieldValue();
}
@ -164,6 +169,7 @@ public class JdbcVascBackendXpql extends AbstractVascBackend<HashMap<String,Obje
/**
* @see net.forwardfire.vasc.backend.VascBackend#provideVascEntryRecordCreator()
*/
@Override
public VascEntryRecordCreator provideVascEntryRecordCreator() {
return new HashMapVascEntryRecordCreator();
}

5
vasc-backend/vasc-backend-jpa/src/main/java/net/forwardfire/vasc/backends/jpa/AbstractHibernateVascBackend.java
View file

@ -43,6 +43,7 @@ abstract public class AbstractHibernateVascBackend<DATA_OBJECT extends Serializa
*/
abstract Session getHibernateSession();
@Override
public void persist(DATA_OBJECT object) throws VascBackendException {
Session s = getHibernateSession();
try {
@ -58,7 +59,8 @@ abstract public class AbstractHibernateVascBackend<DATA_OBJECT extends Serializa
}
}
}
@Override
public DATA_OBJECT merge(DATA_OBJECT object) throws VascBackendException {
Session s = getHibernateSession();
try {
@ -76,6 +78,7 @@ abstract public class AbstractHibernateVascBackend<DATA_OBJECT extends Serializa
}
}
@Override
public void delete(DATA_OBJECT object) throws VascBackendException {
Session s = getHibernateSession();
try {

5
vasc-backend/vasc-backend-jpa/src/main/java/net/forwardfire/vasc/backends/jpa/AbstractPersistenceVascBackend.java
View file

@ -40,6 +40,7 @@ abstract public class AbstractPersistenceVascBackend<DATA_OBJECT extends Seriali
abstract EntityManager getEntityManager();
@Override
public void persist(DATA_OBJECT object) throws VascBackendException {
EntityManager s = getEntityManager();
try {
@ -56,7 +57,8 @@ abstract public class AbstractPersistenceVascBackend<DATA_OBJECT extends Seriali
}
}
}
@Override
public DATA_OBJECT merge(DATA_OBJECT object) throws VascBackendException {
EntityManager s = getEntityManager();
try {
@ -75,6 +77,7 @@ abstract public class AbstractPersistenceVascBackend<DATA_OBJECT extends Seriali
}
}
@Override
public void delete(DATA_OBJECT object) throws VascBackendException {
EntityManager s = getEntityManager();
try {

4
vasc-backend/vasc-backend-jpa/src/main/java/net/forwardfire/vasc/backends/jpa/XpqlHibernateVascBackend.java
View file

@ -77,6 +77,7 @@ public class XpqlHibernateVascBackend<DATA_OBJECT extends Serializable> extends
}
@SuppressWarnings("unchecked")
@Override
public VascBackendResult<DATA_OBJECT> execute(VascBackendState state) throws VascBackendException {
// Copy parameters
@ -121,6 +122,7 @@ public class XpqlHibernateVascBackend<DATA_OBJECT extends Serializable> extends
/**
* @see net.forwardfire.vasc.backend.VascBackend#provideVascEntryFieldValue()
*/
@Override
public VascEntryFieldValue provideVascEntryFieldValue() {
BeanVascEntryFieldValue result = new BeanVascEntryFieldValue();
return result;
@ -129,6 +131,7 @@ public class XpqlHibernateVascBackend<DATA_OBJECT extends Serializable> extends
/**
* @see net.forwardfire.vasc.backend.VascBackend#provideVascEntryRecordCreator()
*/
@Override
public VascEntryRecordCreator provideVascEntryRecordCreator() {
return new BeanVascEntryRecordCreator(resultClass);
}
@ -203,6 +206,7 @@ public class XpqlHibernateVascBackend<DATA_OBJECT extends Serializable> extends
/**
* @see net.forwardfire.vasc.backend.VascBackend#fetchTotalExecuteSize(VascBackendState state)
*/
@Override
public long fetchTotalExecuteSize(VascBackendState state) {
Session s = getHibernateSession();
try {

7
vasc-backend/vasc-backend-jpa/src/main/java/net/forwardfire/vasc/backends/jpa/XpqlPersistanceVascBackend.java
View file

@ -76,9 +76,8 @@ public class XpqlPersistanceVascBackend<DATA_OBJECT extends Serializable> extend
return entityManagerProvider.getEntityManager();
}
@SuppressWarnings("unchecked")
@Override
public VascBackendResult<DATA_OBJECT> execute(VascBackendState state) throws VascBackendException {
// Copy parameters
@ -125,6 +124,7 @@ public class XpqlPersistanceVascBackend<DATA_OBJECT extends Serializable> extend
/**
* @see net.forwardfire.vasc.backend.VascBackend#provideVascEntryFieldValue()
*/
@Override
public VascEntryFieldValue provideVascEntryFieldValue() {
VascEntryFieldValue result = new BeanVascEntryFieldValue();
return result;
@ -133,6 +133,7 @@ public class XpqlPersistanceVascBackend<DATA_OBJECT extends Serializable> extend
/**
* @see net.forwardfire.vasc.backend.VascBackend#provideVascEntryRecordCreator()
*/
@Override
public VascEntryRecordCreator provideVascEntryRecordCreator() {
VascEntryRecordCreator result = new BeanVascEntryRecordCreator(resultClass);
return result;
@ -208,6 +209,7 @@ public class XpqlPersistanceVascBackend<DATA_OBJECT extends Serializable> extend
/**
* @see net.forwardfire.vasc.backend.VascBackend#fetchTotalExecuteSize(VascBackendState state)
*/
@Override
public long fetchTotalExecuteSize(VascBackendState state) {
EntityManager em = getEntityManager();
try {
@ -427,6 +429,7 @@ public class XpqlPersistanceVascBackend<DATA_OBJECT extends Serializable> extend
/**
* @see net.forwardfire.vasc.backend.VascBackend#isSearchable()
*/
@Override
public boolean isSearchable() {
if (query.getQueryParameterValue("text_search")==null) {
return false;

1
vasc-backend/vasc-backend-ldap/src/main/java/net/forwardfire/vasc/backend/ldap/LdapConnectionProviderImpl.java
View file

@ -40,6 +40,7 @@ public class LdapConnectionProviderImpl implements LdapConnectionProvider {
/**
* @see net.forwardfire.vasc.backend.ldap.LdapConnectionProvider#getLdapConnection()
*/
@Override
public LDAPConnection getLdapConnection() {
try {

6
vasc-backend/vasc-backend-ldap/src/main/java/net/forwardfire/vasc/backend/ldap/LdapVascBackend.java
View file

@ -82,6 +82,7 @@ public class LdapVascBackend extends AbstractVascBackend<HashMap<String,Object>>
/**
* @see net.forwardfire.vasc.backend.VascBackend#execute()
*/
@Override
public VascBackendResult<HashMap<String,Object>> execute(VascBackendState state) throws VascBackendException {
LdapConnectionProvider prov = getLdapConnectionProvider();
LDAPConnection connection = prov.getLdapConnection();
@ -136,6 +137,7 @@ public class LdapVascBackend extends AbstractVascBackend<HashMap<String,Object>>
/**
* @see net.forwardfire.vasc.backend.VascBackend#merge(java.lang.Object)
*/
@Override
public HashMap<String,Object> merge(HashMap<String,Object> map) throws VascBackendException {
LdapConnectionProvider prov = getLdapConnectionProvider();
LDAPConnection connection = prov.getLdapConnection();
@ -216,6 +218,7 @@ public class LdapVascBackend extends AbstractVascBackend<HashMap<String,Object>>
/**
* @see net.forwardfire.vasc.backend.VascBackend#persist(java.lang.Object)
*/
@Override
public void persist(HashMap<String,Object> map) throws VascBackendException {
LdapConnectionProvider prov = getLdapConnectionProvider();
LDAPConnection connection = prov.getLdapConnection();
@ -250,6 +253,7 @@ public class LdapVascBackend extends AbstractVascBackend<HashMap<String,Object>>
/**
* @see net.forwardfire.vasc.backend.VascBackend#delete(java.lang.Object)
*/
@Override
public void delete(HashMap<String,Object> map) throws VascBackendException {
LdapConnectionProvider prov = getLdapConnectionProvider();
LDAPConnection connection = prov.getLdapConnection();
@ -292,6 +296,7 @@ public class LdapVascBackend extends AbstractVascBackend<HashMap<String,Object>>
/**
* @see net.forwardfire.vasc.backend.VascBackend#provideVascEntryRecordCreator()
*/
@Override
public VascEntryRecordCreator provideVascEntryRecordCreator() {
return new HashMapVascEntryRecordCreator();
}
@ -299,6 +304,7 @@ public class LdapVascBackend extends AbstractVascBackend<HashMap<String,Object>>
/**
* @see net.forwardfire.vasc.backend.VascBackend#provideVascEntryFieldValue()
*/
@Override
public VascEntryFieldValue provideVascEntryFieldValue() {
return new HashMapVascEntryFieldValue();
}

1
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/MetaModelDataContextCsv.java
View file

@ -42,6 +42,7 @@ public class MetaModelDataContextCsv implements MetaModelDataContextProvider {
private String url = null;
private CsvConfiguration csvConfiguration = null;
@Override
public DataContext getDataContext() {
if (csvConfiguration==null) {
csvConfiguration = new CsvConfiguration();

1
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/MetaModelDataContextJdbc.java
View file

@ -41,6 +41,7 @@ public class MetaModelDataContextJdbc implements MetaModelDataContextProvider {
private String username = null;
private String password = null;
@Override
public DataContext getDataContext() {
JdbcDataContext dataContext = new JdbcDataContext(getConnection());
return dataContext;

1
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/MetaModelDataContextJndiDataContext.java
View file

@ -37,6 +37,7 @@ public class MetaModelDataContextJndiDataContext implements MetaModelDataContext
private String jndiName = null;
@Override
public DataContext getDataContext() {
return getDataContextJndi();
}

1
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/MetaModelDataContextJndiDataSource.java
View file

@ -40,6 +40,7 @@ public class MetaModelDataContextJndiDataSource implements MetaModelDataContextP
private String jndiName = null;
private JdbcDataContext dataContext = null;
@Override
public DataContext getDataContext() {
if (dataContext==null) {
dataContext = new JdbcDataContext(getDataSource());

1
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/MetaModelDataContextMongodb.java
View file

@ -49,6 +49,7 @@ public class MetaModelDataContextMongodb implements MetaModelDataContextProvider
protected Mongo mongo = null;
@Override
public DataContext getDataContext() {
//MongoDbDataContextBean dataContext = new MongoDbDataContextBean(getMongodbConnection());
///dataContext.setRegisterMBean(true);

2
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/MetaModelDataContextXmlDom.java
View file

@ -38,7 +38,7 @@ public class MetaModelDataContextXmlDom implements MetaModelDataContextProvider
private String file = null;
private boolean autoFlattenTables = true;
@Override
public DataContext getDataContext() {
if (file==null) {
throw new NullPointerException("Can's provided data context with null file.");

1
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/MetaModelDataContextXmlSax.java
View file

@ -45,6 +45,7 @@ public class MetaModelDataContextXmlSax implements MetaModelDataContextProvider
tableSchemas = new ArrayList<XmlSaxTableDef>(5);
}
@Override
public DataContext getDataContext() {
if (file==null) {
throw new NullPointerException("Can's provided data context with null file.");

16
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/MetaModelVascBackend.java
View file

@ -211,6 +211,7 @@ public class MetaModelVascBackend extends AbstractVascBackend<Row> {
return q;
}
@Override
public VascBackendResult<Row> execute(VascBackendState state) throws VascBackendException {
Schema schema = dataContext.getDefaultSchema();
Table t = schema.getTableByName(table);
@ -262,32 +263,37 @@ public class MetaModelVascBackend extends AbstractVascBackend<Row> {
return new DefaultVascBackendResult<Row>(result);
}
@Override
public void persist(Row object) throws VascBackendException {
if (crudDataContext==null) {
return;
}
crudDataContext.persist((UpdateableRow) object);
}
@Override
public Row merge(Row object) throws VascBackendException {
if (crudDataContext==null) {
return object;
}
return crudDataContext.merge((UpdateableRow) object);
}
@Override
public void delete(Row object) throws VascBackendException {
if (crudDataContext==null) {
return;
}
crudDataContext.delete((UpdateableRow) object);
}
@Override
public RowVascEntryFieldValue provideVascEntryFieldValue() {
return new RowVascEntryFieldValue();
}
@Override
public VascEntryRecordCreator<Row> provideVascEntryRecordCreator() {
return new RowVascEntryRecordCreator(crudDataContext,crudDataContext.getDefaultSchema().getTableByName(table));
}

8
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/MongoDbDataContextSchemaDetector.java
View file

@ -65,14 +65,19 @@ public class MongoDbDataContextSchemaDetector /* implements MetaModelSchemaDetec
schema = walker.detectSchema(mongoDb, getMainSchemaName());
return schema;
}
@Override
protected String getMainSchemaName() throws MetaModelException {
return mongoDb.getName();
}
@Override
protected DataSet materializeMainSchemaTable(Table table, Column[] columns, int maxRows) {
return materializeMainSchemaTableInternal(table, columns, null, maxRows, true);
}
// Overidded these method because they do not use the getMainSchema() method
@Override
public DataSet executeQuery(Query query) {
// Check for queries containing only simple selects and where clauses,
// or if it is a COUNT(*) query.
@ -170,6 +175,7 @@ public class MongoDbDataContextSchemaDetector /* implements MetaModelSchemaDetec
return _queryPostProcessed;
}
@Override
public SelectItem[] getSelectItems() {
return _selectItems;
}
@ -192,6 +198,7 @@ public class MongoDbDataContextSchemaDetector /* implements MetaModelSchemaDetec
}
}
@Override
public boolean next() {
if (_cursor.hasNext()) {
_dbObject = _cursor.next();
@ -202,6 +209,7 @@ public class MongoDbDataContextSchemaDetector /* implements MetaModelSchemaDetec
}
}
@Override
public Row getRow() {
if (_dbObject == null) {
return null;

7
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/RowVascEntryFieldValue.java
View file

@ -12,10 +12,11 @@ import net.forwardfire.vasc.backend.metamodel.crud.UpdateableRow;
public class RowVascEntryFieldValue implements VascEntryFieldValue<Row> {
private static final long serialVersionUID = -806674640688182132L;
/**
* @see net.forwardfire.vasc.backend.VascEntryFieldValue#getValue(java.lang.String, java.lang.Object)
*/
@Override
public Serializable getValue(String backendName, Row record) throws VascBackendException {
if (backendName==null) {
throw new NullPointerException("Can't get value of null backendName.");
@ -48,6 +49,7 @@ public class RowVascEntryFieldValue implements VascEntryFieldValue<Row> {
/**
* @see net.forwardfire.vasc.backend.VascEntryFieldValue#getDisplayValue(java.lang.String, java.lang.Object)
*/
@Override
public String getDisplayValue(String backendName, Row record) throws VascBackendException {
Object fieldValue = getValue(backendName,record);
if (fieldValue==null) {
@ -55,10 +57,11 @@ public class RowVascEntryFieldValue implements VascEntryFieldValue<Row> {
}
return fieldValue.toString();
}
/**
* @see net.forwardfire.vasc.backend.VascEntryFieldValue#setValue(java.lang.String, java.lang.Object, java.lang.Object)
*/
@Override
public void setValue(String backendName, Row record,Serializable value) throws VascBackendException {
if (record instanceof UpdateableRow) {
UpdateableRow row = (UpdateableRow)record;

3
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/RowVascEntryRecordCreator.java
View file

@ -17,7 +17,8 @@ public class RowVascEntryRecordCreator implements VascEntryRecordCreator<Row> {
this.dataContext=dataContext;
this.table=table;
}
@Override
public Row newRecord() throws VascBackendException {
return dataContext.createRow(table);
}

4
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/bundle/ResourceBundleDataContext.java
View file

@ -218,8 +218,11 @@ public class ResourceBundleDataContext extends QueryPostprocessDataContext imple
final Iterator<Row> resultData = result.iterator();
return new AbstractDataSet() {
int resultCount = 0;
@Override
public SelectItem[] getSelectItems() { return selectItems; }
@Override
public Row getRow() { return resultData.next(); }
@Override
public boolean next() {
if (maxRows > 0 && resultCount++ > maxRows) {
return false;
@ -229,6 +232,7 @@ public class ResourceBundleDataContext extends QueryPostprocessDataContext imple
};
}
@Override
public void executeUpdate(UpdateScript update) {
update.run(resourceBundleUpdateExecutor);
}

1
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/bundle/ResourceBundleDataControl.java
View file

@ -135,6 +135,7 @@ public class ResourceBundleDataControl extends Control {
/**
* Does the loading of the ResourceBundle
*/
@Override
public ResourceBundle newBundle(String baseName, Locale localeRequested, String format, ClassLoader loader, boolean reload) throws IllegalAccessException, InstantiationException, IOException {
long startTime = System.currentTimeMillis();

33
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/bundle/ResourceBundleUpdateExecutor.java
View file

@ -52,37 +52,56 @@ public class ResourceBundleUpdateExecutor extends AbstractUpdateCallback {
return isDataContextWritable();
}
@Override
public boolean isDeleteSupported() {
return isDataContextWritable();
}
@Override
public boolean isDropTableSupported() {
return isDataContextWritable();
}
@Override
public TableCreationBuilder createTable(final Schema schema, final String name) throws IllegalArgumentException, IllegalStateException {
TableCreationBuilder result = new TableCreationBuilder() {
@Override
public Table toTable() { return execute(); }
@Override
public String toSql() { return "nosql"; }
@Override
public TableCreationBuilder like(Table table) { return this; }
@Override
public ColumnCreationBuilder withColumn(String name) {
//return new ColumnCreationBuilderImpl(this,new MutableColumn(name));
final TableCreationBuilder parent = this;
return new ColumnCreationBuilder() {
@Override
public ColumnCreationBuilder withColumn(String name) { return this; }
@Override
public ColumnCreationBuilder ofType(ColumnType type) { return this; }
@Override
public ColumnCreationBuilder ofSize(int size) { return this; }
@Override
public ColumnCreationBuilder ofNativeType(String nativeType) { return this; }
@Override
public ColumnCreationBuilder nullable(boolean nullable) { return this; }
@Override
public ColumnCreationBuilder asPrimaryKey() { return this; }
@Override
public ColumnCreationBuilder like(Column column) { return this; }
@Override
public TableCreationBuilder like(Table table) { return this; }
@Override
public String toSql() { return "nosql"; }
@Override
public Table toTable() { return execute(); }
@Override
public Table execute() throws MetaModelException { return parent.execute();}
};
}
@Override
public Table execute() throws MetaModelException {
File file = new File(name);
Properties p = new Properties();
@ -98,18 +117,22 @@ public class ResourceBundleUpdateExecutor extends AbstractUpdateCallback {
};
return result;
}
@Override
public TableDropBuilder dropTable(Table table) throws IllegalArgumentException, IllegalStateException,UnsupportedOperationException {
TableDropBuilder result = new AbstractTableDropBuilder(table) {
@Override
public void execute() throws MetaModelException {
resourceBundleDataControl.removeBundle(getTable().getName());
}
};
return result;
}
@Override
public RowInsertionBuilder insertInto(final Table table) throws IllegalArgumentException, IllegalStateException,UnsupportedOperationException {
RowInsertionBuilder result = new AbstractRowInsertionBuilder<UpdateCallback>(this, table) {
@Override
public void execute() throws MetaModelException {
Properties data = resourceBundleDataControl.getBundleData(table.getName());
Object[] values = getValues();
@ -118,9 +141,11 @@ public class ResourceBundleUpdateExecutor extends AbstractUpdateCallback {
};
return result;
}
@Override
public RowDeletionBuilder deleteFrom(final Table table) throws IllegalArgumentException, IllegalStateException,UnsupportedOperationException {
RowDeletionBuilder result = new AbstractRowDeletionBuilder(table) {
@Override
public void execute() throws MetaModelException {
DataSet ds = resourceBundleDataContext.materializeMainSchemaTable(getTable(),getTable().getColumns(),0);
Properties data = resourceBundleDataControl.getBundleData(table.getName());

11
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/crud/AbstractCrudDataContext.java
View file

@ -37,13 +37,16 @@ abstract public class AbstractCrudDataContext implements CrudDataContext {
return this;
}
@Override
public UpdateableRow createRow(Table table) {
return wrapOrCreateToUpdateableRow(null,table);
}
@Override
public void persist(final UpdateableRow row) {
UpdateableDataContext dataContext = abstractProviderUpdateableDataContext();
dataContext.executeUpdate(new UpdateScript() {
@Override
public void run(UpdateCallback backendImpl) {
RowInsertionBuilder query = backendImpl.insertInto(row.getTable());
for (int i=0;i<row.size();i++) {
@ -58,7 +61,8 @@ abstract public class AbstractCrudDataContext implements CrudDataContext {
}
});
}
@Override
public UpdateableRow merge(final UpdateableRow row) {
for (String column:row.getPrimaryKeys()) {
if (row.getValue(column)==null) {
@ -67,6 +71,7 @@ abstract public class AbstractCrudDataContext implements CrudDataContext {
}
UpdateableDataContext dataContext = abstractProviderUpdateableDataContext();
dataContext.executeUpdate(new UpdateScript() {
@Override
public void run(UpdateCallback backendImpl) {
Object qWhere = backendImpl.update(row.getTable());
boolean first = true;
@ -109,10 +114,12 @@ abstract public class AbstractCrudDataContext implements CrudDataContext {
ds.close();
return rowResult;
}
@Override
public void delete(final UpdateableRow row) {
UpdateableDataContext dataContext = abstractProviderUpdateableDataContext();
dataContext.executeUpdate(new UpdateScript() {
@Override
public void run(UpdateCallback backendImpl) {
Object qWhere = backendImpl.deleteFrom(row.getTable());
boolean first = true;

12
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/crud/AbstractRow.java
View file

@ -77,6 +77,7 @@ abstract public class AbstractRow implements Row,RowLocal {
return result;
}
@Override
public void setStyle(int index,Style style) {
MetaRowData metaRow = metaData.get(index);
metaRow.style=style;
@ -95,6 +96,8 @@ abstract public class AbstractRow implements Row,RowLocal {
// ==== Start interface
@Override
public Object[] getValues() {
Object[] result = new Object[size()];
for (int i=0;i<size();i++) {
@ -103,14 +106,17 @@ abstract public class AbstractRow implements Row,RowLocal {
return result;
}
@Override
public Object getValue(SelectItem item) {
return getValue(indexOf(item));
}
@Override
public Object getValue(Column column) {
return getValue(indexOf(column));
}
@Override
public int indexOf(SelectItem item) {
if (item == null) {
return UpdateableRow.INDEX_NOT_FOUND;
@ -125,6 +131,7 @@ abstract public class AbstractRow implements Row,RowLocal {
return UpdateableRow.INDEX_NOT_FOUND;
}
@Override
public int indexOf(Column column) {
if (column == null) {
return UpdateableRow.INDEX_NOT_FOUND;
@ -133,20 +140,24 @@ abstract public class AbstractRow implements Row,RowLocal {
return indexOf(selectItem);
}
@Override
public SelectItem[] getSelectItems() {
List<SelectItem> list = getIndexedSelectItemList();
SelectItem[] result = new SelectItem[list.size()];
return list.toArray(result);
}
@Override
public Style getStyle(SelectItem item) {
return getStyle(indexOf(item));
}
@Override
public Style getStyle(Column column) {
return getStyle(indexOf(column));
}
@Override
public Style getStyle(int index) throws IndexOutOfBoundsException {
MetaRowData metaRow = getMetaRowData(index);
if (metaRow==null) {
@ -158,6 +169,7 @@ abstract public class AbstractRow implements Row,RowLocal {
return metaRow.style;
}
@Override
public int size() {
return metaData.size();
}

7
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/crud/AbstractUpdateableRow.java
View file

@ -16,7 +16,8 @@ import org.eobjects.metamodel.schema.Column;
@SuppressWarnings("serial")
abstract public class AbstractUpdateableRow extends AbstractRow implements UpdateableRow {
// TODO: rm / move getValue and indexOf to AbstractRow after UpdateableRow interface change
// TODO: rm / move getValue and indexOf to AbstractRow after UpdateableRow interface change
@Override
public Object getValue(String columnName) {
return getValue(indexOf(columnName));
}
@ -43,18 +44,22 @@ abstract public class AbstractUpdateableRow extends AbstractRow implements Updat
}
}
@Override
public void setValue(String columnName,Object object) {
setValue(indexOf(columnName), object);
}
@Override
public void setValue(SelectItem selectItem,Object object) {
setValue(indexOf(selectItem),object);
}
@Override
public void setValue(Column column,Object object) {
setValue(indexOf(column),object);
}
@Override
public String[] getPrimaryKeys() {
List<String> primaryKeys = getPrimaryKeysList();
return primaryKeys.toArray(new String[primaryKeys.size()]);

47
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/crud/CrudDataContextImpl.java
View file

@ -40,7 +40,8 @@ public class CrudDataContextImpl extends AbstractCrudDataContext implements Abst
public void overridePrimaryKeysForTable(String table,List<String> keys) {
tableKeys.put(table, keys);
}
@Override
public List<String> getPrimaryKeysForTable(Table table) {
List<String> keys = tableKeys.get(table.getName());
if (keys!=null) {
@ -92,6 +93,7 @@ public class CrudDataContextImpl extends AbstractCrudDataContext implements Abst
* Checks if backend dataContextDelegate has native support for UpdateableRowDataContext.
* If not then automatic wrap full DataSet data to UpdateableRow
*/
@Override
public DataSet executeQuery(Query query) throws MetaModelException {
if (dataContextDelegate instanceof UpdateableRowDataContext) {
return ((UpdateableRowDataContext) dataContextDelegate).crudExecuteQuery(this,query);
@ -105,6 +107,7 @@ public class CrudDataContextImpl extends AbstractCrudDataContext implements Abst
* If so then use api to start query builder with this datacontext.
* Else use default InitFromBuilderImpl query builder.
*/
@Override
public InitFromBuilder query() {
if (dataContextDelegate instanceof UpdateableRowDataContext) {
return ((UpdateableRowDataContext) dataContextDelegate).crudCreateQuery(this);
@ -115,15 +118,13 @@ public class CrudDataContextImpl extends AbstractCrudDataContext implements Abst
// === Bean properties
/**
* @return the checkPrimaryKeysAllRows
*/
public boolean isCheckPrimaryKeysAllRows() {
return checkPrimaryKeysAllRows;
}
/**
* @param checkPrimaryKeysAllRows the checkPrimaryKeysAllRows to set
*/
@ -131,86 +132,94 @@ public class CrudDataContextImpl extends AbstractCrudDataContext implements Abst
this.checkPrimaryKeysAllRows = checkPrimaryKeysAllRows;
}
// === Start wrapper to dataContextDelegate
/**
* @see org.eobjects.metamodel.UpdateableDataContext#executeUpdate(org.eobjects.metamodel.UpdateScript)
*/
@Override
public void executeUpdate(UpdateScript arg0) {
dataContextDelegate.executeUpdate(arg0);
}
/**
* @see org.eobjects.metamodel.DataContext#getColumnByQualifiedLabel(java.lang.String)
*/
@Override
public Column getColumnByQualifiedLabel(String arg0) {
return dataContextDelegate.getColumnByQualifiedLabel(arg0);
}
/**
* @see org.eobjects.metamodel.DataContext#getDefaultSchema()
*/
@Override
public Schema getDefaultSchema() throws MetaModelException {
return dataContextDelegate.getDefaultSchema();
}
/**
* @see org.eobjects.metamodel.DataContext#getSchemaByName(java.lang.String)
*/
@Override
public Schema getSchemaByName(String arg0) throws MetaModelException {
return dataContextDelegate.getSchemaByName(arg0);
}
/**
* @see org.eobjects.metamodel.DataContext#getSchemaNames()
*/
@Override
public String[] getSchemaNames() throws MetaModelException {
return dataContextDelegate.getSchemaNames();
}
/**
* @see org.eobjects.metamodel.DataContext#getSchemas()
*/
@Override
public Schema[] getSchemas() throws MetaModelException {
return dataContextDelegate.getSchemas();
}
/**
* @see org.eobjects.metamodel.DataContext#getTableByQualifiedLabel(java.lang.String)
*/
@Override
public Table getTableByQualifiedLabel(String arg0) {
return dataContextDelegate.getTableByQualifiedLabel(arg0);
}
/**
* @see org.eobjects.metamodel.DataContext#refreshSchemas()
*/
@Override
public DataContext refreshSchemas() {
return dataContextDelegate.refreshSchemas();
}
/**
* @see org.eobjects.metamodel.DataContext#parseQuery(java.lang.String)
*/
@Override
public Query parseQuery(String queryString) throws MetaModelException {
return dataContextDelegate.parseQuery(queryString);
}
/**
* @see org.eobjects.metamodel.DataContext#executeQuery(java.lang.String)
*/
@Override
public DataSet executeQuery(String queryString) throws MetaModelException {
return dataContextDelegate.executeQuery(queryString);
}
@Override
public CompiledQuery compileQuery(Query q) throws MetaModelException {
return dataContextDelegate.compileQuery(q);
}
@Override
public DataSet executeQuery(CompiledQuery cq, Object... args) {
return dataContextDelegate.executeQuery(cq, args);
}

10
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/crud/UpdateableRowMapImpl.java
View file

@ -39,29 +39,35 @@ public class UpdateableRowMapImpl extends AbstractUpdateableRow {
// interface
@Override
public Table getTable() {
return table;
}
@Override
public List<String> getPrimaryKeysList() {
return primaryKeys;
}
@Override
public void setValue(int index, Object value) throws IndexOutOfBoundsException {
if (index == UpdateableRow.INDEX_NOT_FOUND) {
throw new IndexOutOfBoundsException("Can't save value without key index: "+UpdateableRow.INDEX_NOT_FOUND+" value:"+value);
}
dataMap.put(index, value);
}
@Override
public Object getValue(int index) throws IndexOutOfBoundsException {
return dataMap.get(index);
}
@Override
public Row getSubSelection(SelectItem[] selectItems) {
return getSubSelectionFromImpl(new UpdateableRowMapImpl(table,primaryKeys,selectItems),selectItems);
}
@Override
public Row getSubSelection(DataSetHeader header) {
return getSubSelection(header.getSelectItems());
}

1
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/jndi/JndiDataContextObjectFactory.java
View file

@ -42,6 +42,7 @@ public class JndiDataContextObjectFactory implements ObjectFactory {
/**
* @see javax.naming.spi.ObjectFactory#getObjectInstance(java.lang.Object, javax.naming.Name, javax.naming.Context, java.util.Hashtable)
*/
@Override
synchronized public Object getObjectInstance(Object obj, Name namePath, Context nameCtx,Hashtable<?, ?> env) throws Exception {
// Create only once.

1
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/jndi/JndiDataContextProvider.java
View file

@ -19,6 +19,7 @@ public class JndiDataContextProvider implements DataContextProvider {
/**
* Returns an DataContext object from the jndi tree.
*/
@Override
public DataContext getDataContext() {
try {
InitialContext context = new InitialContext();

26
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/jndi/JndiReadOnlyDataContext.java
View file

@ -17,47 +17,73 @@ import org.eobjects.metamodel.schema.Table;
* @version 1.0 May 22, 2012
*/
public class JndiReadOnlyDataContext /* extends DataContextProxy */ implements DataContext {
private DataContext proxyDataContext = null;
public JndiReadOnlyDataContext(DataContext proxyDataContext) {
this.proxyDataContext=proxyDataContext;
}
@Override
public DataSet executeQuery(Query arg0) throws MetaModelException {
return proxyDataContext.executeQuery(arg0);
}
@Override
public Column getColumnByQualifiedLabel(String arg0) {
return proxyDataContext.getColumnByQualifiedLabel(arg0);
}
@Override
public Schema getDefaultSchema() throws MetaModelException {
return proxyDataContext.getDefaultSchema();
}
@Override
public Schema getSchemaByName(String arg0) throws MetaModelException {
return proxyDataContext.getSchemaByName(arg0);
}
@Override
public String[] getSchemaNames() throws MetaModelException {
return proxyDataContext.getSchemaNames();
}
@Override
public Schema[] getSchemas() throws MetaModelException {
return proxyDataContext.getSchemas();
}
@Override
public Table getTableByQualifiedLabel(String arg0) {
return proxyDataContext.getTableByQualifiedLabel(arg0);
}
@Override
public InitFromBuilder query() {
return proxyDataContext.query();
}
@Override
public DataContext refreshSchemas() {
return proxyDataContext.refreshSchemas();
}
@Override
public Query parseQuery(String queryString) throws MetaModelException {
return proxyDataContext.parseQuery(queryString);
}
@Override
public DataSet executeQuery(String queryString) throws MetaModelException {
return proxyDataContext.executeQuery(queryString);
}
@Override
public CompiledQuery compileQuery(Query q) throws MetaModelException {
return proxyDataContext.compileQuery(q);
}
@Override
public DataSet executeQuery(CompiledQuery cq, Object... args) {
return proxyDataContext.executeQuery(cq, args);

1
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/jndi/loader/JndiCsvDataContextLoader.java
View file

@ -22,6 +22,7 @@ public class JndiCsvDataContextLoader implements JndiDataContextLoader {
setUseUrlSource(useUrlSource);
}
@Override
public DataContext loadDataContext(JndiDataContextLoaderConfig config) {
if (useUrlSource) {
return new CsvDataContext(config.checkBackendUrl(),createCsvConfig(config.getBackendParameters()));

1
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/jndi/loader/JndiJdbcDataContextLoader.java
View file

@ -26,6 +26,7 @@ public class JndiJdbcDataContextLoader implements JndiDataContextLoader {
setUseDataSource(useDataSource);
}
@Override
public DataContext loadDataContext(JndiDataContextLoaderConfig config) {
if (useDataSource) {
if (config.getBackendUrl()==null) {

1
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/jndi/loader/JndiMongodbDataContextLoader.java
View file

@ -29,6 +29,7 @@ public class JndiMongodbDataContextLoader implements JndiDataContextLoader {
setUseJndiResource(useJndiResource);
}
@Override
public DataContext loadDataContext(JndiDataContextLoaderConfig config) {
//MongoDbDataContextBean result = null;
DB mongoDb = null;

1
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/jndi/loader/JndiXmlDomDataContextLoader.java
View file

@ -19,6 +19,7 @@ public class JndiXmlDomDataContextLoader implements JndiDataContextLoader {
setUseUrlSource(useUrlSource);
}
@Override
public DataContext loadDataContext(JndiDataContextLoaderConfig config) {
boolean autoFlattenTables = true;
if ("false".equalsIgnoreCase(config.getBackendParameters().get("autoFlattenTables"))) {

2
vasc-backend/vasc-backend-metamodel/src/main/java/net/forwardfire/vasc/backend/metamodel/jndi/loader/JndiXmlSaxDataContextLoader.java
View file

@ -29,12 +29,14 @@ public class JndiXmlSaxDataContextLoader implements JndiDataContextLoader {
setUseUrlSource(useUrlSource);
}
@Override
public DataContext loadDataContext(JndiDataContextLoaderConfig config) {
List<XmlSaxTableDef> tableSchemas = createXmlSaxConfig(config.getJndiObjectName(),config.getBackendParameters());
XmlSaxTableDef[] args = new XmlSaxTableDef[tableSchemas.size()];
if (useUrlSource) {
final URL url = config.checkBackendUrl();
return new XmlSaxDataContext(new Ref<InputSource>() { // TODO: missing constructor in XmlSaxDataContext
@Override
public InputSource get() {
InputStream in = null;
try {

1
vasc-backend/vasc-backend-metamodel/src/test/java/SwingLoadTest.java
View file

@ -21,6 +21,7 @@ public class SwingLoadTest {
CsvDataContext dataContext = new CsvDataContext(tmpFile);
final Schema schema = dataContext.getDefaultSchema();
dataContext.executeUpdate(new UpdateScript() {
@Override
public void run(UpdateCallback cb) {
MutableRef<Table> tableRef = new MutableRef<Table>();
table = cb.createTable(schema, "table").withColumn("column").execute();

3
vasc-backend/vasc-backend-metamodel/src/test/java/net/forwardfire/vasc/backend/metamodel/crud/CrudContextTest.java
View file

@ -1,6 +1,7 @@
package net.forwardfire.vasc.backend.metamodel.crud;
import java.io.File;
import org.eobjects.metamodel.DataContext;
import org.eobjects.metamodel.UpdateCallback;
import org.eobjects.metamodel.UpdateScript;
@ -11,6 +12,7 @@ import org.eobjects.metamodel.data.Row;
import org.eobjects.metamodel.schema.Schema;
import org.eobjects.metamodel.schema.Table;
import org.eobjects.metamodel.util.MutableRef;
import junit.framework.TestCase;
public class CrudContextTest extends TestCase {
@ -24,6 +26,7 @@ public class CrudContextTest extends TestCase {
final Schema schema = dataContext.getDefaultSchema();
final MutableRef<Table> tableRef = new MutableRef<Table>();
dataContext.executeUpdate(new UpdateScript() {
@Override
public void run(UpdateCallback cb) {
Table table = null;
int idx = 0;

1
vasc-backend/vasc-backend-mongodb/src/main/java/net/forwardfire/vasc/backend/mongodb/MongodbConnectionProviderImpl.java
View file

@ -49,6 +49,7 @@ public class MongodbConnectionProviderImpl implements MongodbConnectionProvider
protected static Mongo mongo = null;
protected static DB db = null;
@Override
public DB getMongodbConnection() {
if (db!=null) {
return db;

6
vasc-backend/vasc-backend-mongodb/src/main/java/net/forwardfire/vasc/backend/mongodb/MongodbVascBackend.java
View file

@ -106,6 +106,7 @@ public class MongodbVascBackend extends AbstractVascBackend<BasicDBObject> {
return query;
}
@Override
public VascBackendResult<BasicDBObject> execute(VascBackendState state) throws VascBackendException {
DBCollection coll = getDBCollection();
DBObject query = createFilterQuery(state);
@ -122,11 +123,13 @@ public class MongodbVascBackend extends AbstractVascBackend<BasicDBObject> {
return new DefaultVascBackendResult<BasicDBObject>(result);
}
@Override
public void persist(BasicDBObject object) throws VascBackendException {
DBCollection coll = getDBCollection();
coll.insert(object);
}
@Override
public BasicDBObject merge(BasicDBObject row) throws VascBackendException {
DBCollection coll = getDBCollection();
DBObject query = new BasicDBObject();
@ -136,6 +139,7 @@ public class MongodbVascBackend extends AbstractVascBackend<BasicDBObject> {
return row;
}
@Override
public void delete(BasicDBObject object) throws VascBackendException {
DBCollection coll = getDBCollection();
DBObject query = new BasicDBObject();
@ -143,10 +147,12 @@ public class MongodbVascBackend extends AbstractVascBackend<BasicDBObject> {
coll.remove(query); // remove by _id
}
@Override
public MongodbVascEntryFieldValue provideVascEntryFieldValue() {
return new MongodbVascEntryFieldValue();
}
@Override
public VascEntryRecordCreator<BasicDBObject> provideVascEntryRecordCreator() {
return new MongodbVascEntryRecordCreator();
}

3
vasc-backend/vasc-backend-mongodb/src/main/java/net/forwardfire/vasc/backend/mongodb/MongodbVascEntryFieldValue.java
View file

@ -39,15 +39,18 @@ public class MongodbVascEntryFieldValue implements VascEntryFieldValue<BasicDBOb
private static final long serialVersionUID = -7371273796529818557L;
@Override
public Serializable getValue(String backendName, BasicDBObject row) throws VascBackendException {
Serializable data = (Serializable) row.get(backendName);
return data;
}
@Override
public String getDisplayValue(String field, BasicDBObject row) throws VascBackendException {
return ""+getValue(field,row);
}
@Override
public void setValue(String backendName, BasicDBObject row, Serializable value) throws VascBackendException {
row.put(backendName, value);
}

1
vasc-backend/vasc-backend-mongodb/src/main/java/net/forwardfire/vasc/backend/mongodb/MongodbVascEntryRecordCreator.java
View file

@ -38,6 +38,7 @@ public class MongodbVascEntryRecordCreator implements VascEntryRecordCreator<Bas
private static final long serialVersionUID = -9213830731796787384L;
@Override
public BasicDBObject newRecord() throws VascBackendException {
return new BasicDBObject();
}