Package com.j256.ormlite.support

Examples of com.j256.ormlite.support.DatabaseResults

144
145
146
147
148
149
150
151
152
    assertEquals(1, dao.queryForAll().size());

    @SuppressWarnings("unchecked")
    SelectIterator<Foo, String> iterator = (SelectIterator<Foo, String>) dao.iterator();
    DatabaseResults results = iterator.getRawResults();
    assertTrue(results.next());
    iterator.close();
  }
View Full Code Here
185
186
187
188
189
190
191
192
193
194
195
196
197
  @Test(expected = IllegalStateException.class)
  public void testHasNextThrow() throws Exception {
    ConnectionSource cs = createMock(ConnectionSource.class);
    cs.releaseConnection(null);
    CompiledStatement stmt = createMock(CompiledStatement.class);
    DatabaseResults results = createMock(DatabaseResults.class);
    expect(stmt.runQuery(null)).andReturn(results);
    expect(results.first()).andThrow(new SQLException("some database problem"));
    stmt.close();
    replay(stmt, results, cs);
    SelectIterator<Foo, Integer> iterator =
        new SelectIterator<Foo, Integer>(Foo.class, null, null, cs, null, stmt, "statement", null);
    iterator.hasNext();
View Full Code Here
200
201
202
203
204
205
206
207
208
209
210
211
212
  @Test(expected = IllegalStateException.class)
  public void testNextThrow() throws Exception {
    ConnectionSource cs = createMock(ConnectionSource.class);
    cs.releaseConnection(null);
    CompiledStatement stmt = createMock(CompiledStatement.class);
    DatabaseResults results = createMock(DatabaseResults.class);
    expect(stmt.runQuery(null)).andReturn(results);
    expect(results.first()).andReturn(true);
    @SuppressWarnings("unchecked")
    GenericRowMapper<Foo> mapper = (GenericRowMapper<Foo>) createMock(GenericRowMapper.class);
    expect(mapper.mapRow(results)).andThrow(new SQLException("some result problem"));
    stmt.close();
    replay(stmt, mapper, cs, results);
View Full Code Here
218
219
220
221
222
223
224
225
226
227
228
229
  @Test(expected = IllegalStateException.class)
  public void testRemoveThrow() throws Exception {
    ConnectionSource cs = createMock(ConnectionSource.class);
    cs.releaseConnection(null);
    CompiledStatement stmt = createMock(CompiledStatement.class);
    DatabaseResults results = createMock(DatabaseResults.class);
    expect(results.first()).andReturn(true);
    expect(stmt.runQuery(null)).andReturn(results);
    @SuppressWarnings("unchecked")
    GenericRowMapper<Foo> mapper = (GenericRowMapper<Foo>) createMock(GenericRowMapper.class);
    Foo foo = new Foo();
    expect(mapper.mapRow(results)).andReturn(foo);
View Full Code Here
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
      GenericRowMapper<T> rowMapper, ObjectCache objectCache, String label) throws SQLException {
    PreparedStatement stmt =
        connection.prepareStatement(statement, ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
    try {
      statementSetArgs(stmt, args, argFieldTypes);
      DatabaseResults results = new JdbcDatabaseResults(stmt, stmt.executeQuery(), objectCache);
      logger.trace("{} statement is prepared and executed: {}", label, statement);
      if (!results.first()) {
        // no results at all
        return null;
      }
      T first = rowMapper.mapRow(results);
      if (results.next()) {
        return MORE_THAN_ONE;
      } else {
        return first;
      }
    } finally {
View Full Code Here
27
28
29
30
31
32
33
34
35
36
37
38
    assertEquals(value, DateTimeType.getSingleton().parseDefaultString(null, value.toString()));
  }

  @Test
  public void testResultToSqlArg() throws Exception {
    DatabaseResults results = createMock(DatabaseResults.class);
    int col = 21;
    long value = 2094234324L;
    expect(results.getLong(col)).andReturn(value);
    replay(results);
    assertEquals(new DateTime(value), DateTimeType.getSingleton().resultToJava(null, results, col));
  }
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
140
  }

  @Test
  public void testObjectFieldConverterResultToJavaStreamNull() throws Exception {
    int COLUMN = 1;
    DatabaseResults results = (DatabaseResults) createMock(DatabaseResults.class);
    expect(results.getBlobStream(COLUMN)).andReturn(null);
    replay(results);
    DerbyEmbeddedDatabaseType type = new DerbyEmbeddedDatabaseType();
    FieldConverter converter = type.getFieldConverter(DataType.SERIALIZABLE.getDataPersister(), null);
    assertEquals(null, converter.resultToJava(null, results, COLUMN));
    verify(results);
View Full Code Here
141
142
143
144
145
146
147
148
149
150
151
152
153
  }

  @Test(expected = SQLException.class)
  public void testObjectFieldConverterResultToJavaStreamNotObject() throws Exception {
    int COLUMN = 1;
    DatabaseResults results = (DatabaseResults) createMock(DatabaseResults.class);
    String value = "NotASerializedObject";
    expect(results.getBlobStream(COLUMN)).andReturn(new ByteArrayInputStream(value.getBytes()));
    replay(results);
    DerbyEmbeddedDatabaseType type = new DerbyEmbeddedDatabaseType();
    FieldConverter converter = type.getFieldConverter(DataType.SERIALIZABLE.getDataPersister(), null);
    Object obj = converter.resultToJava(null, results, COLUMN);
    verify(results);
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
      @SuppressWarnings("unchecked")
      D castDao = (D) dao;
      return castDao;
    }

    DatabaseTable databaseTable = clazz.getAnnotation(DatabaseTable.class);
    if (databaseTable == null || databaseTable.daoClass() == Void.class
        || databaseTable.daoClass() == BaseDaoImpl.class) {
      @SuppressWarnings("deprecation")
      Dao<T, ?> daoTmp = BaseDaoImpl.createDao(connectionSource, clazz);
      dao = daoTmp;
    } else {
      Class<?> daoClass = databaseTable.daoClass();
      Constructor<?> daoConstructor = null;
      Object[] arguments = null;
      Constructor<?>[] constructors = daoClass.getConstructors();
      // look first for the constructor with a class parameter in case it is a generic dao
      for (Constructor<?> constructor : constructors) {
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
      @SuppressWarnings("unchecked")
      D castDao = (D) dao;
      return castDao;
    }

    DatabaseTable databaseTable = tableConfig.getDataClass().getAnnotation(DatabaseTable.class);
    if (databaseTable == null || databaseTable.daoClass() == Void.class
        || databaseTable.daoClass() == BaseDaoImpl.class) {
      @SuppressWarnings("deprecation")
      Dao<T, ?> daoTmp = BaseDaoImpl.createDao(connectionSource, tableConfig);
      dao = daoTmp;
    } else {
      Class<?> daoClass = databaseTable.daoClass();
      Constructor<?> constructor;
      try {
        constructor = daoClass.getConstructor(ConnectionSource.class, DatabaseTableConfig.class);
      } catch (Exception e) {
        throw SqlExceptionUtil.create(
View Full Code Here
TOP

Related Classes of com.j256.ormlite.support.DatabaseResults

  • android.database.sqlite.SQLiteStatement
  • com.j256.ormlite.android.AndroidDatabaseConnection
  • com.j256.ormlite.android.apptools.OrmLiteSqliteOpenHelper
  • com.j256.ormlite.dao.BaseDaoImpl
  • com.j256.ormlite.dao.BaseDaoImplTest
  • com.j256.ormlite.dao.Dao.CreateOrUpdateStatus
  • com.j256.ormlite.dao.DaoManager
  • com.j256.ormlite.dao.DaoManagerTest
  • com.j256.ormlite.dao.DoubleDbOpenTest
  • com.j256.ormlite.dao.RuntimeExceptionDaoTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.