remove the log throw anti-pattern. add a core package to cpo-core so …

cpo-cassandra/src/main/java/org/synchronoss/cpo/cassandra/CassandraBoundStatementCpoData.java

@@ -24,14 +24,14 @@
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.synchronoss.cpo.CpoException;
 import org.synchronoss.cpo.cassandra.meta.CassandraMethodMapEntry;
 import org.synchronoss.cpo.cassandra.meta.CassandraMethodMapper;
 import org.synchronoss.cpo.cassandra.transform.CassandraCpoTransform;
-import org.synchronoss.cpo.helper.ExceptionHelper;
-import org.synchronoss.cpo.meta.AbstractBindableCpoData;
-import org.synchronoss.cpo.meta.domain.CpoAttribute;
-import org.synchronoss.cpo.transform.CpoTransform;
+import org.synchronoss.cpo.core.CpoException;
+import org.synchronoss.cpo.core.helper.ExceptionHelper;
+import org.synchronoss.cpo.core.meta.AbstractBindableCpoData;
+import org.synchronoss.cpo.core.meta.domain.CpoAttribute;
+import org.synchronoss.cpo.core.transform.CpoTransform;
 
 /**
  * Helps manage data transfer between the CPO object and the Cassandra bound statement

cpo-cassandra/src/main/java/org/synchronoss/cpo/cassandra/CassandraBoundStatementFactory.java

@@ -28,13 +28,13 @@
 import java.util.List;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.synchronoss.cpo.*;
 import org.synchronoss.cpo.cassandra.meta.CassandraMethodMapper;
-import org.synchronoss.cpo.helper.ExceptionHelper;
-import org.synchronoss.cpo.meta.MethodMapper;
-import org.synchronoss.cpo.meta.domain.CpoAttribute;
-import org.synchronoss.cpo.meta.domain.CpoClass;
-import org.synchronoss.cpo.meta.domain.CpoFunction;
+import org.synchronoss.cpo.core.*;
+import org.synchronoss.cpo.core.helper.ExceptionHelper;
+import org.synchronoss.cpo.core.meta.MethodMapper;
+import org.synchronoss.cpo.core.meta.domain.CpoAttribute;
+import org.synchronoss.cpo.core.meta.domain.CpoClass;
+import org.synchronoss.cpo.core.meta.domain.CpoFunction;
 
 /**
  * CassandraBoundStatementFactory is the object that encapsulates the creation of the actual
@@ -67,7 +67,7 @@ public class CassandraBoundStatementFactory extends CpoStatementFactory implemen
    * @param orderBy A collection of orderbys to sort the objects
    * @param nativeQueries Additional sql to be embedded into the CpoFunction sql that is used to
    *     create the actual JDBC PreparedStatement
-   * @throws org.synchronoss.cpo.CpoException if a CPO error occurs
+   * @throws CpoException if a CPO error occurs
    */
   public <T> CassandraBoundStatementFactory(
       Session sess,

cpo-cassandra/src/main/java/org/synchronoss/cpo/cassandra/CassandraCpoAdapter.java

@@ -23,24 +23,25 @@
  */
 
 import com.datastax.driver.core.*;
+import java.lang.reflect.InvocationTargetException;
 import java.util.*;
 import java.util.function.Consumer;
 import java.util.stream.Stream;
 import java.util.stream.StreamSupport;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.synchronoss.cpo.*;
 import org.synchronoss.cpo.cassandra.meta.CassandraCpoAttribute;
 import org.synchronoss.cpo.cassandra.meta.CassandraCpoMetaDescriptor;
 import org.synchronoss.cpo.cassandra.meta.CassandraMethodMapper;
 import org.synchronoss.cpo.cassandra.meta.CassandraResultSetCpoData;
-import org.synchronoss.cpo.enums.Crud;
-import org.synchronoss.cpo.helper.ExceptionHelper;
-import org.synchronoss.cpo.meta.CpoMetaDescriptor;
-import org.synchronoss.cpo.meta.DataTypeMapEntry;
-import org.synchronoss.cpo.meta.domain.CpoAttribute;
-import org.synchronoss.cpo.meta.domain.CpoClass;
-import org.synchronoss.cpo.meta.domain.CpoFunction;
+import org.synchronoss.cpo.core.*;
+import org.synchronoss.cpo.core.enums.Crud;
+import org.synchronoss.cpo.core.helper.ExceptionHelper;
+import org.synchronoss.cpo.core.meta.CpoMetaDescriptor;
+import org.synchronoss.cpo.core.meta.DataTypeMapEntry;
+import org.synchronoss.cpo.core.meta.domain.CpoAttribute;
+import org.synchronoss.cpo.core.meta.domain.CpoClass;
+import org.synchronoss.cpo.core.meta.domain.CpoFunction;
 
 /**
  * CassandraCpoAdapter is an interface for a set of routines that are responsible for managing value
@@ -626,7 +627,7 @@ protected <T> T processSelectGroup(
       localLogger.info(buildCpoClassLogLine(criteriaObj.getClass(), Crud.RETRIEVE, groupName));
 
       try {
-        rObj = (T) bean.getClass().newInstance();
+        rObj = (T) bean.getClass().getDeclaredConstructor().newInstance();
       } catch (IllegalAccessException iae) {
         localLogger.error(
             "=================== Could not access default constructor for Class=<"
@@ -821,16 +822,27 @@ public boolean tryAdvance(Consumer<? super T> action) {
                     Row row = rs.one();
                     T bean = null;
                     try {
-                      bean = (T) result.getClass().newInstance();
+                      bean = (T) result.getClass().getDeclaredConstructor().newInstance();
                     } catch (IllegalAccessException iae) {
-                      localLogger.error(
-                          "=================== Could not access default constructor for Class=<"
+                      String msg =
+                          "Could not access default constructor for Class=<"
                               + result.getClass()
-                              + "> ==================");
-                      throw new CpoException(
-                          "Unable to access the constructor of the Return bean", iae);
+                              + ">";
+                      throw new CpoException(msg, iae);
                     } catch (InstantiationException iae) {
-                      throw new CpoException("Unable to instantiate Return bean", iae);
+                      throw new CpoException(
+                          "Unable to instantiate Return bean for Class=<" + result.getClass() + ">",
+                          iae);
+                    } catch (InvocationTargetException e) {
+                      throw new CpoException(
+                          "Unable to invoke constructor for Return bean Class=<"
+                              + result.getClass()
+                              + ">",
+                          e);
+                    } catch (NoSuchMethodException e) {
+                      throw new CpoException(
+                          "Constructor not found for Return bean Class=<" + result.getClass() + ">",
+                          e);
                     }
 
                     for (int k = 0; k < columnCount; k++) {

cpo-cassandra/src/main/java/org/synchronoss/cpo/cassandra/CassandraCpoAdapterFactory.java

@@ -22,11 +22,11 @@
  * ]]
  */
 
-import org.synchronoss.cpo.CpoAdapter;
-import org.synchronoss.cpo.CpoAdapterFactory;
-import org.synchronoss.cpo.CpoException;
-import org.synchronoss.cpo.CpoTrxAdapter;
-import org.synchronoss.cpo.jta.CpoXaResource;
+import org.synchronoss.cpo.core.CpoAdapter;
+import org.synchronoss.cpo.core.CpoAdapterFactory;
+import org.synchronoss.cpo.core.CpoException;
+import org.synchronoss.cpo.core.CpoTrxAdapter;
+import org.synchronoss.cpo.core.jta.CpoXaResource;
 
 /**
  * A factory for creating CassandraCpoAdapter

cpo-cassandra/src/main/java/org/synchronoss/cpo/cassandra/ClusterDataSourceInfo.java

@@ -28,8 +28,8 @@
 import java.util.List;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.synchronoss.cpo.AbstractDataSourceInfo;
-import org.synchronoss.cpo.CpoException;
+import org.synchronoss.cpo.core.AbstractDataSourceInfo;
+import org.synchronoss.cpo.core.CpoException;
 
 /**
  * Contains the information needed to connect to a Cassandra cluster

cpo-cassandra/src/main/java/org/synchronoss/cpo/cassandra/config/CassandraCpoConfigProcessor.java

@@ -27,15 +27,15 @@
 import java.util.Collection;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.synchronoss.cpo.CpoAdapterFactory;
-import org.synchronoss.cpo.CpoException;
 import org.synchronoss.cpo.cassandra.CassandraCpoAdapter;
 import org.synchronoss.cpo.cassandra.CassandraCpoAdapterFactory;
 import org.synchronoss.cpo.cassandra.ClusterDataSourceInfo;
 import org.synchronoss.cpo.cassandra.meta.CassandraCpoMetaDescriptor;
-import org.synchronoss.cpo.config.CpoConfigProcessor;
+import org.synchronoss.cpo.core.CpoAdapterFactory;
+import org.synchronoss.cpo.core.CpoException;
+import org.synchronoss.cpo.core.config.CpoConfigProcessor;
+import org.synchronoss.cpo.core.meta.CpoMetaDescriptor;
 import org.synchronoss.cpo.cpoconfig.*;
-import org.synchronoss.cpo.meta.CpoMetaDescriptor;
 
 /**
  * CassandraCpoConfigProcessor processes the datasource configuration file for cassandra. It pulls
@@ -55,7 +55,7 @@ public CpoAdapterFactory processCpoConfig(CtDataSourceConfig cpoConfig) throws C
     CpoAdapterFactory cpoAdapterFactory = null;
 
     if (cpoConfig == null || !(cpoConfig instanceof CtCassandraConfig)) {
-      throw new CpoException("Invalid Jdbc Configuration Information");
+      throw new CpoException("Invalid Cassandra Configuration Information");
     }
 
     CtCassandraConfig cassandraConfig = (CtCassandraConfig) cpoConfig;

cpo-cassandra/src/main/java/org/synchronoss/cpo/cassandra/config/ConfigInstantiator.java

@@ -26,8 +26,8 @@
 import java.lang.reflect.Method;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.synchronoss.cpo.CpoException;
-import org.synchronoss.cpo.helper.ExceptionHelper;
+import org.synchronoss.cpo.core.CpoException;
+import org.synchronoss.cpo.core.helper.ExceptionHelper;
 
 /**
  * Instantiates the Config file processor
@@ -53,7 +53,7 @@ public T instantiate(String className) throws CpoException {
     // Lets create the Factory
     try {
       Class factoryClass = Class.forName(className);
-      factoryMethodName = (FactoryMethodName) factoryClass.newInstance();
+      factoryMethodName = (FactoryMethodName) factoryClass.getDeclaredConstructor().newInstance();
       logger.debug("Created factory: " + className);
       Method factoryMethod = factoryClass.getMethod(factoryMethodName.getFactoryMethodName());
       return (T) factoryMethod.invoke(factoryMethodName);

cpo-cassandra/src/main/java/org/synchronoss/cpo/cassandra/exporter/CassandraMetaXmlObjectExporter.java

@@ -23,14 +23,14 @@
  */
 
 import org.synchronoss.cpo.cassandra.meta.CassandraCpoAttribute;
+import org.synchronoss.cpo.core.exporter.CoreMetaXmlObjectExporter;
+import org.synchronoss.cpo.core.exporter.MetaXmlObjectExporter;
+import org.synchronoss.cpo.core.meta.CpoMetaDescriptor;
+import org.synchronoss.cpo.core.meta.domain.CpoArgument;
+import org.synchronoss.cpo.core.meta.domain.CpoAttribute;
 import org.synchronoss.cpo.cpometa.CtCassandraArgument;
 import org.synchronoss.cpo.cpometa.CtCassandraAttribute;
 import org.synchronoss.cpo.cpometa.ObjectFactory;
-import org.synchronoss.cpo.exporter.CoreMetaXmlObjectExporter;
-import org.synchronoss.cpo.exporter.MetaXmlObjectExporter;
-import org.synchronoss.cpo.meta.CpoMetaDescriptor;
-import org.synchronoss.cpo.meta.domain.CpoArgument;
-import org.synchronoss.cpo.meta.domain.CpoAttribute;
 
 /**
  * Exports the Cassandra metadata

cpo-cassandra/src/main/java/org/synchronoss/cpo/cassandra/meta/CassandraCpoAttribute.java

@@ -25,11 +25,11 @@
 import java.io.Serial;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.synchronoss.cpo.CpoException;
-import org.synchronoss.cpo.helper.CpoClassLoader;
-import org.synchronoss.cpo.helper.ExceptionHelper;
-import org.synchronoss.cpo.meta.CpoMetaDescriptor;
-import org.synchronoss.cpo.meta.domain.CpoAttribute;
+import org.synchronoss.cpo.core.CpoException;
+import org.synchronoss.cpo.core.helper.CpoClassLoader;
+import org.synchronoss.cpo.core.helper.ExceptionHelper;
+import org.synchronoss.cpo.core.meta.CpoMetaDescriptor;
+import org.synchronoss.cpo.core.meta.domain.CpoAttribute;
 
 /**
  * JdbcCpoAttribute. A class that includes the Jdbc specifc attributes that are additional to the

cpo-cassandra/src/main/java/org/synchronoss/cpo/cassandra/meta/CassandraCpoMetaAdapter.java

@@ -33,15 +33,15 @@
 import java.util.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.synchronoss.cpo.CpoException;
+import org.synchronoss.cpo.core.CpoException;
+import org.synchronoss.cpo.core.meta.AbstractCpoMetaAdapter;
+import org.synchronoss.cpo.core.meta.DataTypeMapEntry;
+import org.synchronoss.cpo.core.meta.DataTypeMapper;
+import org.synchronoss.cpo.core.meta.domain.CpoAttribute;
+import org.synchronoss.cpo.core.parser.BoundExpressionParser;
+import org.synchronoss.cpo.core.parser.ExpressionParser;
 import org.synchronoss.cpo.cpometa.CtAttribute;
 import org.synchronoss.cpo.cpometa.CtCassandraAttribute;
-import org.synchronoss.cpo.meta.AbstractCpoMetaAdapter;
-import org.synchronoss.cpo.meta.DataTypeMapEntry;
-import org.synchronoss.cpo.meta.DataTypeMapper;
-import org.synchronoss.cpo.meta.domain.CpoAttribute;
-import org.synchronoss.cpo.parser.BoundExpressionParser;
-import org.synchronoss.cpo.parser.ExpressionParser;
 
 /**
  * Created with IntelliJ IDEA. User: dberry Date: 9/10/13 Time: 08:14 AM To change this template use

cpo-cassandra/src/main/java/org/synchronoss/cpo/cassandra/meta/CassandraCpoMetaDescriptor.java

@@ -22,10 +22,10 @@
  * ]]
  */
 
-import org.synchronoss.cpo.CpoException;
 import org.synchronoss.cpo.cassandra.exporter.CassandraMetaXmlObjectExporter;
-import org.synchronoss.cpo.exporter.MetaXmlObjectExporter;
-import org.synchronoss.cpo.meta.CpoMetaDescriptor;
+import org.synchronoss.cpo.core.CpoException;
+import org.synchronoss.cpo.core.exporter.MetaXmlObjectExporter;
+import org.synchronoss.cpo.core.meta.CpoMetaDescriptor;
 
 /**
  * Created with IntelliJ IDEA. User: dberry Date: 9/10/13 Time: 07:56 AM To change this template use

cpo-cassandra/src/main/java/org/synchronoss/cpo/cassandra/meta/CassandraMethodMapEntry.java

@@ -24,7 +24,7 @@
 
 import java.io.Serial;
 import java.lang.reflect.Method;
-import org.synchronoss.cpo.meta.MethodMapEntry;
+import org.synchronoss.cpo.core.meta.MethodMapEntry;
 
 /**
  * MethodMapEntry is a class defines the getters and setters for JDBC specific data classes

cpo-cassandra/src/main/java/org/synchronoss/cpo/cassandra/meta/CassandraMethodMapper.java

@@ -37,8 +37,8 @@
 import java.util.UUID;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.synchronoss.cpo.CpoException;
-import org.synchronoss.cpo.meta.MethodMapper;
+import org.synchronoss.cpo.core.CpoException;
+import org.synchronoss.cpo.core.meta.MethodMapper;
 
 /**
  * MethodMapper is a class defines the getters and setters for all the JDBC specific data classes

cpo-cassandra/src/main/java/org/synchronoss/cpo/cassandra/meta/CassandraResultSetCpoData.java

@@ -23,10 +23,10 @@
  */
 
 import java.lang.reflect.InvocationTargetException;
-import org.synchronoss.cpo.meta.MethodMapEntry;
-import org.synchronoss.cpo.meta.MethodMapper;
-import org.synchronoss.cpo.meta.ResultSetCpoData;
-import org.synchronoss.cpo.meta.domain.CpoAttribute;
+import org.synchronoss.cpo.core.meta.MethodMapEntry;
+import org.synchronoss.cpo.core.meta.MethodMapper;
+import org.synchronoss.cpo.core.meta.ResultSetCpoData;
+import org.synchronoss.cpo.core.meta.domain.CpoAttribute;
 
 /** Manages data transfer between the cpo objects and the result set */
 public class CassandraResultSetCpoData extends ResultSetCpoData {

cpo-cassandra/src/main/java/org/synchronoss/cpo/cassandra/transform/CassandraCpoTransform.java

@@ -22,9 +22,9 @@
  * ]]
  */
 
-import org.synchronoss.cpo.CpoException;
 import org.synchronoss.cpo.cassandra.CassandraBoundStatementFactory;
-import org.synchronoss.cpo.transform.CpoTransform;
+import org.synchronoss.cpo.core.CpoException;
+import org.synchronoss.cpo.core.transform.CpoTransform;
 
 /**
  * Custom transforms of Java classes to Datasource classes

cpo-cassandra/src/main/java/org/synchronoss/cpo/cassandra/transform/TransformNoOp.java

@@ -24,8 +24,8 @@
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.synchronoss.cpo.CpoException;
 import org.synchronoss.cpo.cassandra.CassandraBoundStatementFactory;
+import org.synchronoss.cpo.core.CpoException;
 
 /**
  * This is an example of a transform that does nothing. It is used to test the mechanics of the

cpo-cassandra/src/test/java/org/synchronoss/cpo/cassandra/BlobTest.java

@@ -27,9 +27,9 @@
 import java.nio.ByteBuffer;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.synchronoss.cpo.CpoAdapter;
-import org.synchronoss.cpo.CpoAdapterFactoryManager;
 import org.synchronoss.cpo.cassandra.meta.CassandraCpoMetaDescriptor;
+import org.synchronoss.cpo.core.CpoAdapter;
+import org.synchronoss.cpo.core.CpoAdapterFactoryManager;
 import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;

cpo-cassandra/src/test/java/org/synchronoss/cpo/cassandra/CassandraSuiteListener.java

@@ -27,7 +27,7 @@
 import com.github.terma.javaniotcpproxy.TcpProxyConfig;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.synchronoss.cpo.CpoAdapterFactoryManager;
+import org.synchronoss.cpo.core.CpoAdapterFactoryManager;
 import org.testcontainers.cassandra.CassandraContainer;
 import org.testcontainers.utility.DockerImageName;
 import org.testng.ISuite;

cpo-cassandra/src/test/java/org/synchronoss/cpo/cassandra/CollectionsTest.java

@@ -25,9 +25,9 @@
 import static org.testng.Assert.*;
 
 import java.util.*;
-import org.synchronoss.cpo.CpoAdapter;
-import org.synchronoss.cpo.CpoAdapterFactoryManager;
 import org.synchronoss.cpo.cassandra.meta.CassandraCpoMetaDescriptor;
+import org.synchronoss.cpo.core.CpoAdapter;
+import org.synchronoss.cpo.core.CpoAdapterFactoryManager;
 import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;

cpo-cassandra/src/test/java/org/synchronoss/cpo/cassandra/ConstructorTest.java

@@ -26,8 +26,8 @@
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.synchronoss.cpo.CpoAdapter;
-import org.synchronoss.cpo.CpoAdapterFactoryManager;
+import org.synchronoss.cpo.core.CpoAdapter;
+import org.synchronoss.cpo.core.CpoAdapterFactoryManager;
 import org.testng.annotations.Test;
 
 /**

cpo-cassandra/src/test/java/org/synchronoss/cpo/cassandra/DeleteObjectTest.java

@@ -30,10 +30,10 @@
 import java.util.Date;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.synchronoss.cpo.CpoAdapter;
-import org.synchronoss.cpo.CpoAdapterFactoryManager;
 import org.synchronoss.cpo.cassandra.meta.CassandraCpoMetaDescriptor;
-import org.synchronoss.cpo.helper.ExceptionHelper;
+import org.synchronoss.cpo.core.CpoAdapter;
+import org.synchronoss.cpo.core.CpoAdapterFactoryManager;
+import org.synchronoss.cpo.core.helper.ExceptionHelper;
 import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;