📄 pxlbmgr.java
字号:
package dbmgr;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.*;
import userbean.Userbean;
public class PxlbMgr {
DBConMgr db_conn=new DBConMgr();
public Collection query(String pxming)
{
db_conn.ConnectDB();
Collection showlist=new ArrayList();
ResultSet rs = null;
try{
String sql="select * from tb1 where 1=1"+pxming+"";
rs = db_conn.stmt.executeQuery(sql);
Userbean user=null;
while(rs.next()){
user=new Userbean();
user.setLeibieid(rs.getInt("leibieid"));
user.setPxming(rs.getString("pxming"));
user.setLianxirentel(rs.getString("lianxirentel"));
user.setPxtime(rs.getString("pxtime"));
user.setExtra(rs.getString("extra"));
showlist.add(user);
}
return showlist;
}
catch (SQLException SqlE) {
SqlE.printStackTrace();
return null;
}
catch (Exception E) {
E.printStackTrace();
return null;
}
finally {
// 关闭连接,释放数据库资源:
db_conn.CloseDB();
}
}
public Collection getAll()
{
db_conn.ConnectDB();
Collection showlist=new ArrayList();
ResultSet rs = null;
try{
String sql="select * from tb1 order by leibieid asc";
rs = db_conn.stmt.executeQuery(sql);
Userbean user=null;
while(rs.next()){
user=new Userbean();
user.setLeibieid(rs.getInt("leibieid"));
user.setPxming(rs.getString("pxming"));
user.setLianxirentel(rs.getString("lianxirentel"));
user.setPxtime(rs.getString("pxtime"));
user.setExtra(rs.getString("extra"));
showlist.add(user);
}
return showlist;
}
catch (SQLException SqlE) {
SqlE.printStackTrace();
return null;
}
catch (Exception E) {
E.printStackTrace();
return null;
}
finally {
// 关闭连接,释放数据库资源:
db_conn.CloseDB();
}
}
public int insert(Userbean user){
db_conn.ConnectDB();
try{
String sql="insert into tb1(leibieid,pxming," +
"lianxirentel,pxtime,extra)" +
" values("+user.getLeibieid()+",'"+
user.getPxming()+"','"+
user.getLianxirentel()+"','" +
user.getPxtime() + "','" +
user.getExtra()+ "')";
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(Userbean user){
db_conn.ConnectDB();
try{
String sql = "update tb1 set "+
"pxming='"+
user.getPxming()+"',lianxirentel='"+
user.getLianxirentel()+"',pxtime='"+
user.getPxtime()+"',extra='"+
user.getExtra()+"' where leibieid="+
user.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 tb1 where leibieid="+leibieid+"";
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 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 tb1 order by leibieid asc";
rs = db_conn.stmt.executeQuery(sql);
Userbean user = null;
int i=1;
while(rs.next())
{
if((i>=start)&&(i<start+size))
{ user=new Userbean();
user.setLeibieid(rs.getInt("leibieid"));
user.setPxming(rs.getString("pxming"));
user.setLianxirentel(rs.getString("lianxirentel"));
user.setPxtime(rs.getString("pxtime"));
user.setExtra(rs.getString("extra"));
showlist.add(user);
}
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 + -