package dao;
import java.util.ArrayList;
import java.util.List;
import org.hibernate.Query;
import org.hibernate.SQLQuery;
import org.hibernate.Transaction;
import com.sun.org.apache.bcel.internal.generic.GETSTATIC;
import common.BaseDAO;
import common.DataZh;
import entity.Station;
//station和ddxx是一对多关系，为保证代码整洁，每个实体的增删改查写在自己的dao,复杂查询可以写在需要的dao里
public class StationDAO extends BaseDAO<Station> {
////////////////////////////////////////////////////////////////演示hql查询
// 使用Hql查询站名里含"京"字的所有站点
public List findByproperty(String propertyName) {
// 通过占位符传参
String querystring = "from Station as model where model.czmc like ?";
// 显示传参
// String
// querystring="from Station as model where model.czmc like '%"+propertyName+"%'";
Query queryObject = gs().createQuery(querystring);
queryObject.setParameter(0, "%" + propertyName + "%"); // 传参
return queryObject.list();
}
// 查询最后一个字是"京"字并且等级是"一级的"所有站点
public List findByKey(String Key1, String Key2) {
String querystring = "from Station as model where model.czmc like ? and model.dj=?";
// 显示传参
// String
// querystring="from Station as model where model.czmc like '%"+propertyName+"%'";
Query queryObject = gs().createQuery(querystring);
queryObject.setParameter(0, "%" + Key1);
queryObject.setParameter(1, Key2); // 传参
return queryObject.list();
}
// 通过判断参数动态组合Hql语句，生成基本通用查询
public List find(Station entity) {
List reuslt = null;
// 字符串辅助类
StringBuffer hql = new StringBuffer("from Station where 1=1");
List vp = new ArrayList();
if (entity != null) {
// 小于0的和null都不做比较
if (entity.getCzdm() != null && entity.getCzdm() < 0) {
hql.append(" and czdm=?");
vp.add(entity.getCzdm());
}
// 空字符串和null都不做比较
if (entity.getCzmc() != null && entity.getCzmc().length() > 0) {
hql.append(" and czmc = ?");
vp.add(entity.getCzmc());
}
if (entity.getDj() != null) {
hql.append(" and dj=?");
vp.add(entity.getDj());
}
}
Query q = gs().createQuery(hql.toString());
for (int i = 0; i < vp.size(); i++) {
q.setParameter(i, vp.get(i));
}
reuslt = q.list();
return reuslt;
}
////////////////////////////////////////////////////////////////演示复杂查询
// 使用原生sql,根据等级模糊查询符合条件的所有车站名
public List<String> findonebydj(String dj) {
// sql语句
String sql = "select czmc from station where dj like '%" + dj + "%'";
SQLQuery q = gs().createSQLQuery(sql);
return DataZh.ObjtoStr(q.list());
}
// 使用原生sql,根据等级模糊查询符合条件的所有的车站名和车站代码
public List<String[]> findmanybydj(String dj) {
// sql语句
String sql = "select czmc,czdm from station where dj like '%" + dj
+ "%'";
SQLQuery q = gs().createSQLQuery(sql);
return DataZh.ObjArrtoStrArr(q.list());
}
// 使用原生sql,关联两表station,ddxx, 查询广州东发出的所有订单id,状态,等级
public List<String[]> findmanysbydj(String dj) {
// sql语句
String sql = "select a.czmc,id,b.status,dj from station a,ddxx b where a.czdm=b.czid and a.czmc='"
+ dj + "'";
SQLQuery q = gs().createSQLQuery(sql);
return DataZh.ObjArrtoStrArr(q.list());
}
////////////////////////////////////////////////////////////////演示复杂删除
// 输入车站代码，将相关的车站和订单全部删除
public int excuteFzDelete(Integer id) {
//分别删除
String sql = "delete from station where czdm=" + id;
String sql2 = "delete from ddxx where czid=" + id;
// 增删改需要事务，事务开始
Transaction tx = null;
tx = gs().beginTransaction();
SQLQuery q = gs().createSQLQuery(sql);
int a = q.executeUpdate();
SQLQuery q2 = gs().createSQLQuery(sql2);
int b = q2.executeUpdate();
tx.commit(); // 提交事务
if (a > 0 || b > 0) //有效删除则返回1
return 1;
else
return 0; //无效删除则返回0
}
////////////////////////////////////////////////////////////////演示复杂更新
// 将所有无效的（车站已经不存在的）订单全部车站ID（czid）全部更新为指定的车站ID
//复杂更新，需用inner join
//update ddxx a INNER JOIN
//(select id from ddxx where czid not in(select DISTINCT czdm from station)) as b
//ON a.id=b.id set czid=222
public int excuteFzUpdate(Integer czid)
{
StringBuffer s=new StringBuffer();
s.append("update ddxx a INNER JOIN");
s.append("(select id from ddxx where czid not in(select DISTINCT czdm from station)) as b");
s.append(" ON a.id=b.id set czid="+czid);
//增删改加事务
Transaction tx;
tx=gs().beginTransaction();
SQLQuery q=gs().createSQLQuery(s.toString());
//受影响的行数
int a=q.executeUpdate();
tx.commit();
return a;
}
////////////////////////////////////////////////////////////////演示多对多
/*
* 站点（Station）与线路(Line)是多对多关系，
* 在数据库里面，解决方式是拆成三张表，做一个中间表，中间表要包含两个主表的主键
* 多对多拆成了两个一对多
*
*/
//查询经过指定站点的所有线路名称
public List<String> searchLineByStation(String czmc)
{
String sql = "select xlmc from line where xlid in (select a.LID from stationjoinline a,station b where a.SID = b.czdm and b.czmc=?)";
SQLQuery q=gs().createSQLQuery(sql);
//建议使用setParameter加参数
q.setParameter(0, czmc);
return DataZh.ObjtoStr(q.list());
}
//查询指定线路经过的所有站点名称,站点ID
public List<String[]> searchStationByLine(String xlmc)
{
String sql="SELECT * from station c WHERE c.czdm IN"+
"(SELECT b.SID FROM stationjoinline b WHERE b.LID IN"+
"(SELECT a.xlid FROM line a WHERE a.xlmc=?))";
SQLQuery q=gs().createSQLQuery(sql);
q.setParameter(0, xlmc);
List<String[]> list=q.list();
return DataZh.ObjArrtoStrArr(q.list());
}
////////////////////////////////////////////////////////////dao总结
/*
* 总结：
*
* --------------------------------------查询
* 1.hql查询
*
* StringBuffer hql = new StringBuffer("from Station where 1=1");
*
* Query q = gs().createQuery(hql.toString());
*
* q.list();
*
* 2.sql查询
*
* String sql = "select czmc,czdm from station where dj like '%" + dj
+ "%'";
SQLQuery q = gs().createSQLQuery(sql); //sql查询使用createSQLQuery
q.list();
*
* DataZh.ObjArrtoStrArr(q.list()) //sql查询返回的是Object，记得转换
*
*
* --------------------------------------增删改
* 使用原生sql语句执行
*
* String sql = "delete from station where czdm=" + id;
*
* Transaction tx = null;
tx = gs().beginTransaction();
SQLQuery q = gs().createSQLQuery(sql);
* tx.commit(); // 提交事务
*
* q.executeUpdate() //增删改的语句使用这个函数
*
* return result //返回受影响的行数
*
*/
}