JDO Query介绍

类别:Java 点击:0 评论:0 推荐:

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