Ignore:
Timestamp:
02/04/10 21:56:24 (2 years ago)
Author:
kasper
Message:
 
File:
1 edited

Legend:

Unmodified
Added
Removed

  • MetadataBeans/trunk/src/test/java/org/eobjects/metamodel/CsvDataContextStrategyTest.java

    r886 r887  
    2424 
    2525import org.apache.commons.lang.ArrayUtils; 
    26 import org.eobjects.metamodel.CsvDataContextStrategy; 
    27 import org.eobjects.metamodel.DataContext; 
    28 import org.eobjects.metamodel.QueryPostprocessDataContextStrategy; 
    2926import org.eobjects.metamodel.data.DataSet; 
    3027import org.eobjects.metamodel.query.FilterItem; 
    … …  
    3532import org.eobjects.metamodel.schema.Column; 
    3633import org.eobjects.metamodel.schema.ColumnType; 
     34import org.eobjects.metamodel.schema.MutableColumn; 
    3735import org.eobjects.metamodel.schema.Schema; 
    3836import org.eobjects.metamodel.schema.Table; 
    39  
    4037 
    4138public class CsvDataContextStrategyTest extends MetaModelTestCase { 
    … …  
    5148                File file = new File("target/huge_csv.csv"); 
    5249                ExampleDataCreator.createFile(file); 
    53                  
     50 
    5451                long timeAtStart = System.currentTimeMillis(); 
    5552                System.out.println("time at start: " + timeAtStart); 
    5653 
    57                 DataContext dc = new DataContext(new CsvDataContextStrategy(file, ',', '"')); 
     54                DataContext dc = new DataContext(new CsvDataContextStrategy(file, ',', 
     55                                '"')); 
    5856                Table t = dc.getDefaultSchema().getTables()[0]; 
    5957 
    … …  
    6866 
    6967                while (ds.next()) { 
    70                         assertEquals(ExampleDataCreator.NUM_COLS, ds.getRow().getValues().length); 
     68                        assertEquals(ExampleDataCreator.NUM_COLS, 
     69                                        ds.getRow().getValues().length); 
    7170                } 
    7271                ds.close(); 
    … …  
    7473                long timeAfterDataSet = System.currentTimeMillis(); 
    7574                System.out.println("time after dataSet: " + timeAfterDataSet); 
    76                  
     75 
    7776                if (!file.delete()) { 
    7877                        file.deleteOnExit(); 
    … …  
    8382                File file = new File("src/test/resources/tickets.csv"); 
    8483                FileInputStream inputStream = new FileInputStream(file); 
    85                 DataContext dc = new DataContext(new CsvDataContextStrategy(inputStream, ',', '"')); 
     84                DataContext dc = new DataContext(new CsvDataContextStrategy( 
     85                                inputStream, ',', '"')); 
    8686                Schema schema = dc.getDefaultSchema(); 
    8787                String name = schema.getName(); 
    … …  
    9191                Table table = schema.getTables()[0]; 
    9292                Column column = table.getColumns()[0]; 
    93                 TableModel tableModel = dc.executeQuery(new Query().select(column).from(table)).toTableModel(); 
     93                TableModel tableModel = dc.executeQuery( 
     94                                new Query().select(column).from(table)).toTableModel(); 
    9495                assertEquals(1, tableModel.getColumnCount()); 
    9596                assertEquals(36, tableModel.getRowCount()); 
    … …  
    9899                // Test two seperate reads to ensure that the temp file is working 
    99100                // properly and persistent. 
    100                 tableModel = dc.executeQuery(new Query().select(column).from(table)).toTableModel(); 
     101                tableModel = dc.executeQuery(new Query().select(column).from(table)) 
     102                                .toTableModel(); 
    101103                assertEquals(1, tableModel.getColumnCount()); 
    102104                assertEquals(36, tableModel.getRowCount()); 
    … …  
    132134        public void testGetSchemas() throws Exception { 
    133135                File file = new File("src/test/resources/csv_people.csv"); 
    134                 QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy(file); 
     136                QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy( 
     137                                file); 
    135138                Schema[] schemas = new DataContext(strategy).getSchemas(); 
    136139                assertEquals(2, schemas.length); 
    … …  
    153156        public void testWhereItemNotInSelectClause() throws Exception { 
    154157                File file = new File("src/test/resources/csv_people.csv"); 
    155                 QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy(file); 
    156                 Table table = new DataContext(strategy).getSchemas()[0].getTableByName("csv_people"); 
     158                QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy( 
     159                                file); 
     160                Table table = new DataContext(strategy).getSchemas()[0] 
     161                                .getTableByName("csv_people"); 
    157162 
    158163                Query q = new Query(); 
    159164                q.from(table); 
    160                 q.where(new FilterItem(new SelectItem(table.getColumnByName("id")), OperatorType.EQUALS_TO, 1)); 
     165                q.where(new FilterItem(new SelectItem(table.getColumnByName("id")), 
     166                                OperatorType.EQUALS_TO, 1)); 
    161167                q.select(table.getColumnByName("name")); 
    162168                DataSet data = strategy.executeQuery(q); 
    … …  
    167173 
    168174        public void testGroupByQuery() throws Exception { 
    169                 DataContext dc = new DataContext(new CsvDataContextStrategy(new File("src/test/resources/csv_people.csv"))); 
     175                DataContext dc = new DataContext(new CsvDataContextStrategy(new File( 
     176                                "src/test/resources/csv_people.csv"))); 
    170177                Table table = dc.getSchemas()[0].getTableByName("csv_people"); 
    171178 
    … …  
    173180                q.from(table); 
    174181                q.groupBy(table.getColumnByName("gender")); 
    175                 q.select(new SelectItem(table.getColumnByName("gender")), new SelectItem(FunctionType.MAX, table 
    176                                 .getColumnByName("age")), new SelectItem(FunctionType.MIN, table.getColumnByName("age")), 
    177                                 new SelectItem(FunctionType.COUNT, "*", "total"), new SelectItem(FunctionType.MIN, table 
    178                                                 .getColumnByName("id")).setAlias("firstId")); 
     182                q.select(new SelectItem(table.getColumnByName("gender")), 
     183                                new SelectItem(FunctionType.MAX, table.getColumnByName("age")), 
     184                                new SelectItem(FunctionType.MIN, table.getColumnByName("age")), 
     185                                new SelectItem(FunctionType.COUNT, "*", "total"), 
     186                                new SelectItem(FunctionType.MIN, table.getColumnByName("id")) 
     187                                                .setAlias("firstId")); 
    179188                DataSet data = dc.executeQuery(q); 
    180189                assertEquals( 
    … …  
    182191                                ArrayUtils.toString(data.getSelectItems())); 
    183192 
    184                 String[] expectations = new String[] { "Row[values={female,20,17,5,5}]", "Row[values={male,19,17,4,1}]" }; 
     193                String[] expectations = new String[] { 
     194                                "Row[values={female,20,17,5,5}]", 
     195                                "Row[values={male,19,17,4,1}]" }; 
    185196 
    186197                assertTrue(data.next()); 
    … …  
    193204        public void testMaterializeTable() throws Exception { 
    194205                File file = new File("src/test/resources/csv_people.csv"); 
    195                 QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy(file); 
     206                QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy( 
     207                                file); 
    196208                Table table = new DataContext(strategy).getSchemas()[0].getTables()[0]; 
    197                 DataSet dataSet = strategy.materializeMainSchemaTable(table, table.getColumns(), -1); 
     209                DataSet dataSet = strategy.materializeMainSchemaTable(table, table 
     210                                .getColumns(), -1); 
    198211                assertNull(dataSet.getRow()); 
    199212                assertTrue(dataSet.next()); 
    200                 assertEquals("Row[values={1,mike,male,18}]", dataSet.getRow().toString()); 
    201                 assertTrue(dataSet.next()); 
    202                 assertEquals("Row[values={2,michael,male,19}]", dataSet.getRow().toString()); 
    203                 assertTrue(dataSet.next()); 
    204                 assertEquals("Row[values={3,peter,male,18}]", dataSet.getRow().toString()); 
    205                 assertTrue(dataSet.next()); 
    206                 assertTrue(dataSet.next()); 
    207                 assertEquals("Row[values={5,barbara, barb,female,18}]", dataSet.getRow().toString()); 
    208                 assertTrue(dataSet.next()); 
    209                 assertTrue(dataSet.next()); 
    210                 assertTrue(dataSet.next()); 
    211                 assertTrue(dataSet.next()); 
    212                 assertEquals("Row[values={9,carrie,female,17}]", dataSet.getRow().toString()); 
     213                assertEquals("Row[values={1,mike,male,18}]", dataSet.getRow() 
     214                                .toString()); 
     215                assertTrue(dataSet.next()); 
     216                assertEquals("Row[values={2,michael,male,19}]", dataSet.getRow() 
     217                                .toString()); 
     218                assertTrue(dataSet.next()); 
     219                assertEquals("Row[values={3,peter,male,18}]", dataSet.getRow() 
     220                                .toString()); 
     221                assertTrue(dataSet.next()); 
     222                assertTrue(dataSet.next()); 
     223                assertEquals("Row[values={5,barbara, barb,female,18}]", dataSet 
     224                                .getRow().toString()); 
     225                assertTrue(dataSet.next()); 
     226                assertTrue(dataSet.next()); 
     227                assertTrue(dataSet.next()); 
     228                assertTrue(dataSet.next()); 
     229                assertEquals("Row[values={9,carrie,female,17}]", dataSet.getRow() 
     230                                .toString()); 
    213231                assertFalse(dataSet.next()); 
    214232 
    215                 dataSet = strategy.materializeMainSchemaTable(table, table.getColumns(), 1); 
    216                 assertTrue(dataSet.next()); 
    217                 assertEquals("Row[values={1,mike,male,18}]", dataSet.getRow().toString()); 
     233                dataSet = strategy.materializeMainSchemaTable(table, 
     234                                table.getColumns(), 1); 
     235                assertTrue(dataSet.next()); 
     236                assertEquals("Row[values={1,mike,male,18}]", dataSet.getRow() 
     237                                .toString()); 
    218238                assertFalse(dataSet.next()); 
    219239        } 
    … …  
    221241        public void testAlternativeDelimitors() throws Exception { 
    222242                File file = new File("src/test/resources/csv_semicolon_singlequote.csv"); 
    223                 QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy(file, ';', '\''); 
     243                QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy( 
     244                                file, ';', '\''); 
    224245                Table table = new DataContext(strategy).getSchemas()[0].getTables()[0]; 
    225                 DataSet dataSet = strategy.materializeMainSchemaTable(table, table.getColumns(), -1); 
    226                 assertTrue(dataSet.next()); 
    227                 assertEquals("Row[values={1,mike,male,18}]", dataSet.getRow().toString()); 
    228                 assertTrue(dataSet.next()); 
    229                 assertEquals("Row[values={2,michael,male,19}]", dataSet.getRow().toString()); 
    230                 assertTrue(dataSet.next()); 
    231                 assertEquals("Row[values={3,peter,male,18}]", dataSet.getRow().toString()); 
    232                 assertTrue(dataSet.next()); 
    233                 assertTrue(dataSet.next()); 
    234                 assertEquals("Row[values={5,barbara; barb,female,18}]", dataSet.getRow().toString()); 
    235                 assertTrue(dataSet.next()); 
    236                 assertTrue(dataSet.next()); 
    237                 assertTrue(dataSet.next()); 
    238                 assertTrue(dataSet.next()); 
    239                 assertEquals("Row[values={9,carrie,female,17}]", dataSet.getRow().toString()); 
     246                DataSet dataSet = strategy.materializeMainSchemaTable(table, table 
     247                                .getColumns(), -1); 
     248                assertTrue(dataSet.next()); 
     249                assertEquals("Row[values={1,mike,male,18}]", dataSet.getRow() 
     250                                .toString()); 
     251                assertTrue(dataSet.next()); 
     252                assertEquals("Row[values={2,michael,male,19}]", dataSet.getRow() 
     253                                .toString()); 
     254                assertTrue(dataSet.next()); 
     255                assertEquals("Row[values={3,peter,male,18}]", dataSet.getRow() 
     256                                .toString()); 
     257                assertTrue(dataSet.next()); 
     258                assertTrue(dataSet.next()); 
     259                assertEquals("Row[values={5,barbara; barb,female,18}]", dataSet 
     260                                .getRow().toString()); 
     261                assertTrue(dataSet.next()); 
     262                assertTrue(dataSet.next()); 
     263                assertTrue(dataSet.next()); 
     264                assertTrue(dataSet.next()); 
     265                assertEquals("Row[values={9,carrie,female,17}]", dataSet.getRow() 
     266                                .toString()); 
    240267                assertFalse(dataSet.next()); 
    241268                assertNull(dataSet.getRow()); 
    … …  
    244271        public void testMaxRows() throws Exception { 
    245272                File file = new File("src/test/resources/csv_semicolon_singlequote.csv"); 
    246                 QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy(file, ';', '\''); 
     273                QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy( 
     274                                file, ';', '\''); 
    247275                Table table = new DataContext(strategy).getSchemas()[0].getTables()[0]; 
    248                 Query query = new Query().from(table).select(table.getColumns()).setMaxRows(5); 
     276                Query query = new Query().from(table).select(table.getColumns()) 
     277                                .setMaxRows(5); 
    249278                DataSet dataSet = strategy.executeQuery(query); 
    250279                TableModel tableModel = dataSet.toTableModel(); 
    … …  
    254283        public void testQueryOnlyAggregate() throws Exception { 
    255284                File file = new File("src/test/resources/csv_people.csv"); 
    256                 QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy(file); 
     285                QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy( 
     286                                file); 
    257287                DataContext dc = new DataContext(strategy); 
    258288                Table table = dc.getDefaultSchema().getTables()[0]; 
    259289 
    260290                Query q = new Query().selectCount().from(table); 
    261                 assertEquals("SELECT COUNT(*) FROM csv_people.csv.csv_people", q.toString()); 
     291                assertEquals("SELECT COUNT(*) FROM csv_people.csv.csv_people", q 
     292                                .toString()); 
    262293 
    263294                List<Object[]> data = dc.executeQuery(q).toObjectArrays(); 
    … …  
    268299 
    269300                q.select(table.getColumns()[0]); 
    270                 assertEquals("SELECT COUNT(*), csv_people.id FROM csv_people.csv.csv_people", q.toString()); 
     301                assertEquals( 
     302                                "SELECT COUNT(*), csv_people.id FROM csv_people.csv.csv_people", 
     303                                q.toString()); 
    271304                data = dc.executeQuery(q).toObjectArrays(); 
    272305                assertEquals(9, data.size()); 
    … …  
    290323        public void testUsingColumnTypeTransformers() throws Exception { 
    291324                File file = new File("src/test/resources/csv_people.csv"); 
    292                 QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy(file); 
     325                QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy( 
     326                                file); 
    293327                DataContext dc = new DataContext(strategy); 
    294328                Table table = dc.getDefaultSchema().getTables()[0]; 
    … …  
    299333                strategy.transformColumnTypes(idColumn, ageColumn); 
    300334 
    301                 idColumn.setType(ColumnType.INTEGER); 
    302                 ageColumn.setType(ColumnType.DOUBLE); 
    303  
    304                 DataSet dataSet = dc.executeQuery(new Query().select(idColumn, ageColumn).from(table)); 
    305                 assertTrue(dataSet.next()); 
    306                 assertEquals("java.lang.Integer", dataSet.getRow().getValue(idColumn).getClass().getName()); 
     335                ((MutableColumn) idColumn).setType(ColumnType.INTEGER); 
     336                ((MutableColumn) ageColumn).setType(ColumnType.DOUBLE); 
     337 
     338                DataSet dataSet = dc.executeQuery(new Query().select(idColumn, 
     339                                ageColumn).from(table)); 
     340                assertTrue(dataSet.next()); 
     341                assertEquals("java.lang.Integer", dataSet.getRow().getValue(idColumn) 
     342                                .getClass().getName()); 
    307343                assertEquals(1, dataSet.getRow().getValue(idColumn)); 
    308                 assertEquals("java.lang.Double", dataSet.getRow().getValue(ageColumn).getClass().getName()); 
     344                assertEquals("java.lang.Double", dataSet.getRow().getValue(ageColumn) 
     345                                .getClass().getName()); 
    309346                assertEquals(18.0, dataSet.getRow().getValue(ageColumn)); 
    310347 
    311348                assertTrue(dataSet.next()); 
    312                 assertEquals("java.lang.Integer", dataSet.getRow().getValue(idColumn).getClass().getName()); 
     349                assertEquals("java.lang.Integer", dataSet.getRow().getValue(idColumn) 
     350                                .getClass().getName()); 
    313351                assertEquals(2, dataSet.getRow().getValue(idColumn)); 
    314                 assertEquals("java.lang.Double", dataSet.getRow().getValue(ageColumn).getClass().getName()); 
     352                assertEquals("java.lang.Double", dataSet.getRow().getValue(ageColumn) 
     353                                .getClass().getName()); 
    315354                assertEquals(19.0, dataSet.getRow().getValue(ageColumn)); 
    316355 
    … …  
    320359        public void testAutoTransformColumnTypes() throws Exception { 
    321360                File file = new File("src/test/resources/csv_people.csv"); 
    322                 QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy(file); 
     361                QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy( 
     362                                file); 
    323363                strategy.autoTransformColumnTypes(); 
    324364 
    … …  
    331371                assertEquals(ColumnType.INTEGER, ageColumn.getType()); 
    332372 
    333                 DataSet dataSet = dc.executeQuery(new Query().select(idColumn, ageColumn).from(table)); 
    334                 assertTrue(dataSet.next()); 
    335                 assertEquals("java.lang.Integer", dataSet.getRow().getValue(idColumn).getClass().getName()); 
     373                DataSet dataSet = dc.executeQuery(new Query().select(idColumn, 
     374                                ageColumn).from(table)); 
     375                assertTrue(dataSet.next()); 
     376                assertEquals("java.lang.Integer", dataSet.getRow().getValue(idColumn) 
     377                                .getClass().getName()); 
    336378                assertEquals(1, dataSet.getRow().getValue(idColumn)); 
    337                 assertEquals("java.lang.Integer", dataSet.getRow().getValue(ageColumn).getClass().getName()); 
     379                assertEquals("java.lang.Integer", dataSet.getRow().getValue(ageColumn) 
     380                                .getClass().getName()); 
    338381                assertEquals(18, dataSet.getRow().getValue(ageColumn)); 
    339382 
    340383                assertTrue(dataSet.next()); 
    341                 assertEquals("java.lang.Integer", dataSet.getRow().getValue(idColumn).getClass().getName()); 
     384                assertEquals("java.lang.Integer", dataSet.getRow().getValue(idColumn) 
     385                                .getClass().getName()); 
    342386                assertEquals(2, dataSet.getRow().getValue(idColumn)); 
    343                 assertEquals("java.lang.Integer", dataSet.getRow().getValue(ageColumn).getClass().getName()); 
     387                assertEquals("java.lang.Integer", dataSet.getRow().getValue(ageColumn) 
     388                                .getClass().getName()); 
    344389                assertEquals(19, dataSet.getRow().getValue(ageColumn)); 
    345390 
    … …  
    349394        public void testAllTypes() throws Exception { 
    350395                File file = new File("src/test/resources/csv_various_types.csv"); 
    351                 QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy(file); 
     396                QueryPostprocessDataContextStrategy strategy = new CsvDataContextStrategy( 
     397                                file); 
    352398                strategy.autoTransformColumnTypes(); 
    353399 
    354400                DataContext dc = new DataContext(strategy); 
    355401                Table table = dc.getDefaultSchema().getTables()[0]; 
    356                 assertEquals("{date,time,description,rating,holiday}", ArrayUtils.toString(table.getColumnNames())); 
    357  
    358                 assertEquals( 
    359                                 "Column[name=date,columnNumber=0,type=DATE,nullable=false,indexed=false,nativeType=Text transformed to date,columnSize=<null>]", 
     402                assertEquals("{date,time,description,rating,holiday}", ArrayUtils 
     403                                .toString(table.getColumnNames())); 
     404 
     405                assertEquals( 
     406                                "MutableColumn[name=date,columnNumber=0,type=DATE,nullable=false,indexed=false,nativeType=Text transformed to date,columnSize=<null>]", 
    360407                                table.getColumnByName("date").toString()); 
    361408                assertEquals( 
    362                                 "Column[name=time,columnNumber=1,type=TIME,nullable=false,indexed=false,nativeType=Text transformed to time,columnSize=<null>]", 
     409                                "MutableColumn[name=time,columnNumber=1,type=TIME,nullable=false,indexed=false,nativeType=Text transformed to time,columnSize=<null>]", 
    363410                                table.getColumnByName("time").toString()); 
    364411                assertEquals( 
    365                                 "Column[name=description,columnNumber=2,type=VARCHAR,nullable=false,indexed=false,nativeType=Text,columnSize=<null>]", 
     412                                "MutableColumn[name=description,columnNumber=2,type=VARCHAR,nullable=false,indexed=false,nativeType=Text,columnSize=<null>]", 
    366413                                table.getColumnByName("description").toString()); 
    367414                assertEquals( 
    368                                 "Column[name=rating,columnNumber=3,type=DOUBLE,nullable=false,indexed=false,nativeType=Text transformed to double,columnSize=<null>]", 
     415                                "MutableColumn[name=rating,columnNumber=3,type=DOUBLE,nullable=false,indexed=false,nativeType=Text transformed to double,columnSize=<null>]", 
    369416                                table.getColumnByName("rating").toString()); 
    370417                assertEquals( 
    371                                 "Column[name=holiday,columnNumber=4,type=BOOLEAN,nullable=true,indexed=false,nativeType=Text transformed to boolean,columnSize=<null>]", 
     418                                "MutableColumn[name=holiday,columnNumber=4,type=BOOLEAN,nullable=true,indexed=false,nativeType=Text transformed to boolean,columnSize=<null>]", 
    372419                                table.getColumnByName("holiday").toString()); 
    373420 
    374                 DataSet dataSet = dc.executeQuery(new Query().from(table).select(table.getColumns())); 
    375                 assertTrue(dataSet.next()); 
    376                 assertEquals("java.sql.Date", dataSet.getRow().getValue(0).getClass().getName()); 
    377                 assertEquals("java.sql.Time", dataSet.getRow().getValue(1).getClass().getName()); 
    378                 assertEquals("java.lang.String", dataSet.getRow().getValue(2).getClass().getName()); 
    379                 assertEquals("java.lang.Double", dataSet.getRow().getValue(3).getClass().getName()); 
    380                 assertEquals("java.lang.Boolean", dataSet.getRow().getValue(4).getClass().getName()); 
    381                 assertEquals("{2008-11-04,12:00:00,election day,8.8,false}", ArrayUtils.toString(dataSet.getRow().getValues())); 
    382                 assertTrue(dataSet.next()); 
    383                 assertEquals("java.sql.Date", dataSet.getRow().getValue(0).getClass().getName()); 
    384                 assertEquals("java.sql.Time", dataSet.getRow().getValue(1).getClass().getName()); 
    385                 assertEquals("java.lang.String", dataSet.getRow().getValue(2).getClass().getName()); 
    386                 assertEquals("java.lang.Double", dataSet.getRow().getValue(3).getClass().getName()); 
    387                 assertEquals("java.lang.Boolean", dataSet.getRow().getValue(4).getClass().getName()); 
    388                 assertEquals("{2008-12-24,00:00:00,christmas day,9.0,true}", ArrayUtils.toString(dataSet.getRow().getValues())); 
    389                 assertTrue(dataSet.next()); 
    390                 assertEquals("java.sql.Date", dataSet.getRow().getValue(0).getClass().getName()); 
    391                 assertEquals("java.sql.Time", dataSet.getRow().getValue(1).getClass().getName()); 
    392                 assertEquals("java.lang.String", dataSet.getRow().getValue(2).getClass().getName()); 
    393                 assertEquals("java.lang.Double", dataSet.getRow().getValue(3).getClass().getName()); 
     421                DataSet dataSet = dc.executeQuery(new Query().from(table).select( 
     422                                table.getColumns())); 
     423                assertTrue(dataSet.next()); 
     424                assertEquals("java.sql.Date", dataSet.getRow().getValue(0).getClass() 
     425                                .getName()); 
     426                assertEquals("java.sql.Time", dataSet.getRow().getValue(1).getClass() 
     427                                .getName()); 
     428                assertEquals("java.lang.String", dataSet.getRow().getValue(2) 
     429                                .getClass().getName()); 
     430                assertEquals("java.lang.Double", dataSet.getRow().getValue(3) 
     431                                .getClass().getName()); 
     432                assertEquals("java.lang.Boolean", dataSet.getRow().getValue(4) 
     433                                .getClass().getName()); 
     434                assertEquals("{2008-11-04,12:00:00,election day,8.8,false}", ArrayUtils 
     435                                .toString(dataSet.getRow().getValues())); 
     436                assertTrue(dataSet.next()); 
     437                assertEquals("java.sql.Date", dataSet.getRow().getValue(0).getClass() 
     438                                .getName()); 
     439                assertEquals("java.sql.Time", dataSet.getRow().getValue(1).getClass() 
     440                                .getName()); 
     441                assertEquals("java.lang.String", dataSet.getRow().getValue(2) 
     442                                .getClass().getName()); 
     443                assertEquals("java.lang.Double", dataSet.getRow().getValue(3) 
     444                                .getClass().getName()); 
     445                assertEquals("java.lang.Boolean", dataSet.getRow().getValue(4) 
     446                                .getClass().getName()); 
     447                assertEquals("{2008-12-24,00:00:00,christmas day,9.0,true}", ArrayUtils 
     448                                .toString(dataSet.getRow().getValues())); 
     449                assertTrue(dataSet.next()); 
     450                assertEquals("java.sql.Date", dataSet.getRow().getValue(0).getClass() 
     451                                .getName()); 
     452                assertEquals("java.sql.Time", dataSet.getRow().getValue(1).getClass() 
     453                                .getName()); 
     454                assertEquals("java.lang.String", dataSet.getRow().getValue(2) 
     455                                .getClass().getName()); 
     456                assertEquals("java.lang.Double", dataSet.getRow().getValue(3) 
     457                                .getClass().getName()); 
    394458                assertNull(dataSet.getRow().getValue(4)); 
    395                 assertEquals("{2007-12-31,23:59:00,new years eve,6.4,<null>}", ArrayUtils 
    396                                 .toString(dataSet.getRow().getValues())); 
     459                assertEquals("{2007-12-31,23:59:00,new years eve,6.4,<null>}", 
     460                                ArrayUtils.toString(dataSet.getRow().getValues())); 
    397461                assertFalse(dataSet.next()); 
    398462        } 
Note: See TracChangeset for help on using the changeset viewer.