com.yahoo.squidb.sql.Query.select()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(8.7k)|赞(0)|评价(0)|浏览(121)

本文整理了Java中com.yahoo.squidb.sql.Query.select方法的一些代码示例,展示了Query.select的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Query.select方法的具体详情如下:
包路径:com.yahoo.squidb.sql.Query
类名称:Query
方法名:select

Query.select介绍

[英]Construct a new Select statement that queries for the specified Field
[中]构造查询指定字段的新Select语句

代码示例

代码示例来源:origin: yahoo/squidb

/**
 * Construct a new Select statement that queries all the {@link Field Fields} of the given {@link View}
 *
 * @param view the View to select from
 * @return a new Query object
 */
public static Query fromView(View view) {
  return Query.select(view.qualifiedFields()).from(view);
}

代码示例来源:origin: yahoo/squidb

public void testSelectFunction() {
  Function<String> upper = Function.upper(TestModel.LAST_NAME);
  SquidCursor<TestModel> cursor = database
      .query(TestModel.class, Query.select(TestModel.PROPERTIES).selectMore(upper));
  try {
    cursor.moveToFirst();
    new TestModel(cursor); // Should succeed without throwing an exception
  } finally {
    cursor.close();
  }
}

代码示例来源:origin: yahoo/squidb

protected <TYPE extends AbstractModel> SquidCursor<TYPE> fetchFirstItem(Class<TYPE> modelClass,
    Criterion criterion, Property<?>... properties) {
  return fetchFirstItem(modelClass, Query.select(properties).where(criterion));
}

代码示例来源:origin: yahoo/squidb

/**
 * Construct a new Select statement that queries all the {@link Field}s of the given subquery
 *
 * @param subquery the inner Query object
 * @param subqueryAlias the name to alias the subquery
 * @return a new Query object
 */
public static Query fromSubquery(Query subquery, String subqueryAlias) {
  SubqueryTable table = subquery.as(subqueryAlias);
  return Query.select(table.qualifiedFields()).from(table);
}

代码示例来源:origin: yahoo/squidb

/**
 * Count the number of rows matching a given {@link Criterion}. Use null to count all rows.
 *
 * @param modelClass the model class corresponding to the table
 * @param criterion the criterion to match
 * @return the number of rows matching the given criterion
 */
public int count(Class<? extends AbstractModel> modelClass, Criterion criterion) {
  Property.IntegerProperty countProperty = Property.IntegerProperty.countProperty();
  Query query = Query.select(countProperty);
  if (criterion != null) {
    query.where(criterion);
  }
  query = inferTableForQuery(modelClass, query);
  CompiledStatement compiled = query.compile(getCompileContext());
  acquireNonExclusiveLock();
  try {
    return (int) getDatabase().simpleQueryForLong(compiled.sql, compiled.sqlArgs);
  } finally {
    releaseNonExclusiveLock();
  }
}

代码示例来源:origin: yahoo/squidb

/**
 * Build a {@link Query} combining this object's internal state with the arguments passed. If a
 * {@link ProjectionMap} is set, the projection elements will be evaluated and transformed accordingly. If the
 * sortOrder is null or empty, the default order will be used (if one was set).
 *
 * @param projection the raw column names to be selected
 * @param selection a raw selection string
 * @param selectionArgs array of strings which substitute replaceable arguments in the selection string
 * @param sortOrder a raw ordering clause
 * @return a {@link Query} using the projection, selection, selection args, and sort order
 */
public Query build(String[] projection, String selection, String[] selectionArgs, String sortOrder) {
  Query query = Query.select(computeProjection(projection)).from(dataSource);
  boolean hasUserSelection = !SqlUtils.isEmpty(selection);
  if (hasUserSelection) {
    query.where(Criterion.fromRawSelection(selection, selectionArgs));
  }
  if (!SqlUtils.isEmpty(sortOrder)) {
    query.orderBy(Order.fromExpression(sortOrder));
  } else if (defaultOrder != null && defaultOrder.length > 0) {
    query.orderBy(defaultOrder);
  }
  if (strictMode && hasUserSelection) {
    query.requestValidation();
  }
  return query;
}

代码示例来源:origin: yahoo/squidb

@Override
  public void run() {
    Function<String> json = JSONFunctions.json(" { \"this\" : \"is\", \"a\": [ \"test\" ] } ");
    String minified = database.simpleQueryForString(Query.select(json));
    assertEquals("{\"this\":\"is\",\"a\":[\"test\"]}", minified);
  }
});

代码示例来源:origin: yahoo/squidb

@Override
  public void run() {
    Function<Integer> valid = JSONFunctions.jsonValid(" { \"this\" : \"is\", \"a\": [ \"test\" ] } ");
    Function<Integer> invalid = JSONFunctions.jsonValid(" { \"this\" : \"is\", \"a\": [ \"test\"  } ");
    long validResult = database.simpleQueryForLong(Query.select(valid));
    assertEquals(1, validResult);
    long invalidResult = database.simpleQueryForLong(Query.select(invalid));
    assertEquals(0, invalidResult);
  }
});

代码示例来源:origin: yahoo/squidb

public void testObservableEmitsCustomObject() {
  final AtomicBoolean objectsMatch = new AtomicBoolean(false);
  final Query originalQuery = Query.select().from(TestModel.TABLE);
  Observable<Query> observable = database.observeTableAndEmit(TestModel.TABLE, originalQuery, true);
  observable.subscribe(new Action1<Query>() {
    @Override
    public void call(Query query) {
      objectsMatch.set(originalQuery == query);
    }
  });
  assertTrue(objectsMatch.get());
}

代码示例来源:origin: yahoo/squidb

@Override
  public void run() {
    database.query(TestModel.class, Query.select().from(TestModel.TABLE));
  }
});

代码示例来源:origin: yahoo/squidb

private boolean isJson1ExtensionEnabled() {
  try {
    return database.simpleQueryForLong(Query.select(JSONFunctions.jsonValid("{ \"a\" : \"b\" }"))) != 0;
  } catch (RuntimeException e) {
    Logger.d("JSONFunctionTest", "JSON1 extension not available", e);
    return false;
  }
}

代码示例来源:origin: yahoo/squidb

public void testReusableQuery() {
  AtomicReference<String> name = new AtomicReference<>();
  Query query = Query.select().where(Employee.NAME.eq(name));
  testReusableQueryInternal(name, "bigBird", query);
  testReusableQueryInternal(name, "cookieMonster", query);
  testReusableQueryInternal(name, "elmo", query);
}

代码示例来源:origin: yahoo/squidb

public void testValidationPropagatesToSubqueryJoinAndCompoundSelect() {
  Query subquery = Query.select(Thing.FOO).from(Thing.TABLE).where(Thing.BAR.gt(0));
  Query joinSubquery = Query.select(Thing.BAR).from(Thing.TABLE).where(Thing.FOO.isNotEmpty());
  Query compoundSubquery = Query.select(Thing.BAZ).from(Thing.TABLE).where(Thing.IS_ALIVE.isTrue());
  SubqueryTable subqueryTable = subquery.as("t1");
  SubqueryTable joinTable = joinSubquery.as("t2");
  Query query = Query.select().from(subqueryTable).innerJoin(joinTable, (Criterion[]) null)
      .union(compoundSubquery);
  final int queryLength = query.compile(database.getCompileContext()).sql.length();
  String withValidation = query.sqlForValidation(database.getCompileContext());
  assertEquals(queryLength + 6, withValidation.length());
}

代码示例来源:origin: yahoo/squidb

public void testIdColumnForTableModels() {
  Query query = Query.select(TestModel.PROPERTIES).orderBy(TestModel.ID.asc());
  testCursorAdapterInternal(new TestModel(), null, query, new CursorAdapterTest() {
    @Override
    public void testCursorAdapter(SquidCursorAdapter<AbstractModel> adapter) {
      assertTrue(adapter.hasStableIds());
      assertEquals(1, adapter.getItemId(0));
      assertEquals(2, adapter.getItemId(1));
    }
  });
}

代码示例来源:origin: yahoo/squidb

private void testJsonTypeInternal(String json, String path, String expectedType) {
  Function<String> type;
  if (path == null) {
    type = JSONFunctions.jsonType(json);
  } else {
    type = JSONFunctions.jsonType(json, path);
  }
  String result = database.simpleQueryForString(Query.select(type));
  assertEquals(expectedType, result);
}

代码示例来源:origin: yahoo/squidb

public void testFunctionOnAmbiguousColumnName() {
  IntegerProperty happyCount = IntegerProperty.countProperty(Employee.IS_HAPPY, false);
  Query test = Query.select(TestModel.ID, TestModel.FIRST_NAME, TestModel.IS_HAPPY, happyCount)
      .join(Join.inner(Employee.TABLE, Employee.IS_HAPPY.eq(TestModel.IS_HAPPY)));
  // just test that the query compiles with the function
  database.query(TestModel.class, test);
}

代码示例来源:origin: yahoo/squidb

private <T extends Number> void testMath(Property<T> property, T expectedValue) {
  SquidCursor<?> cursor = database.query(null, Query.select(property));
  try {
    cursor.moveToFirst();
    T value = cursor.get(property);
    assertEquals(expectedValue, value);
  } finally {
    cursor.close();
  }
}

代码示例来源:origin: yahoo/squidb

public void testMin() {
  LongProperty minId = LongProperty.fromFunction(Function.min(TestModel.ID), "minId");
  SquidCursor<TestModel> cursor = database.query(TestModel.class, Query.select(minId));
  try {
    cursor.moveToFirst();
    assertEquals(model1.getRowId(), cursor.get(minId).longValue());
  } finally {
    cursor.close();
  }
}

代码示例来源:origin: yahoo/squidb

public void testBindArgsProtectsInjection() {
  Query q = Query.select().where(Employee.NAME.eq("'Sam'); drop table " + Employee.TABLE.getName() + ";"));
  SquidCursor<Employee> cursor = database.query(Employee.class, q);
  try {
    assertFalse(database.countAll(Employee.class) == 0);
  } finally {
    cursor.close();
  }
}

代码示例来源:origin: yahoo/squidb

public void testQueryFreeze() {
  Query base = Query.select().from(Employee.TABLE).limit(1).freeze();
  Query fork = base.limit(2);
  assertFalse(base == fork);
  assertEquals(Field.field("1"), base.getLimit());
  assertEquals(Field.field("2"), fork.getLimit());
  assertEquals(base.getTable(), fork.getTable());
}

相关文章