Query 介绍
你可以通过PersistenceManager获得一个Query对象。Query对象用于从持久化对象中查询数据。下面我们将详细的讨论Query中的每个部分。
1. 必须的Query元素
public void setClass (Class candidateClass);
public void setCandidates (Extent candidates);
public void setCandidates (Collection candidates);
public void setFilter (String filter);
Query有3个必须的元素:
1) 候选类:用于查询的候选类或子类,这个候选类通过setClass方法设置。
2) 候选对象集合:候选类可以被置于一个集合中或是一个Extent中,你可以通过setCandidates方法来设置他们。
3) 查询字符串:这是一个JDOQL字符串,你可以通过setFilter来设置它。
2. 可选的Query元素
public void declareImports (String imports);
public void declareParameters (String parameters);
public void declareVariables (String variables);
public void setOrdering (String ordering);
Query有4个可选的元素:
1) Import:它可以通过declareImports来设置,这个字符串是几个由分号格开的标准的Javaa Import语法,这和JSP中的@page import=””语法相似。通过这个设置你就可以不必把输出的类名全部列处理。
2) 参数声明:用于设置Query的查询参数,可以通过declareParameters设置。
3) 变量声明:用于设置Query查询参数的值,可以通过declareVariables设置。
4) 排序:设置返回的查询结果的排序方式,含义相当于sql语言中的order by,可以通过setOrdering设置。
3. JDOQL
JDOQL是一个与具体数据库无关的查询语言,它和标准的SQL语法非常类似,但也有一些不同:
1) 允许原始类型和原始类型的封装类的比较和排序。
2) 允许Date对象的比较和排序。
3) 比较操作使用“==”,不支持equals比较操作。
4) 不支持=, +=, *=,++ 和—等操作
5) 不支持除了下面以为的方法:
Collection.contains
Collection.isEmpty
String.startsWith
String.endsWith
6) 如果得到一个空值将抛出NullPointException异常。
现在我们将举例说明JDOQL和Query的使用,它将使用下面的持久化类
package org.mag;
public class Magazine
{
private String title;
private double price;
private int copiesSold;
private Company publisher;
private Article coverArticle;
private Set articles;
...
}
public class Article
{
private String title;
private Collection subTitles;
...
}
package org.mag.pub;
public class Company
{
private String name;
private double revenue;
...
}
例1:最基本的查询
查询价格大于10元的杂志(Magazine)。注意我们也可以在查询字符中使用持久化类的持久字段。
Extent mags = pm.getExtent (Magazine.class, false);
String filter = "price > 10.0";
Query query = pm.newQuery (mags, filter);
Collection results = (Collection) query.execute ();
例子2:排序和方法调用
查询以The开头的记录并按升序排列结果。
Extent mags = pm.getExtent (Magazine.class, false);
String filter = "title.startsWith (\"The \")";
Query query = pm.newQuery (mags, filter);
query.setOrdering ("price ascending");//按升序排列
Collection results = (Collection) query.execute ();
例子3:精确操作和关系遍历
Extent mags = pm.getExtent (Magazine.class, false);
String filter = "price * copiesSold > publisher.revenue * .01";
Query query = pm.newQuery (mags, filter);
query.setOrdering ("publisher.revenue descending, publisher.name ascending");
Collection results = (Collection) query.execute ();
查询杂志的价格收入大于1%的记录,把价格按降序排列,出版社的名称按升序排列。
例子4:优先和逻辑操作
查询杂志的价格小于等于10元并且出版社的名称是Random House或Addison Wesley的。
Extent mags = pm.getExtent (Magazine.class, false);
String filter = "price <= 10.0 "
+ "&& (publisher.name == \"Random House\" "
+ "|| publisher.name == \"Addison Wesley\")";
Query query = pm.newQuery (mags, filter);
Collection results = (Collection) query.execute ();
例子5:导入和参数
通过给定的公司或价格查询属于这个出版社并且价格大于10元的杂志。
declareImports导入了我们需要的Company类,你要可以通过设置字符串为“import org.mag.pub.Company“只导入一个Company类。
Company myCompany = ...;
Double myPrice = ...;
Extent mags = pm.getExtent (Magazine.class, false);
String filter = "publisher == pub && price > amnt";
Query query = pm.newQuery (mags, filter);
query.declareImports ("import org.mag.pub.*;");
query.declareParameters ("Company pub, Double amnt");
Collection results = (Collection) query.execute (myCompany, myPrice);
例子6:集合
查询杂志的中标题包含“The Real Story“或者没有标题的文章。
Extent mags = pm.getExtent (Magazine.class, false);
String filter = "coverArticle.subTitles.contains (\"The Real Story\") "
+ "|| coverArticle.subTitles.isEmpty ()";
Query query = pm.newQuery (mags, filter);
Collection results = (Collection) query.execute ();
例子7:变量
查询标题为“Fourier Transforms“的文章。注意这里的标题使用了一个变量art来代替Article。
Extent mags = pm.getExtent (Magazine.class, false);
String filter = "articles.contains (art) "
+ "&& art.title == \"Fourier Transforms\"";
Query query = pm.newQuery (mags, filter);
query.declareVariables ("Article art");
Collection results = (Collection) query.execute ();
例子8:集合参数
查询文章标题符合条件的记录,可能的标题放到一个集合中,这有点和SQL中in操作类似。
Collection titles = ...; // 可能的标题集合
Extent mags = pm.getExtent (Magazine.class, false);
String filter = "articles.contains (art) "
+ "&& titles.contains (art.title)";
Query query = pm.newQuery (mags, filter);
query.declareParameters ("Collection titles");
query.declareVariables ("Article art");
Collection results = (Collection) query.execute ();
4. 执行查询
public Object execute ();
public Object execute (Object param1);
public Object execute (Object param1, Object param2);
public Object execute (Object param1, Object param2, Object param3);
public Object executeWithArray (Object[] params);
public Object executeWithMap (Map params);
所有的查询都是通过execute执行的,它返回的结果包含在一个Collection集合中,这个集合中包含结果集的对象。你可以通过集合的迭代获得集合中的对象。最后通过close关闭Query
public void close (Object result);
public void closeAll ();
举例:
PersistenceManager pm = ...;
Query query = pm.newQuery (Employee.class, "salary > 50000");
Collection employees = (Collection) query.execute ();
try
{
for (Iterator itr = employees.iterator (); itr.hasNext ();)
processEmployee ((Employee) itr.next ());
}
finally
{
query.close (employees);
}
5. 查询编辑
你可以在查询之前首先使用compile编译查询,这样可以优化你的查询,如果查询语句有问题会抛出JDOUserException异常。
public void compile ();
本文地址:http://com.8s8s.com/it/it16833.htm