Notes

import com.adventnet.ds.query.Column;
import com.manageengine.ela.server.common.data.conversion.DataConverter;
import com.manageengine.ela.server.common.data.conversion.RowDataTransformer;
import com.manageengine.ela.server.common.response.BaseStatusCode;
import org.json.JSONException;
import org.json.JSONObject;

import java.util.ArrayList;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.logging.Logger;


/**
* @author praveen.aj
*
* Created at Nov 17, 2016
*/
public class ClientDBDataFormatter extends ClientAbstractFormatter<Column>
{
private static final Map<Column, Long> COLUMN_TRANSFORMER_CACHE = new ConcurrentHashMap<>();

private static ClientDBDataFormatter instence = null;
private static final Logger LOGGER = Logger.getLogger(ClientDBDataFormatter.class.getName());

private ClientDBDataFormatter(){}
public static ClientDBDataFormatter getInstence()
{
if(instence == null)
{
instence = new ClientDBDataFormatter();
}
return instence;
}

@Override
protected boolean checkAndAddtransformerCache(Column data , Long transformerID)
{
if(!COLUMN_TRANSFORMER_CACHE.containsKey(data)) // TODO flow should be changed
{
COLUMN_TRANSFORMER_CACHE.put(data, transformerID);
}
return true;
}

@Override
protected Column getNewColumn(JSONObject singleObject) throws JSONException
{
return Column.getColumn(singleObject.getString("COLUMN_TABLENAME"), singleObject.getString("COLUMNNAME")); //No I18N;
}

@Override
protected boolean isValidColumn(JSONObject singleObject) throws JSONException
{
if (singleObject.isNull("COLUMN_TABLENAME") || singleObject.getString("COLUMN_TABLENAME").isEmpty())
{
return false;
}
else
{
return true;
}
}

@Override
protected void fillDependentColumns(Long transformID , ArrayList<Column> columnList) throws BaseStatusCode
{
DataConverter<Column, Object> transformer = RowDataTransformer.getTransformer(transformID);
Object[] columns = transformer.getArguments();
if (columns != null)
{
for (Object col : columns)
{
if(col != null && col instanceof Column)
{
Column depdntCol = (Column) col;
if(!columnList.contains(depdntCol))
{
columnList.add(depdntCol);
}
}
}
}
}

@Override
protected DataConverter<Column , Object> getTransformer(Column data)
{
Long transformer = COLUMN_TRANSFORMER_CACHE.get(data); // need to handle this in better way
if(transformer != null)
{
try
{
return RowDataTransformer.getTransformer(transformer);
}
catch (BaseStatusCode e)
{
LOGGER.fine("Exception in convertion method collection : "+e.getMessage());
}
}
return null;
}

@Override
protected String getCustomResultKeyName(Column key)
{
return key.getTableAlias()+"_"+key.getColumnName();
}

@Override
protected boolean verifySkipListAndAllowedList(Column column, ArrayList<Column> skipList , ArrayList<Column> allowdList)
{
if((skipList != null && skipList.contains(column)) || (allowdList != null && !allowdList.contains(column)))
{
return false;
}
else
{
return true;
}

}


}