📄 tsmgr.java
字号:
package dbmgr;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Collection;
import userbean.Pxjh;
import dbmgr.DBConMgr;
public class TsMgr {
DBConMgr db_conn=new DBConMgr();
public Collection search(String psort)
{
db_conn.ConnectDB();
Collection showlist=new ArrayList();
ResultSet rs = null;
try{
String sql="select * from mokuai2 where psort='"+psort+"'";
rs = db_conn.stmt.executeQuery(sql);
Pxjh pxjh = null;
while(rs.next())
{
pxjh=new Pxjh();
pxjh.setLeibieid(rs.getInt("leibieid"));
pxjh.setPsort(rs.getString("psort"));
pxjh.setTdate(rs.getString("tdate"));
pxjh.setTadress(rs.getString("tadress"));
pxjh.setTcharge(rs.getString("tcharge"));
pxjh.setTorgan(rs.getString("torgan"));
pxjh.setTraincm(rs.getString("traincm"));
pxjh.setFulu(rs.getString("fulu"));
showlist.add(pxjh);
}
return showlist;
}
catch (SQLException SqlE) {
SqlE.printStackTrace();
return null;
}
catch (Exception E) {
E.printStackTrace();
return null;
}
finally {
// 关闭连接,释放数据库资源:
db_conn.CloseDB();
}
}
public Collection getAll(){
//System.out.println("11111111");
db_conn.ConnectDB();
Collection showlist=new ArrayList();
ResultSet rs = null;
try{
String sql="select * from mokuai2 order by leibieid asc";
rs = db_conn.stmt.executeQuery(sql);
Pxjh pxjh = null;
while(rs.next())
{
pxjh=new Pxjh();
pxjh.setLeibieid(rs.getInt("leibieid"));
pxjh.setPsort(rs.getString("psort"));
pxjh.setTdate(rs.getString("tdate"));
pxjh.setTcharge(rs.getString("tcharge"));
pxjh.setTadress(rs.getString("tadress"));
pxjh.setTraincm(rs.getString("traincm"));
pxjh.setTorgan(rs.getString("torgan"));
pxjh.setFulu(rs.getString("fulu"));
showlist.add(pxjh);
}
return showlist;
}
catch (SQLException SqlE) {
SqlE.printStackTrace();
return null;
}
catch (Exception E) {
E.printStackTrace();
return null;
}
finally {
// 关闭连接,释放数据库资源:
db_conn.CloseDB();
}
}
public int insert(Pxjh pxjh)
{
db_conn.ConnectDB();
try {
String sql = "insert into mokuai2(leibieid,psort,tdate," +
"tcharge,tadress,torgan,traincm,fulu)" +
" values("+pxjh.getLeibieid()
+",'" + pxjh.getPsort()
+ "','" + pxjh.getTdate()
+"','" + pxjh.getTcharge()
+"','" +pxjh.getTadress()
+"','"+pxjh.getTorgan()
+"','"+pxjh.getTraincm()
+"','"+pxjh.getFulu()+"')";
//System.out.println(sql);
int i = db_conn.stmt.executeUpdate(sql); // 执行sql语句
return i;
}
catch (SQLException SqlE){
SqlE.printStackTrace();
return -1;
}
catch (Exception E) {
E.printStackTrace();
return -2;
}
finally {
// 关闭连接,释放数据库资源:
db_conn.CloseDB();
}
}
public int chang(Pxjh pxjh)
{
db_conn.ConnectDB();
try {
String sql = "update mokuai2 set leibieid='"+
pxjh.getLeibieid()+"',psort='"+
pxjh.getPsort()+"',tdate='"+
pxjh.getTdate()+"',tcharge='"+
pxjh.getTcharge()+"',tadress='"+
pxjh.getTadress()+"',traincm='"+
pxjh.getTraincm()+"',torgan='"+
pxjh.getTorgan()+"',fulu='"+
pxjh.getFulu()+"' where leibieid="+
pxjh.getLeibieid();
int i = db_conn.stmt.executeUpdate(sql); // 执行sql语句
return i;
}
catch (SQLException SqlE){
SqlE.printStackTrace();
return -1;
}
catch (Exception E) {
E.printStackTrace();
return -2;
}
finally {
// 关闭连接,释放数据库资源:
db_conn.CloseDB();
}
}
public int delete(int leibieid)
{
db_conn.ConnectDB();
try {
String sql="delete from mokuai2 where leibieid="+leibieid+"";
int i = db_conn.stmt.executeUpdate(sql);
return i;
}
catch (SQLException SqlE){
SqlE.printStackTrace();
return -1;
}
catch (Exception E) {
E.printStackTrace();
return -2;
}
finally {
// 关闭连接,释放数据库资源:
db_conn.CloseDB();
}
}
public Collection getPage(int start,int size)
{
//System.out.println(start+","+size);
db_conn.ConnectDB();
Collection showlist=new ArrayList();
ResultSet rs = null;
try{
String sql="select * from mokuai2 order by leibieid asc";
rs = db_conn.stmt.executeQuery(sql);
Pxjh pxjh = null;
int i=1;
while(rs.next())
{
if((i>=start)&&(i<start+size))
{pxjh=new Pxjh();
pxjh.setLeibieid(rs.getInt("leibieid"));
pxjh.setPsort(rs.getString("psort"));
pxjh.setTdate(rs.getString("tdate"));
pxjh.setTcharge(rs.getString("tcharge"));
pxjh.setTadress(rs.getString("tadress"));
pxjh.setTorgan(rs.getString("torgan"));
pxjh.setTraincm(rs.getString("traincm"));
pxjh.setFulu(rs.getString("fulu"));
showlist.add(pxjh);
}
i=i+1;
}
return showlist;
}
catch (SQLException SqlE) {
SqlE.printStackTrace();
return null;
}
catch (Exception E) {
E.printStackTrace();
return null;
}
finally {
// 关闭连接,释放数据库资源:
db_conn.CloseDB();
}
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -