package DAO;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import bean.TrainManage;
import util.JDBCConnect;
public class TrainManageDAO {
//插入车次
public static int insert(TrainManage train) throws Exception {
String sql = "INSERT INTO TrainManage (trainid,start,end,time,yzprice,rzprice,ywprice,rwprice,root) " +
"VALUES ('" + train.getTrainid() +"','"+ train.getStart() +"','"+ train.getEnd() +
"','"+ train.getTime() +"','"+ train.getYzprice() +"','"+ train.getRzprice() +
"','"+ train.getYwprice() +"','"+ train.getRwprice() +"','"+ train.getRoot() +"');";
System.out.println(sql);
return JDBCConnect.executeUpdate(sql);
/**
* 总是报错 No value specified for parameter 5
* 很多原因是 insert into train (?,?,?) values (?,?,?) 前面不应该是问号
* 但我的怀疑是参数过多使用executeUpdate(sql,?,?,?...)方法是错误
*
* String sql = "INSERT INTO TrainManage (trainid,start,end,time,yzprice,rzprice,ywprice,rwprice,root) VALUES (?,?,?,?,?,?,?,?,?);";
* System.out.println(sql);
* return JDBCConnect.executeUpdate(sql, train.getTrainid(), train.getStart(), train.getEnd(),
* train.getTime(), train.getYzprice(), train.getRzprice(), train.getYwprice(),
* train.getRwprice(), train.getRoot());
*/
}
//更新车次
public static int update(TrainManage train) throws Exception {
/**
* String sql = "UPDATE TrainManage SET start = ?, end = ? WHERE trainid = ? ";
* return JDBCConnect.executeUpdate(sql, train.getStart(), train.getEnd(), train.getTrainid());
*/
/*
String sql = "UPDATE TrainManage SET start = '"+ train.getStart() +
"', end = '" + train.getEnd() + "' WHERE trainid = '" +
train.getTrainid() +"';";
System.out.println(sql);
return JDBCConnect.executeUpdate(sql);
*/
String sql = "UPDATE TrainManage SET start = ?, end = ? WHERE trainid = ? ";
return JDBCConnect.executeUpdate(sql, train.getStart(), train.getEnd(), train.getTrainid());
}
//删除操作
public static int delete(String id) throws Exception {
String sql = "DELETE FROM TrainManage WHERE trainid = ? ";
return JDBCConnect.executeUpdate(sql, id);
}
//查找记录 某车次
public static TrainManage find(String id) throws Exception {
String sql = "SELECT * FROM TrainManage WHERE trainid = ? ";
Connection conn = null;
PreparedStatement preStmt = null;
ResultSet rs = null;
try {
//链接数据库执行SQL语句
conn = JDBCConnect.getConnection(); //连接默认数据库
preStmt = conn.prepareStatement(sql);
preStmt.setString(1, id);
rs = preStmt.executeQuery();
//获取查询结果
if (rs.next()) {
TrainManage train = new TrainManage();
train.setTrainid(rs.getString("trainid"));
train.setStart(rs.getString("start"));
train.setEnd(rs.getString("end"));
train.setTime(rs.getString("time"));
train.setYzprice(rs.getFloat("yzprice"));
train.setYwprice(rs.getFloat("ywprice"));
train.setRzprice(rs.getFloat("rzprice"));
train.setRwprice(rs.getFloat("rwprice"));
train.setRoot(rs.getString("root"));
return train;
} else {
return null;
}
} finally { //依次关闭 记录集 声明 连接对象
if (rs != null)
rs.close();
if (preStmt != null)
preStmt.close();
if (conn != null)
conn.close();
}
}
//查找记录 某车次
public static List<TrainManage> findStartEnd(String start,String end) throws Exception {
List<TrainManage> list = new ArrayList<TrainManage>();
String sql = null;
Connection conn = null;
Statement statement = null;
ResultSet rs = null;
//判断SQL语句
if(start==""&&end=="") {
sql = "SELECT * FROM TrainManage;";
} else if(end=="") {
sql = "SELECT * FROM TrainManage WHERE start = '"+ start + "';";
} else if(start=="") {
sql = "SELECT * FROM TrainManage WHERE end = '"+ end + "';";
} else {
sql = "SELECT * FROM TrainManage WHERE start = '"
+ start + "' and end = '"+ end +"';";
}
//执行
try {
//链接数据库执行SQL语句
conn = JDBCConnect.getConnection(); //连接默认数据库
statement = conn.createStatement();
System.out.println(start+" "+end);
System.out.println(sql);
rs = statement.executeQuery(sql);
//获取查询结果
while(rs.next()) {
TrainManage train = new TrainManage();
train.setTrainid(rs.getString("trainid"));
train.setStart(rs.getString("start"));
train.setEnd(rs.getString("end"));
train.setTime(rs.getString("time"));
train.setYzprice(rs.getFloat("yzprice"));
train.setYwprice(rs.getFloat("ywprice"));
train.setRzprice(rs.getFloat("rzprice"));
train.setRwprice(rs.getFloat("rwprice"));
train.setRoot(rs.getString("root"));
list.add(train);
}
} catch (Exception e) {
System.out.println("错误:"+e.getMessage());
}
finally { //依次关闭 记录集 声明 连接对象
if (rs != null)
rs.close();
if (statement != null)
statement.close();
if (conn != null)
conn.close();
}
return list;
}
//查询所有车次信息
public static List<TrainManage> listStudents() throws Exception {
List<TrainManage> list = new ArrayList<TrainManage>();
String sql = "SELECT * FROM TrainManage";
Connection conn = null;
PreparedStatement preStmt = null;
ResultSet rs = null;
try {
conn = JDBCConnect.getConnection();
preStmt = conn.prepareStatement(sql);
rs = preStmt.executeQuery();
while (rs.next()) {
//设置数据库中表参数 否则报错java.sql.SQLException: Column 'id' not found.
TrainManage train = new TrainManage();
train.setTrainid(rs.getString("trainid"));
train.setStart(rs.getString("start"));
train.setEnd(rs.getString("end"));
train.setTime(rs.getString("time"));
train.setYzprice(rs.getFloat("yzprice"));
train.setYwprice(rs.getFloat("ywprice"));
train.setRzprice(rs.getFloat("rzprice"));
train.setRwprice(rs.getFloat("rwprice"));
train.setRoot(rs.getString("root"));
list.add(train);
}
} finally {
if (rs != null)
rs.close();
if (preStmt != null)
preStmt.close();
if (conn != null)
conn.close();
}
return list;
}
}
没有合适的资源?快使用搜索试试~ 我知道了~
温馨提示
该资源主要参考自己的博客http://blog.csdn.net/eastmount/article/details/45936121 讲诉Java+MyEclipse+Tomcat 详解Servlet和DAO数据库增删改查操作,主要包括数据库的操作MySQL。免费基础资源,希望对你有所帮助,建议结合博客进行学习。By:Eastmount
资源推荐
资源详情
资源评论
收起资源包目录
TrainDatabase.rar (43个子文件)
TrainDatabase
.settings
org.eclipse.wst.jsdt.ui.superType.name 6B
org.eclipse.wst.common.project.facet.core.xml 252B
org.eclipse.wst.common.component 477B
org.eclipse.wst.jsdt.ui.superType.container 49B
.jsdtscope 500B
org.eclipse.jdt.core.prefs 364B
src
bean
TrainManage.java 1KB
servlet
UpdateTrainAction.java 3KB
InsertTrainAction.java 3KB
util
JDBCConnect.java 2KB
DAO
TrainManageDAO.java 6KB
.project 2KB
WebRoot
trainManage.jsp 6KB
trainManageDelete.jsp 6KB
image
ccxxgl.jpg 19KB
hygl-xz.jpg 17KB
dpgl-xz.jpg 18KB
hygl.jpg 18KB
ccxxgl-xz.jpg 18KB
lygl-xz.jpg 18KB
spqktj.jpg 19KB
logo.swf 101KB
logo.jpg 63KB
dpgl.jpg 18KB
logo.gif 311KB
exit.jpg 18KB
spqktj-xz.jpg 18KB
lygl.jpg 18KB
META-INF
MANIFEST.MF 36B
WEB-INF
web.xml 1KB
classes
bean
TrainManage.class 2KB
servlet
UpdateTrainAction.class 4KB
InsertTrainAction.class 4KB
util
JDBCConnect.class 3KB
DAO
TrainManageDAO.class 6KB
lib
mysql-connector-java-5.1.15-bin.jar 768KB
trainManageUpdate.jsp 6KB
index.jsp 834B
trainManageInsert.jsp 6KB
trainManageSelect.jsp 6KB
trainManageDetail.jsp 6KB
.mymetadata 312B
.classpath 529B
.myeclipse
共 43 条
- 1
Eastmount
- 粉丝: 25w+
- 资源: 80
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功
- 1
- 2
- 3
- 4
前往页