package test.sync4j;import sync4j.framework.engine.SyncItem;import sync4j.framework.engine.SyncItemImpl;import sync4j.framework.engine.SyncItemKey;import sync4j.framework.engine.SyncItemState;import sync4j.framework.engine.SyncProperty;import sync4j.framework.engine.source.AbstractSyncSource;import sync4j.framework.engine.source.SyncSource;import sync4j.framework.engine.source.SyncSourceException;import sync4j.framework.tools.beans.BeanInitializationException;import sync4j.framework.tools.beans.LazyInitBean;import javax.naming.InitialContext;import javax.naming.NamingException;import javax.sql.DataSource;import java.security.Principal;import java.sql.Connection;import java.sql.DatabaseMetaData;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Timestamp;import java.text.MessageFormat;import java.util.ArrayList;import java.util.List;public class TestSyncSource extends AbstractSyncSource implements SyncSource, LazyInitBean{	private static final String JDBC_RECORDSET_MIMETYPE = "application/vnd.syncml+xmlrecordset";	private static final String METADATA_COLUMN_NAME = "COLUMN_NAME";	private static final int SQL_GET_ALL_ITEMS = 0;	private static final int SQL_GET_ALL_ITEMS_SINCE = 1;	private static final int SQL_GET_ITEMS = 2;	private static final int SQL_GET_ITEMS_SINCE = 3;	private static final int SQL_DELETE_ITEM = 4;	private static final int SQL_ADD_ITEM = 5;	private static final int SQL_UPDATE_ITEM = 6;	private DataSource dataSource;	private String[] columnNames;	private String[] sqlStatements;	private String jndiName;	private String jdbcDriver;	private String urlConnection;	private String userConnection;	private String passwordConnection;	private String tableName;	private String keyColumnName;	private String timestampColumnName;	private String stateColumnName;	private String catalogName;	private String schemaName;	public TestSyncSource(){		setType(JDBC_RECORDSET_MIMETYPE);	}	public void init() throws BeanInitializationException{		//Initialize the jndi datasource if provided		if(jndiName != null && jndiName.length() > 0){			try{				dataSource = (DataSource)new InitialContext().lookup(jndiName);			}			catch(NamingException e){				throw new BeanInitializationException("Data source not found: " + jndiName, e);			}		}		//Get the table's column names (excluding key, timestamp, state columns)		Connection connection = null;		try{			connection = getConnection();			columnNames = getColumnNames(connection.getMetaData(), catalogName, schemaName, tableName);		}		catch(SQLException e){			throw new BeanInitializationException("SQL exception initializing " + getClass().getName(), e);		}		finally{			closeConnection(connection);		}		//Prepare sql statements		sqlStatements = buildSql();	}	public String getJndiName(){		return jndiName;	}	public void setJndiName(String jndiName){		this.jndiName = jndiName;	}	public String getJdbcDriver(){		return jdbcDriver;	}	public void setJdbcDriver(String jdbcDriver){		this.jdbcDriver = jdbcDriver;	}	public String getUrlConnection(){		return urlConnection;	}	public void setUrlConnection(String urlConnection){		this.urlConnection = urlConnection;	}	public String getUserConnection(){		return userConnection;	}	public void setUserConnection(String userConnection){		this.userConnection = userConnection;	}	public String getPasswordConnection(){		return passwordConnection;	}	public void setPasswordConnection(String passwordConnection){		this.passwordConnection = passwordConnection;	}	public String getTableName(){		return tableName;	}	public void setTableName(String tableName){		this.tableName = tableName;	}	public String getKeyColumnName(){		return keyColumnName;	}	public void setKeyColumnName(String keyColumnName){		this.keyColumnName = keyColumnName;	}	public String getTimestampColumnName(){		return timestampColumnName;	}	public void setTimestampColumnName(String timestampColumnName){		this.timestampColumnName = timestampColumnName;	}	public String getStateColumnName(){		return stateColumnName;	}	public void setStateColumnName(String stateColumnName){		this.stateColumnName = stateColumnName;	}	public String getCatalogName(){		return catalogName;	}	public void setCatalogName(String catalogName){		this.catalogName = catalogName;	}	public String getSchemaName(){		return schemaName;	}	public void setSchemaName(String schemaName){		this.schemaName = schemaName;	}	public String toString(){		StringBuffer sb = new StringBuffer(super.toString());		sb.append(" - { ");		sb.append("name: ").append(name).append(", ");		sb.append("jndiName: ").append(jndiName).append(", ");		sb.append("jdbcDriver: ").append(jdbcDriver).append(", ");		sb.append("urlConnection: ").append(urlConnection).append(", ");		sb.append("userConnection: ").append(userConnection).append(", ");		sb.append("passwordConnection: ").append(passwordConnection).append(", ");		sb.append("tableName: ").append(tableName).append(", ");		sb.append("keyColumnName: ").append(keyColumnName).append(", ");		sb.append("timestampColumnName: ").append(timestampColumnName).append(", ");		sb.append("stateColumnName: ").append(stateColumnName).append(" }");		return sb.toString();	}	public boolean isModified(Principal principal, Timestamp since){		return true;	}	public SyncItem[] getAllSyncItems(Principal principal) throws SyncSourceException{		//Get all sync items		return getSyncItems(SyncItemState.UNKNOWN, null);	}	public SyncItemKey[] getDeletedSyncItemKeys(Principal principal, Timestamp since) throws SyncSourceException{		return null;	}	public SyncItem[] getDeletedSyncItems(Principal principal, Timestamp since) throws SyncSourceException{		//Get all deleted sync items since the specified date		return getSyncItems(SyncItemState.DELETED, since);	}	public SyncItemKey[] getNewSyncItemKeys(Principal principal, Timestamp since) throws SyncSourceException{		return null;	}	public SyncItem[] getNewSyncItems(Principal principal, Timestamp since) throws SyncSourceException{		//Get all new sync items since the specified date		return getSyncItems(SyncItemState.NEW, since);	}	public SyncItemKey[] getUpdatedSyncItemKeys(Principal principal, Timestamp since) throws SyncSourceException{		return null;	}	public SyncItem[] getUpdatedSyncItems(Principal principal, Timestamp since) throws SyncSourceException{		//Get all updated sync items since the specified date		return getSyncItems(SyncItemState.UPDATED, since);	}	public void removeSyncItem(Principal principal, SyncItem syncItem) throws SyncSourceException{		//Delete a sync item		Connection connection = null;		try{			connection = getConnection();			PreparedStatement statement = connection.prepareStatement(sqlStatements[SQL_DELETE_ITEM]);			statement.setTimestamp(1, new Timestamp(System.currentTimeMillis()));			statement.setString(2, syncItem.getKey().getKeyAsString());			statement.executeUpdate();		}		catch(SQLException e){			throw new SyncSourceException("Error removing item " +				syncItem.getKey().getKeyAsString(), e);		}		finally{			closeConnection(connection);		}	}	public void removeSyncItems(Principal principal, SyncItem[] syncItems) throws SyncSourceException{		if(syncItems != null){			for(int i = 0; i < syncItems.length; i++){				removeSyncItem(principal, syncItems[i]);			}		}	}	public SyncItem setSyncItem(Principal principal, SyncItem syncItem) throws SyncSourceException{		//Set a sync item with specified item data		String[] values = xmlToValues(new String((byte[])syncItem.getPropertyValue(SyncItem.PROPERTY_BINARY_CONTENT)));		Timestamp timestamp = (Timestamp)syncItem.getPropertyValue(SyncItem.PROPERTY_TIMESTAMP);		Connection connection = null;		try{			//Try to update item			connection = getConnection();			PreparedStatement statement = connection.prepareStatement(sqlStatements[SQL_UPDATE_ITEM]);			statement.setString(1, String.valueOf(SyncItemState.UPDATED));			statement.setTimestamp(2, timestamp);			for(int i = 0; i < values.length; ++i){				statement.setString(i + 3, values[i]);			}			statement.setString(values.length + 3, syncItem.getKey().getKeyAsString());			if(statement.executeUpdate() != 0){				return syncItem;			}			//Update failed, add new item			try{				statement.close();			}			catch(SQLException e){			}			statement = connection.prepareStatement(sqlStatements[SQL_ADD_ITEM]);			statement.setString(1, String.valueOf(SyncItemState.NEW));			statement.setTimestamp(2, timestamp);			statement.setString(3, syncItem.getKey().getKeyAsString());			for(int i = 0; i < columnNames.length; ++i){				statement.setString(i + 4, values[i]);			}			statement.executeUpdate();		}		catch(SQLException e){			throw new SyncSourceException("Error setting item " +				syncItem.getKey().getKeyAsString(), e);		}		finally{			closeConnection(connection);		}		return syncItem;	}	private static String[] xmlToValues(String xml){		//Extract values from xml		List values = new ArrayList();		for(int end, offset = 0; offset < xml.length(); offset = end + 8){			offset = xml.indexOf("<field>", offset);			if(offset < 0){				break;			}			offset += 7;			end = xml.indexOf("</field>", offset);			if(end < 0){				break;			}			values.add(xml.substring(offset, end));		}		return (String[])values.toArray(new String[values.size()]);	}	public SyncItem[] setSyncItems(Principal principal, SyncItem[] syncItems) throws SyncSourceException{		//Set sync items with specified data		if(syncItems != null){			for(int i = 0; i < syncItems.length; i++){				setSyncItem(principal, syncItems[i]);			}		}		return syncItems;	}	public SyncItem getSyncItemFromId(Principal principal, SyncItemKey syncItemKey) throws SyncSourceException{		return null;	}	public SyncItem[] getSyncItemsFromIds(Principal principal, SyncItemKey[] syncItemsKeys) throws SyncSourceException{		return new SyncItem[0];	}	public SyncItem getSyncItemFromTwin(Principal principal, SyncItem syncItem) throws SyncSourceException{		return null;	}	public SyncItem[] getSyncItemsFromTwins(Principal principal, SyncItem[] syncItem) throws SyncSourceException{		return new SyncItem[0];	}	private SyncItem[] getSyncItems(char state, Timestamp since) throws SyncSourceException{		//Get sync items based on state and last modification timestamp		List items = new ArrayList();		Connection connection = null;		try{			connection = getConnection();			PreparedStatement statement;			if(state == SyncItemState.UNKNOWN){				//Get all items				if(since == null){					statement = connection.prepareStatement(sqlStatements[SQL_GET_ALL_ITEMS]);				}				//Get all items since timestamp				else{					statement = connection.prepareStatement(sqlStatements[SQL_GET_ALL_ITEMS_SINCE]);					statement.setTimestamp(1, since);				}			}			else{				//Get items with state				if(since == null){					statement = connection.prepareStatement(sqlStatements[SQL_GET_ITEMS]);					statement.setString(1, String.valueOf(state));				}				//Get items with state since timestamp				else{					statement = connection.prepareStatement(sqlStatements[SQL_GET_ITEMS_SINCE]);					statement.setString(1, String.valueOf(state));					statement.setTimestamp(2, since);				}			}			//Build sync items from the resultset			for(ResultSet rs = statement.executeQuery(); rs.next();){				items.add(rowToSyncItem(rs));			}		}		catch(SQLException e){			throw new SyncSourceException("Error getting items", e);		}		finally{			closeConnection(connection);		}		return (SyncItem[])items.toArray(new SyncItem[items.size()]);	}	private SyncItem rowToSyncItem(ResultSet rs) throws SQLException{		//Convert a database record to a sync item		StringBuffer xml = new StringBuffer("<record>\n");		for(int i = 0; i < columnNames.length; i++){			xml.append("<field>").append(rs.getString(columnNames[i])).append("</field>\n");		}		xml.append("</record>\n");		SyncItem item = new SyncItemImpl(this, rs.getString(keyColumnName),			rs.getString(stateColumnName).charAt(0));		item.setProperty(new SyncProperty(SyncItem.PROPERTY_BINARY_CONTENT,			xml.toString().getBytes()));		return item;	}	private Connection getConnection() throws SQLException{		if(dataSource != null){			return dataSource.getConnection();		}		try{			Class.forName(jdbcDriver);		}		catch(ClassNotFoundException e){			e.printStackTrace();		}		return DriverManager.getConnection(urlConnection, userConnection, passwordConnection);	}	private static void closeConnection(Connection connection){		if(connection != null){			try{				connection.close();			}			catch(SQLException e){			}		}	}	private String[] getColumnNames(DatabaseMetaData metaData, String catalog, String schema, String tableName) throws SQLException{		String catalogName = (catalog == null || catalog.length() <= 0) ? null : catalog;		String schemaName = (schema == null || schema.length() <= 0) ? metaData.getUserName() : schema;		ResultSet rs = metaData.getColumns(catalogName, schemaName, tableName, "%");		List columnNames = new ArrayList();		while(rs.next()){			String columnName = rs.getString(METADATA_COLUMN_NAME);			//Skip key, timestamp and state columns			if(!(keyColumnName.equalsIgnoreCase(columnName) ||				timestampColumnName.equalsIgnoreCase(columnName) ||				stateColumnName.equalsIgnoreCase(columnName)) &&				!columnNames.contains(columnName)){				columnNames.add(columnName);			}		}		try{			rs.close();		}		catch(SQLException e){		}		return (String[])columnNames.toArray(new String[columnNames.size()]);	}	private String[] buildSql(){		StringBuffer columns = new StringBuffer();		StringBuffer columnValues = new StringBuffer();		StringBuffer columnAssignments = new StringBuffer();		for(int i = 0; i < columnNames.length; ++i){			columns.append(", ").append(columnNames[i]);			columnValues.append(", ?");			columnAssignments.append(", ").append(columnNames[i]).append(" = ?");		}		Object[] args = new Object[]{			tableName,			stateColumnName,			timestampColumnName,			keyColumnName,			columns.toString(),			columnValues.toString(),			columnAssignments.toString()		};		String[] sql = new String[]{			"select * from {0}",			"select * from {0} where {2} > ?",			"select * from {0} where {1} = ?",			"select * from {0} where {1} = ? and {2} > ?",			"update {0} set {1} = ''D'', {2} = ? where {3} = ?",			"insert into {0} ({1}, {2}, {3}{4}) values(?, ?, ?{5})",			"update {0} set {1} = ?, {2} = ?{6} where {3} = ?"		};		for(int i = 0; i < sql.length; i++){			sql[i] = MessageFormat.format(sql[i], args);		}		return sql;	}}