DB検索時にクエリエラーが発生する

Question

Hibernateを使ってWebアプリケーションを作成しています。DBを検索した時にクエリエラーが発生しました。検索ではpreCustomerIdという仮会員IDのみを取得したいです。エラーについて調べてみましたが有力な解決方法が見つかりませんでした。Hibernate JPAにお詳しい方がいましたらご回答をお願いいたします。

※質問の文字数制限の都合でエラーメッセージはキャプチャーとして掲載させていただきます。

package registration.dao;

import java.io.Closeable;
import java.io.IOException;
import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.EntityTransaction;
import javax.persistence.TypedQuery;

import registration.entity.PreUserEntity;
import util.dao.EmProvider;

/**
 * 仮ユーザーテーブルにアクセスする
 *
 * @author user
 *
 */
public class PreUserDAO implements Closeable {

	private final static String SQL_FIND_ALL_PRE_USER_ID = "PreUser.findAllPreCostomerId";

    private EntityManager em = null;
    EntityTransaction et = null;

	/**
	 * 発番された仮会員IDがテーブルに存在するかどうかを確認する
	 */
	public void findAllPreUserId() {

	    EntityManager em = null;
	    try {

	        em = EmProvider.getInstance().getEntityManagerFactory().createEntityManager();

	        if(em == null){
	        	System.out.println("emの設定に失敗");
	        }

	        TypedQuery<PreUserEntity> query = em.createNamedQuery(SQL_FIND_ALL_PRE_USER_ID, PreUserEntity.class);

	        if(query == null){
	        	System.out.println("検索結果のマッピングに失敗");
	        }

	        List<PreUserEntity> entity = query.getResultList();

	        if(entity.size() != 0){
	        	System.out.println("検索成功しました。");
	        } else {
	        	System.out.println("検索結果に失敗しました。");
	        }
	    }
	    catch(Exception e) {
	    	e.printStackTrace();
	    }
	    finally {
	        if(em != null) {
	             em.close();
	        }
	        EmProvider.getInstance().closeEmf();
	    }
	}

	@Override
	public void close() throws IOException {
		if (em != null) {
			em.close();
		}
	}
}

package registration.entity;

import java.io.Serializable;
import java.util.Date;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
import javax.persistence.Temporal;
import javax.persistence.TemporalType;

import org.hibernate.annotations.NamedQueries;
import org.hibernate.annotations.NamedQuery;

/**
 * The persistent class for the pre_user database table.
 *
 */
@Entity
@Table(name = "pre_user")
@NamedQueries({
	@NamedQuery(name = "PreUser.find", query = "SELECT p FROM pre_user p"),
	@NamedQuery(name = "PreUser.findAllPreCostomerId", query = "SELECT NEW registration.entity.PreUserEntity (p.preCustomerId) FROM pre_user p")
})

public class PreUserEntity implements Serializable {

	private static final long serialVersionUID = 1L;

	@Id
	@Column(name="pre_customer_id")
	private String preCustomerId;

	@Column(name="process_name")
	private String processName;

	@Column(name="process_status")
	private String processStatus;

	@Temporal(TemporalType.TIMESTAMP)
	@Column(name="register_time")
	private Date registerTime;

	@Column(name="register_user")
	private String registerUser;

	@Temporal(TemporalType.TIMESTAMP)
	@Column(name="update_time")
	private Date updateTime;

	@Column(name="update_user")
	private String updateUser;

	public PreUserEntity() {
	}

	public PreUserEntity(String preCostomerId) {
		this.preCustomerId = preCostomerId;
	}

	public String getPreCustomerId() {
		return this.preCustomerId;
	}

	public void setPreCustomerId(String preCustomerId) {
		this.preCustomerId = preCustomerId;
	}

	public String getProcessName() {
		return this.processName;
	}

	public void setProcessName(String processName) {
		this.processName = processName;
	}

	public String getProcessStatus() {
		return this.processStatus;
	}

	public void setProcessStatus(String processStatus) {
		this.processStatus = processStatus;
	}

	public Date getRegisterTime() {
		return this.registerTime;
	}

	public void setRegisterTime(Date registerTime) {
		this.registerTime = registerTime;
	}

	public String getRegisterUser() {
		return this.registerUser;
	}

	public void setRegisterUser(String registerUser) {
		this.registerUser = registerUser;
	}

	public Date getUpdateTime() {
		return this.updateTime;
	}

	public void setUpdateTime(Date updateTime) {
		this.updateTime = updateTime;
	}

	public String getUpdateUser() {
		return this.updateUser;
	}

	public void setUpdateUser(String updateUser) {
		this.updateUser = updateUser;
	}
}

Answer 1

queryのFROM句で指定しているテーブル名は、実テーブル名ではなく、クラスを指定します。

 @NamedQuery(name = "PreUser.find", query = "SELECT p FROM PreUser p"),
 @NamedQuery(name = "PreUser.findAllPreCostomerId", query = "SELECT NEW registration.entity.PreUserEntity (p.preCustomerId) FROM PreUser p")

Comments

[Linkey]

ありがとうございました。無事に解決できました。