package nl.astraeus.database; import junit.framework.Assert; import nl.astraeus.database.jdbc.ConnectionPool; import nl.astraeus.database.jdbc.ConnectionProvider; import nl.astraeus.database.test.model.Person; import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.util.List; /** * Date: 11/16/13 * Time: 12:27 AM */ public class TestSelectWhere { private final static Logger logger = LoggerFactory.getLogger(TestSelectWhere.class); @BeforeClass public static void createDatabase() { DdlMapping.get().setExecuteDDLUpdates(true); ConnectionPool.get().setConnectionProvider(new ConnectionProvider() { @Override public Connection getConnection() { try { Class.forName("org.h2.Driver"); Connection connection = DriverManager.getConnection("jdbc:h2:mem:TestSelectWhere", "sa", ""); connection.setAutoCommit(false); return connection; } catch (ClassNotFoundException e) { throw new IllegalStateException(e); } catch (SQLException e) { throw new IllegalStateException(e); } } }); } @AfterClass public static void clearMetaData() { Persister.dispose(); } @Test public void testSelectWhere() { Persister.begin(); Persister.insert(new Person("Rien", 40, "Rozendael")); Persister.insert(new Person("Jan", 32, "Straat")); Persister.insert(new Person("Ronald", 32, "Wherever")); Persister.insert(new Person("Piet", 26, "Weg")); Persister.insert(new Person("Klaas", 10, "Pad")); Persister.commit(); Persister.begin(); List<Person> persons = Persister.selectWhere(Person.class, "age > ?", 30); Assert.assertEquals(persons.size(), 3); persons = Persister.selectWhere(Person.class, "name like ?", "R%"); Assert.assertEquals(persons.size(), 2); Persister.rollback(); } }