📄 tevaluatedao.java
字号:
package edu.yinhe.mis.model;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.List;
import edu.yinhe.mis.dto.HeaderMyselfDTO;
import edu.yinhe.mis.dto.TevaluateDTO;
import edu.yinhe.mis.vo.TevaluateVO;
import edu.yinhe.system.model.BaseDAO;
public class TevaluateDAO extends BaseDAO{
public Object delete(Object arg0) throws SQLException {
// TODO Auto-generated method stub
return null;
}
public Object find() throws SQLException {
// TODO Auto-generated method stub
return null;
}
/**
* @author 姜娟
* 课堂教学记录表与老师表的联系
*/
public Object find(Object arg0) throws SQLException {
/**
* SQL语句预处理
*/
PreparedStatement pstmt=null;
/**
* 结果集的存放;
*/
ResultSet rs=null;
HeaderMyselfDTO dto = (HeaderMyselfDTO)arg0;
ArrayList alist = new ArrayList();
StringBuffer SQL = new StringBuffer("");
TevaluateVO cvo = null;
int nIndex =1;
Statement st = null;
try {
SQL.append("SELECT t.teacher_name teacher, avg(tf.FACT_SCORE) faceScore" +
" FROM teacher t left join tevaluate_follow tf" +
" on tf.TEACHER_NAME = t.teacher_name group by t.teacher_name ");
if(dto.getCurrentPage()!=null&&!"".equals(dto.getCurrentPage())&&
dto.getPageSize()!=null&&!"".equals(dto.getPageSize())){
int curr=(Integer.parseInt(dto.getCurrentPage())-1)*Integer.parseInt(dto.getPageSize());
SQL.append(" limit "+curr+","+Integer.parseInt(dto.getPageSize()));
}
pstmt = conn.prepareStatement(SQL.toString());
rs = pstmt.executeQuery();
while(rs.next()){
cvo = new TevaluateVO();
cvo.setTeacher(rs.getString("teacher"));
cvo.setFacSore(rs.getInt("faceScore"));
alist.add(cvo);
}
} catch (RuntimeException e) {
e.printStackTrace();
}finally{
if(rs!=null) rs.close();
if(pstmt!=null) pstmt.close();
SQL = null;
dto = null;
}
return alist;
}
public Object findAll() throws SQLException {
// TODO Auto-generated method stub
return null;
}
/**
* @author wanjiansheng
* 查询课堂教学记录表的数据
*/
public Object findAll(Object arg0) throws SQLException {
/**
* SQL语句预处理
*/
PreparedStatement ps=null;
/**
* 结果集的存放;
*/
ResultSet rs=null;
TevaluateVO temv=null;
TevaluateDTO temd=(TevaluateDTO)arg0;
List list=new ArrayList();
StringBuffer sb=new StringBuffer("SELECT tm.MAIN_ID,tm.TABLE_NAME,tm.TABLE_NO,tm.OBSERVATION," +
" tm.SCORE,tm.LEVEL,tm.ANYSCORE,tf.ID,tf.OBJECT_NAME,tf.TEACHER_NAME,tf.ADD_SCORE," +
" tf.ADD_REASON,tf.FACT_SCORE,tf.EVALUATE_TIME FROM tevaluate_main tm ,tevaluate_follow tf WHERE tm.MAIN_ID=tf.MAIN_ID ");
// if(temd.getMainId()!=null&&!"".equals(temd.getMainId())){
// sb.append("And tm.MAIN_ID="+temd.getMainId());
// }
if(temd.getTeacher()!=null&&!"".equals(temd.getTeacher())){
sb.append("And tf.TEACHER_NAME like '%"+temd.getTeacher()+"%'");
}
System.out.println(sb.toString());
if(temd.getSubject()!=null&&!"".equals(temd.getSubject())){
sb.append("And tf.OBJECT_NAME='"+temd.getSubject()+"'");
}
if(temd.getFacSore()!=0&&!"".equals(temd.getFacSore())){
sb.append("And tf.FACT_SCORE="+temd.getFacSore());
}
if(temd.getStartDate()!=null&&!"".equals(temd.getStartDate())&&
temd.getEndDate()!=null&&!"".equals(temd.getEndDate())){
sb =sb.append(" AND tf.EVALUATE_TIME BETWEEN '"+temd.getStartDate()+"' and '"+temd.getEndDate()+"'");
}
System.out.println(sb.toString());
ps = conn.prepareStatement(String.valueOf(sb));
rs = ps.executeQuery();
while(rs.next()){
temv=new TevaluateVO();
temv.setAddReason(rs.getString("ADD_REASON"));
temv.setAddScore(rs.getString("ADD_SCORE"));
temv.setAnyScore(rs.getString("ANYSCORE"));
temv.setEvaluateTime(rs.getString("EVALUATE_TIME"));
temv.setFacSore(rs.getInt("FACT_SCORE"));
temv.setId(rs.getInt("ID"));
temv.setLeval(rs.getString("LEVEL"));
temv.setMainId(rs.getInt("MAIN_ID"));
temv.setObservation(rs.getString("OBSERVATION"));
temv.setScore(rs.getString("SCORE"));
temv.setSubject(rs.getString("OBJECT_NAME"));
temv.setTableName(rs.getString("TABLE_NAME"));
temv.setTableNo(rs.getString("TABLE_NO"));
temv.setTeacher(rs.getString("TEACHER_NAME"));
/*System.out.println(">>>>>>>>>>>>>>>>>");*/
list.add(temv);
/*System.out.println(list.size());*/
}
return list;
}
public Object findById(Object arg0) throws SQLException {
// TODO Auto-generated method stub
return null;
}
public Object findByObject(Object arg0) throws SQLException {
// TODO Auto-generated method stub
return null;
}
public int getCount(Object arg0) throws SQLException {
// TODO Auto-generated method stub
return 0;
}
/**
* @author wanjiansheng
*获得主表的最大main_id
*/
public Object getMaxId(Object arg0) throws SQLException {
ResultSet rs=null;
PreparedStatement ps = null;
Integer MAIN_ID=null;
int n =0;
TevaluateDTO ted=(TevaluateDTO)arg0;
String strSQL="SELECT MAX(main_id) FROM tevaluate_main";
ps=conn.prepareStatement(strSQL);
rs = ps.executeQuery();
while(rs.next()){
n = rs.getInt(1);
}
if(ps!=null){
ps.close();
}
return n;
}
/**
* @author wanjiansheng
* 导入Excel表到数据库
*/
public Object insert(Object arg0) throws SQLException {
/**
* SQL语句预处理
*/
PreparedStatement ps=null;
/**
* SQL语句预处理
*/
PreparedStatement ps1=null;
boolean flag=false;
Integer MAIN_ID=0;
int nIndex=1;
int i =0;
TevaluateDTO ted=(TevaluateDTO)arg0;
try {
String strSQL1="insert into tevaluate_main(TABLE_NAME,TABLE_NO,OBSERVATION,SCORE,LEVEL,ANYSCORE) values(?,?,?,?,?,?)";
ps=conn.prepareStatement(strSQL1);
ps.setString(nIndex++,ted.getTableName());
ps.setString(nIndex++,ted.getTableNo());
ps.setString(nIndex++,ted.getObservation());
ps.setString(nIndex++,ted.getScore());
ps.setString(nIndex++,ted.getLeval());
ps.setString(nIndex++,ted.getAnyScore());
i=ps.executeUpdate();
//System.out.println(strSQL1);
if(i!=0){
flag=true;
}
int n=1;
MAIN_ID=(Integer) getMaxId(ted);
//System.out.println(MAIN_ID);
StringBuffer strSQL2=new StringBuffer("insert into tevaluate_follow(OBJECT_NAME,TEACHER_NAME,ADD_SCORE,ADD_REASON,FACT_SCORE,EVALUATE_TIME,MAIN_ID) values(?,?,?,?,?,?,?)");
ps1=conn.prepareStatement(strSQL2.toString());
ps1.setString(n++, ted.getSubject());
System.out.println(ted.getSubject());
ps1.setString(n++, ted.getTeacher());
ps1.setString(n++, ted.getAddScore());
ps1.setString(n++, ted.getAddReason());
ps1.setInt(n++, ted.getFacSore());
//ps1.setInt(n++, 0);
ps1.setString(n++, ted.getEvaluateTime());
ps1.setInt(n++,MAIN_ID);
int j=ps1.executeUpdate();
System.out.println(strSQL2.toString());
if(j!=0)
flag=true;
if(ps!=null){
ps.close();
}
if(ps1!=null){
ps1.close();
}
} catch (RuntimeException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
ted=null;
}
return flag;
}
public Object update(Object arg0) throws SQLException {
// TODO Auto-generated method stub
return null;
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -