• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java DataSet类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.metamodel.data.DataSet的典型用法代码示例。如果您正苦于以下问题:Java DataSet类的具体用法?Java DataSet怎么用?Java DataSet使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



DataSet类属于org.apache.metamodel.data包,在下文中一共展示了DataSet类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: insertRowIntoBlockingQueue

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
private void insertRowIntoBlockingQueue(DataSet dataset) throws InterruptedException {

		hashedColumn = table.getColumnByName(columnName);
		requests = metrics.meter("read thread");

		while (dataset.next()) {
			Row row = dataset.getRow();
			if (horizontal && isKey(row)) {
				queue.put(row);
				requests.mark();
			} else {
			    if(!horizontal){
				queue.put(row);
				requests.mark();
			    }
			}

		}

	}
 
开发者ID:Iranox,项目名称:mapbench-datadistributor,代码行数:21,代码来源:DataReader.java


示例2: readComplexData

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
public void readComplexData() throws Exception {
		Column primaryColumn = dataContext.getTableByQualifiedLabel(joinTable).getColumnByName(secondFkey);
		System.out.println(dataContext.query().from(joinTable).select(primaryColumn).groupBy(primaryColumn).toQuery().toString());
		DataSet dataSet = dataContext.query().from(joinTable).select(primaryColumn).groupBy(primaryColumn).execute();
		while (dataSet.next()) {

			arrayData = new ArrayList<Row>();
			Object dataValue = dataSet.getRow().getValue(primaryColumn);
			DataSet dataSetArray = dataContext.query().from(joinTable).select(forgeinKey).where(primaryColumn)
					.eq(dataValue).execute();
			System.out.println( dataContext.query().from(joinTable).select(forgeinKey).where(primaryColumn)
					.eq(dataValue).toQuery().toSql());
			readDataSet(dataSetArray);
			ComplexData complexDataObject = new ComplexData(dataSet.getRow(), arrayData);
			queueComplexData.put(complexDataObject);
			dataSetArray.close();
//			dataContext.executeUpdate();

		}
		insertPosion();
		dataSet.close();

	}
 
开发者ID:Iranox,项目名称:mapbench-datadistributor,代码行数:24,代码来源:ComplexDataReader.java


示例3: loadIntoMemory

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
public SimpleDictionary loadIntoMemory(final DatastoreConnection datastoreConnection) {
    final DataContext dataContext = datastoreConnection.getDataContext();
    final Column column = getColumn(datastoreConnection);

    final Query query = dataContext.query().from(column.getTable()).select(column).toQuery();
    if (datastoreConnection.getDatastore().getPerformanceCharacteristics().isQueryOptimizationPreferred()) {
        query.getSelectClause().setDistinct(true);
    }

    final Set<String> values = new HashSet<>();

    try (DataSet dataSet = dataContext.executeQuery(query)) {
        while (dataSet.next()) {
            final Object value = dataSet.getRow().getValue(0);
            if (value != null) {
                values.add(value.toString());
            }
        }
    }

    return new SimpleDictionary(getName(), values);
}
 
开发者ID:datacleaner,项目名称:DataCleaner,代码行数:23,代码来源:DatastoreDictionary.java


示例4: loadIntoMemory

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
public SimpleSynonymCatalog loadIntoMemory(final DatastoreConnection datastoreConnection) {
    final Map<String, String> synonymMap = new HashMap<>();

    final Column masterTermColumn = getMasterTermColumn(datastoreConnection);
    final Column[] columns = getSynonymColumns(datastoreConnection);

    try (DataSet dataSet = datastoreConnection.getDataContext().query().from(masterTermColumn.getTable().getName())
            .select(masterTermColumn).select(columns).execute()) {
        while (dataSet.next()) {
            final Row row = dataSet.getRow();
            final String masterTerm = getMasterTerm(row, masterTermColumn);
            final String[] synonyms = getSynonyms(row, columns);
            for (final String synonym : synonyms) {
                synonymMap.put(synonym, masterTerm);
            }
        }
    }

    return new SimpleSynonymCatalog(getName(), synonymMap);
}
 
开发者ID:datacleaner,项目名称:DataCleaner,代码行数:21,代码来源:DatastoreSynonymCatalog.java


示例5: performQuery

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
private Object[] performQuery(final InputRow row, final List<Object> queryInput) {
    try {
        final Column[] queryConditionColumns = getQueryConditionColumns();

        final Object[] parameterValues = new Object[queryConditionColumns.length];
        for (int i = 0; i < queryConditionColumns.length; i++) {
            parameterValues[i] = queryInput.get(i);
        }

        try (DataSet dataSet = datastoreConnection.getDataContext().executeQuery(lookupQuery, parameterValues)) {
            return handleDataSet(row, dataSet);
        }
    } catch (final RuntimeException e) {
        logger.error("Error occurred while looking up based on conditions: " + queryInput, e);
        throw e;
    }
}
 
开发者ID:datacleaner,项目名称:DataCleaner,代码行数:18,代码来源:TableLookupTransformer.java


示例6: DataSetWindow

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
public DataSetWindow(final Query query, final DataContext dataContext, final int pageSize,
        final WindowContext windowContext) {
    super(windowContext);
    _table = new DCTable();
    _query = query;
    _pageSize = pageSize;
    _title = "DataSet: " + _query.toSql();
    _tableModelCallable = () -> {
        final DataSet dataSet = dataContext.executeQuery(_query);
        return new DataSetTableModel(dataSet);
    };
    _previousPageButton = WidgetFactory.createDefaultButton("Previous page", IconUtils.ACTION_BACK);
    _previousPageButton.setEnabled(false);
    _nextPageButton = WidgetFactory.createDefaultButton("Next page", IconUtils.ACTION_FORWARD);
    _nextPageButton.setHorizontalTextPosition(SwingConstants.LEFT);
    _nextPageButton.setEnabled(false);
}
 
开发者ID:datacleaner,项目名称:DataCleaner,代码行数:18,代码来源:DataSetWindow.java


示例7: getPreviewData

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
private DataSet getPreviewData(final String filename) {
    if (!isPreviewDataAvailable()) {
        logger.info("Not displaying preview table because isPreviewDataAvailable() returned false");
        return null;
    }

    final D datastore = getPreviewDatastore(filename);
    try (DatastoreConnection con = datastore.openConnection()) {
        final DataContext dc = con.getDataContext();
        final Table table = getPreviewTable(dc);

        List<Column> columns = table.getColumns();
        if (columns.size() > getPreviewColumns()) {
            // include max 10 columns
            columns = columns.stream().limit(getPreviewColumns()).collect(Collectors.toList());
        }
        final Query q = dc.query().from(table).select(columns).toQuery();
        q.setMaxRows(7);

        return dc.executeQuery(q);
    }
}
 
开发者ID:datacleaner,项目名称:DataCleaner,代码行数:23,代码来源:AbstractFileBasedDatastoreDialog.java


示例8: performAssertions

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
public void performAssertions(final DataSet dataSet, final boolean typeSafe) {
    Assert.assertTrue(dataSet.next());
    assertEquals("hello, world", dataSet.getRow().getValue(0), typeSafe);
    assertEquals(null, dataSet.getRow().getValue(1), typeSafe);

    assertEquals(getExampleDate(), dataSet.getRow().getValue(2), typeSafe);
    assertEquals(null, dataSet.getRow().getValue(3), typeSafe);

    Assert.assertTrue(dataSet.next());
    assertEquals(null, dataSet.getRow().getValue(0), typeSafe);
    assertEquals(-20, dataSet.getRow().getValue(1), typeSafe);
    assertEquals(null, dataSet.getRow().getValue(2), typeSafe);
    assertEquals(3.14f, dataSet.getRow().getValue(3), typeSafe);
    assertEquals("testObject", dataSet.getRow().getValue(4), typeSafe);

    Assert.assertFalse(dataSet.next());
}
 
开发者ID:datacleaner,项目名称:DataCleaner,代码行数:18,代码来源:OutputWriterScenarioHelper.java


示例9: testFullScenario

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
public void testFullScenario() throws Exception {
    final OutputWriterScenarioHelper scenarioHelper = new OutputWriterScenarioHelper();

    final String filename = "target/test-output/csv-file1.txt";
    final OutputWriter writer = CsvOutputWriterFactory.getWriter(filename, scenarioHelper.getColumns());

    scenarioHelper.writeExampleData(writer);
    writer.close();

    final DataContext dc = DataContextFactory.createCsvDataContext(new File(filename));
    final Table table = dc.getDefaultSchema().getTable(0);
    final Query q = dc.query().from(table).select(table.getColumns()).toQuery();
    final DataSet dataSet = dc.executeQuery(q);

    scenarioHelper.performAssertions(dataSet, false);
}
 
开发者ID:datacleaner,项目名称:DataCleaner,代码行数:17,代码来源:CsvOutputWriterFactoryTest.java


示例10: materializeMainSchemaTable

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
@Override
protected DataSet materializeMainSchemaTable(final Table table, final List<Column> columns, final int maxRows) {
    final SelectItem[] tableSelectItems = MetaModelHelper.createSelectItems(table.getColumns().toArray(new Column[0]));
    final SelectItem[] selectItems = MetaModelHelper.createSelectItems(columns.toArray(new Column[0]));
    final SimpleDataSetHeader header = new SimpleDataSetHeader(tableSelectItems);

    final List<Row> rows = new ArrayList<>();
    
    final SimpleDataSetHeader subSelectionHeader = new SimpleDataSetHeader(selectItems);

    rows.add(new DefaultRow(header, new Object[] { 1, "hello" }).getSubSelection(subSelectionHeader));
    rows.add(new DefaultRow(header, new Object[] { 2, "there" }).getSubSelection(subSelectionHeader));
    rows.add(new DefaultRow(header, new Object[] { 3, "big" }).getSubSelection(subSelectionHeader));
    rows.add(new DefaultRow(header, new Object[] { 4, "wide" }).getSubSelection(subSelectionHeader));
    rows.add(new DefaultRow(header, new Object[] { 5, "world" }).getSubSelection(subSelectionHeader));

    return new InMemoryDataSet(rows);
}
 
开发者ID:datacleaner,项目名称:DataCleaner,代码行数:19,代码来源:SampleDataContext.java


示例11: performQuery

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
private Object[] performQuery(List<Object> queryInput) {
    try {
        final Column[] queryConditionColumns = getQueryConditionColumns();

        final Object[] parameterValues = new Object[queryConditionColumns.length];
        for (int i = 0; i < queryConditionColumns.length; i++) {
            parameterValues[i] = queryInput.get(i);
        }

        try (final DataSet dataSet = datastoreConnection.getDataContext()
                .executeQuery(lookupQuery, parameterValues)) {
            return handleDataSet(dataSet);
        }
    } catch (RuntimeException e) {
        logger.error("Error occurred while looking up based on conditions: " + queryInput, e);
        throw e;
    }
}
 
开发者ID:datacleaner,项目名称:AnalyzerBeans,代码行数:19,代码来源:TableLookupTransformer.java


示例12: getValues

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
@Override
public Collection<String> getValues() {
    try (final DatastoreConnection con = _datastore.openConnection()) {
        final DataContext dataContext = con.getDataContext();

        final Query q = dataContext.query().from(_column.getTable()).select(_column).toQuery();
        q.selectDistinct();

        try (final DataSet dataSet = dataContext.executeQuery(q)) {
            final List<String> values = new ArrayList<String>();
            while (dataSet.next()) {
                final Row row = dataSet.getRow();
                
                Object value = row.getValue(0);
                if (value != null) {
                    value = value.toString();
                }
                values.add((String) value);
            }
            return values;
        }
    }
}
 
开发者ID:datacleaner,项目名称:AnalyzerBeans,代码行数:24,代码来源:DatastoreReferenceValues.java


示例13: materializeMainSchemaTable

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
@Override
protected DataSet materializeMainSchemaTable(Table table, Column[] columns, int maxRows) {
    DataInputStream inputStream = createInputStream();

    // skip through the metadata section
    try {
        readMetadataSection(inputStream);
    } catch (RuntimeException e) {
        FileHelper.safeClose(inputStream);
        throw e;
    }

    DataSet dataSet = new KettleDataSet(columns, inputStream, rowMeta);
    if (maxRows >= 0) {
        dataSet = new MaxRowsDataSet(dataSet, maxRows);
    }
    return dataSet;
}
 
开发者ID:datacleaner,项目名称:pdi-datacleaner,代码行数:19,代码来源:KettleDataContext.java


示例14: materializeMainSchemaTable

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
@Override
protected DataSet materializeMainSchemaTable(Table table, List<Column> columns, int firstRow, int maxRows) {
    // the connector represents a handle to the the couchdb "database".
    final String databaseName = table.getName();
    final CouchDbConnector connector = _couchDbInstance.createConnector(databaseName, false);

    ViewQuery query = new ViewQuery().allDocs().includeDocs(true);

    if (maxRows > 0) {
        query = query.limit(maxRows);
    }
    if (firstRow > 1) {
        final int skip = firstRow - 1;
        query = query.skip(skip);
    }

    final StreamingViewResult streamingView = connector.queryForStreamingView(query);

    final List<SelectItem> selectItems = columns.stream().map(SelectItem::new).collect(Collectors.toList());
    return new CouchDbDataSet(selectItems, streamingView);
}
 
开发者ID:apache,项目名称:metamodel,代码行数:22,代码来源:CouchDbDataContext.java


示例15: executeQuery

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
@Override
public DataSet executeQuery(Table table, List<Column> columns, int maxRows) {
    final Workbook wb = ExcelUtils.readWorkbook(_resource);
    final Sheet sheet = wb.getSheet(table.getName());

    if (sheet == null || sheet.getPhysicalNumberOfRows() == 0) {
        return new EmptyDataSet(columns.stream().map(SelectItem::new).collect(Collectors.toList()));
    }

    DataSet dataSet = ExcelUtils.getDataSet(wb, sheet, table, _configuration);

    if (maxRows > 0) {
        dataSet = new MaxRowsDataSet(dataSet, maxRows);
    }
    return dataSet;
}
 
开发者ID:apache,项目名称:metamodel,代码行数:17,代码来源:DefaultSpreadsheetReaderDelegate.java


示例16: testGroupByQuery

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
@Test
public void testGroupByQuery() throws Exception {
    Table table = dataContext.getDefaultSchema().getTableByName(peopleIndexType);

    Query q = new Query();
    q.from(table);
    q.groupBy(table.getColumnByName("gender"));
    q.select(new SelectItem(table.getColumnByName("gender")),
            new SelectItem(FunctionType.MAX, table.getColumnByName("age")),
            new SelectItem(FunctionType.MIN, table.getColumnByName("age")), new SelectItem(FunctionType.COUNT, "*",
                    "total"), new SelectItem(FunctionType.MIN, table.getColumnByName("id")).setAlias("firstId"));
    q.orderBy("gender");
    DataSet data = dataContext.executeQuery(q);
    assertEquals(
            "[peopletype.gender, MAX(peopletype.age), MIN(peopletype.age), COUNT(*) AS total, MIN(peopletype.id) AS firstId]",
            Arrays.toString(data.getSelectItems().toArray()));

    assertTrue(data.next());
    assertEquals("Row[values=[female, 20, 17, 5, 5]]", data.getRow().toString());
    assertTrue(data.next());
    assertEquals("Row[values=[male, 19, 17, 4, 1]]", data.getRow().toString());
    assertFalse(data.next());
}
 
开发者ID:apache,项目名称:metamodel,代码行数:24,代码来源:ElasticSearchDataContextTest.java


示例17: testDoubleQuoteEscape

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
@Test
public void testDoubleQuoteEscape() throws Exception {
    CsvConfiguration configuration = new CsvConfiguration(1, "UTF-8", ',', '"', '"');
    CsvDataContext dc = new CsvDataContext(new File("src/test/resources/csv_doublequoteescape.csv"), configuration);

    DataSet dataSet = dc.query().from("csv_doublequoteescape.csv").select("age", "name").execute();

    assertTrue(dataSet.next());
    assertEquals("Row[values=[18, mi\"ke]]", dataSet.getRow().toString());

    assertEquals("mi\"ke", dataSet.getRow().getValue(dc.getColumnByQualifiedLabel("name")));

    assertTrue(dataSet.next());
    assertEquals("Row[values=[19, mic\"hael]]", dataSet.getRow().toString());
    assertTrue(dataSet.next());
    assertEquals("Row[values=[18, pet\"er]]", dataSet.getRow().toString());
    assertTrue(dataSet.next());
    assertEquals("Row[values=[18, barbar\"a, \"\"barb]]", dataSet.getRow().toString());

    dataSet.close();
}
 
开发者ID:apache,项目名称:metamodel,代码行数:22,代码来源:DoubleQuoteEscapeTest.java


示例18: testExecuteQueryBeforeLoadingSchema

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
/**
 * Tests that you can execute a query on a ExcelDataContext even though the
 * schema has not yet been (explicitly) loaded.
 */
public void testExecuteQueryBeforeLoadingSchema() throws Exception {
    // first use one DataContext to retreive the schema/table/column objects
    ExcelDataContext dc1 = new ExcelDataContext(copyOf("src/test/resources/Spreadsheet2007.xlsx"));
    Schema schema = dc1.getDefaultSchema();
    Table table = schema.getTable(0);
    Column column = table.getColumn(0);

    // query another DataContext using the schemas of the one above
    ExcelDataContext dc2 = new ExcelDataContext(copyOf("src/test/resources/Spreadsheet2007.xlsx"));
    DataSet ds = dc2.executeQuery(new Query().from(table).select(column));

    // previously we would crash at this point!

    assertNotNull(ds);
    ds.close();
}
 
开发者ID:apache,项目名称:metamodel,代码行数:21,代码来源:ExcelDataContextTest.java


示例19: testApproximatedCountSmallFile

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
public void testApproximatedCountSmallFile() throws Exception {
    DataContext dc = new CsvDataContext(new File("src/test/resources/csv_people.csv"));

    Table table = dc.getDefaultSchema().getTables().get(0);
    Query q = dc.query().from(table).selectCount().toQuery();
    SelectItem selectItem = q.getSelectClause().getItem(0);
    selectItem.setFunctionApproximationAllowed(true);

    DataSet ds = dc.executeQuery(q);
    assertTrue(ds.next());
    Object[] values = ds.getRow().getValues();
    assertEquals(1, values.length);
    assertEquals(9, ((Long) ds.getRow().getValue(selectItem)).intValue());
    assertEquals(9, ((Long) values[0]).intValue());
    assertFalse(ds.next());
}
 
开发者ID:apache,项目名称:metamodel,代码行数:17,代码来源:CsvDataContextTest.java


示例20: testQuerySameScalarFunctionOnSameColumnButDifferentParamsInBothSelectAndWhere

import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
public void testQuerySameScalarFunctionOnSameColumnButDifferentParamsInBothSelectAndWhere() throws Exception {
    final DataContext dc = getDataContext();
    final Query query = dc.parseQuery(
            "SELECT SUBSTRING(name, 1, 3) FROM contributor WHERE SUBSTRING(name, 4, 3) = 'per' ORDER BY contributor_id");

    // assert on the parsed select items just to ensure that nothing gets mangled in the parsing
    assertSame(FunctionType.SUBSTRING, query.getSelectClause().getItem(0).getScalarFunction());
    assertEquals(" 1", query.getSelectClause().getItem(0).getFunctionParameters()[0]);
    assertEquals(" 3", query.getSelectClause().getItem(0).getFunctionParameters()[1]);
    assertSame(FunctionType.SUBSTRING, query.getWhereClause().getItem(0).getSelectItem().getScalarFunction());
    assertEquals(" 4", query.getWhereClause().getItem(0).getSelectItem().getFunctionParameters()[0]);
    assertEquals(" 3", query.getWhereClause().getItem(0).getSelectItem().getFunctionParameters()[1]);

    try (DataSet ds = dc.executeQuery(query)) {
        assertTrue(ds.next());
        // name is "kasper"
        final Object value1 = ds.getRow().getValue(0);
        assertEquals("kas", value1.toString());
        assertTrue(ds.next());
        // name is "jesper"
        final Object value2 = ds.getRow().getValue(0);
        assertEquals("jes", value2.toString());
        assertFalse(ds.next());
    }
}
 
开发者ID:apache,项目名称:metamodel,代码行数:26,代码来源:QueryPostprocessDataContextTest.java



注:本文中的org.apache.metamodel.data.DataSet类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java GearJointDef类代码示例发布时间:2022-05-23
下一篇:
Java Pair类代码示例发布时间:2022-05-23
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap