JUnit for QueryHelper api

Author: fugerit79

fj-core/src/test/java/test/org/fugerit/java/core/db/dao/daogen/TestAddressSelectHelper.java

@@ -0,0 +1,22 @@
+package test.org.fugerit.java.core.db.dao.daogen;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+import org.fugerit.java.core.db.dao.RSExtractor;
+
+import test.org.fugerit.java.core.db.helpers.MemDBTestBase;
+
+public class TestAddressSelectHelper extends MemDBTestBase {
+
+	public static final String COL_INFO = "INFO";
+	
+	public static RSExtractor<String> RSE_ADDRESS_COL_INFO = new RSExtractor<String>() {
+		@Override
+		public String extractNext(ResultSet rs) throws SQLException {
+			return rs.getString( COL_INFO );
+		}
+	};
+
+	
+}

fj-core/src/test/java/test/org/fugerit/java/core/db/dao/daogen/TestSelectHelperSimple.java

@@ -0,0 +1,45 @@
+package test.org.fugerit.java.core.db.dao.daogen;
+
+import java.sql.Statement;
+
+import org.fugerit.java.core.db.daogen.BasicDAOHelper;
+import org.fugerit.java.core.db.daogen.CloseableDAOContext;
+import org.fugerit.java.core.db.daogen.CloseableDAOContextSC;
+import org.fugerit.java.core.db.daogen.SelectHelper;
+import org.junit.Assert;
+import org.junit.Test;
+
+public class TestSelectHelperSimple extends TestAddressSelectHelper {
+	
+	
+	protected void testQueryHelperSimple( String syntax ) {
+		try ( CloseableDAOContext context = new CloseableDAOContextSC( this.getConnection() ) ) {
+			try ( Statement stm = context.getConnection().createStatement() ) {
+				stm.execute( "SET DATABASE SQL SYNTAX "+syntax+" TRUE" );
+			}
+			// SelectHelper setup
+			BasicDAOHelper<String> daoHelper = new BasicDAOHelper<>(context);
+			SelectHelper selectHelper = daoHelper.newSelectHelper( "fugerit.address" );
+			// add param
+			selectHelper.andEqualParam( COL_INFO , "Test address 01" );
+			logger.info( "sql -> {}", selectHelper.getQueryContent() );		// method getQueryContent() provides access to current query buffer
+			// result
+			String res = daoHelper.loadOneHelper( selectHelper, RSE_ADDRESS_COL_INFO );
+			logger.info( "res -> {}", res );
+			Assert.assertNotNull( "Result should not be null" , res );
+		} catch (Exception e) {
+			this.failEx(e);
+		}
+	}
+	
+	@Test
+	public void testQuerySelectSimplePostgres() {
+		testQueryHelperSimple( "PGS"  );
+	}
+	
+	@Test
+	public void testQuerySelectSimpleOracle() {
+		testQueryHelperSimple( "ORA" );
+	}
+	
+}

fj-core/src/test/java/test/org/fugerit/java/core/db/dao/daogen/TestSelectHelperUpper.java

@@ -0,0 +1,48 @@
+package test.org.fugerit.java.core.db.dao.daogen;
+
+import java.sql.Statement;
+
+import org.fugerit.java.core.db.daogen.BasicDAOHelper;
+import org.fugerit.java.core.db.daogen.CloseableDAOContext;
+import org.fugerit.java.core.db.daogen.CloseableDAOContextSC;
+import org.fugerit.java.core.db.daogen.SelectHelper;
+import org.junit.Assert;
+import org.junit.Test;
+
+public class TestSelectHelperUpper extends TestAddressSelectHelper {
+	
+	protected void testQueryHelperIgnoreCase( String syntax ) {
+		try ( CloseableDAOContext context = new CloseableDAOContextSC( this.getConnection() ) ) {
+			try ( Statement stm = context.getConnection().createStatement() ) {
+				stm.execute( "SET DATABASE SQL SYNTAX "+syntax+" TRUE" );
+			}
+			// SelectHelper setup
+			BasicDAOHelper<String> daoHelper = new BasicDAOHelper<>(context);
+			SelectHelper selectHelper = daoHelper.newSelectHelper( "fugerit.address" );
+			// select helper is basically a query builder, it is possible to add functions, instead of the simple column name
+			String column = String.format( "UPPER(%s)" , COL_INFO );		// will add 'UPPER(INFO)'
+			// it is possible to transform upper case the value to be compared
+			String value = "test address 01".toUpperCase();
+			// this will perform an ignore case comparison, as both the column and the value are now UPPERCASE
+			selectHelper.andEqualParam( column , value );
+			logger.info( "sql -> {}", selectHelper.getQueryContent() );		// method getQueryContent() provides access to current query buffer
+			// the result
+			String res = daoHelper.loadOneHelper( selectHelper, RSE_ADDRESS_COL_INFO );
+			logger.info( "res -> {}", res );
+			Assert.assertNotNull( "Result should not be null" , res );
+		} catch (Exception e) {
+			this.failEx(e);
+		}
+	}
+	
+	@Test
+	public void testQuerySelectIgnoreCasePostgres() {
+		testQueryHelperIgnoreCase( "PGS"  );
+	}
+	
+	@Test
+	public void testQuerySelectgnoreCaseOracle() {
+		testQueryHelperIgnoreCase( "ORA" );
+	}
+	
+}

fj-core/src/test/resources/test/memdb/base_db_init.sql

@@ -65,8 +65,8 @@ CREATE SEQUENCE fugerit.seq_test START WITH 1;
 INSERT INTO fugerit.user ( id, username, password, last_login, state ) VALUES ( nextval('fugerit.seq_test'), 'user1', 'a3f8h5h4h3n3n1n9', sysdate, 1 );
 INSERT INTO fugerit.user ( id, username, password, last_login, state ) VALUES ( nextval('fugerit.seq_test'), 'user2', '5h4h3n3n1n9a3f8h', sysdate, 0 );
 
-INSERT INTO fugerit.address ( id, id_user, info ) VALUES ( nextval('fugerit.seq_test'), 1, 'test address 01' );
-INSERT INTO fugerit.address ( id, id_user, info ) VALUES ( nextval('fugerit.seq_test'), 2, 'test address 02' );
-INSERT INTO fugerit.address ( id, id_user, info ) VALUES ( nextval('fugerit.seq_test'), 1, 'test address 03' );
+INSERT INTO fugerit.address ( id, id_user, info ) VALUES ( nextval('fugerit.seq_test'), 1, 'Test address 01' );
+INSERT INTO fugerit.address ( id, id_user, info ) VALUES ( nextval('fugerit.seq_test'), 2, 'Test address 02' );
+INSERT INTO fugerit.address ( id, id_user, info ) VALUES ( nextval('fugerit.seq_test'), 1, 'Test address 03' );
 
 INSERT INTO fugerit.test_two_field_key ( id_one, id_two, info ) VALUES ( nextval('fugerit.seq_test'), nextval('fugerit.seq_test'), 'test info 01' );