📄 databean.java
字号:
package com.wang.bean;
import java.sql.*;
import com.wang.bean.*;
import java.text.SimpleDateFormat;
import java.util.*;
public class DataBean
{
private Connection conn = null;
private ResultSet res = null;
private java.sql.PreparedStatement prepar = null;
private boolean flag = false;
public DataBean()
{
try
{
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
String dburl =
"jdbc:odbc:driver={Microsoft Access Driver (*.mdb)};DBQ=C:\\MyData.mdb"; //注意空格
conn = DriverManager.getConnection(dburl);
System.out.println("连接成功");
}
catch (SQLException ex)
{
System.out.println(ex.getMessage() + "1路径错误");
}
catch (ClassNotFoundException ex)
{
System.out.println(ex.getMessage() + "路径错误");
}
}
public UserBean checkUsersLogin(String userName, String userPwd)
{
UserBean useBean = new UserBean();
flag = false;
if (!checkParameter(userName + userPwd))
{
useBean = null;
return useBean;
}
try
{
String sql =
"select count(*) from Users where userName=? and userPwd=?";
prepar = conn.prepareStatement(sql);
prepar.setString(1, userName);
prepar.setString(2, userPwd);
res = prepar.executeQuery();
if (res.next())
{
if (res.getInt(1) > 0)
{
useBean = this.getUser(userName);
}
else
{
useBean = null;
}
}
else
{
useBean = null;
}
}
catch (Exception e)
{
useBean = null;
e.printStackTrace();
}
return useBean;
}
public AdminBean checkAdminLogin(String adminName, String adminPwd)
{
AdminBean admin = new AdminBean();
flag = false;
if (!checkParameter(adminName + adminPwd))
{
admin = null;
return admin;
}
try
{
String sql =
"select count(*) from admin where adminName=? and adminPwd=?";
prepar = conn.prepareStatement(sql);
prepar.setString(1, adminName);
prepar.setString(2, adminPwd);
res = prepar.executeQuery();
if (res.next())
{
if (res.getInt(1) > 0)
{
admin = getAdmin(adminName);
}
else
{
admin = null;
}
}
else
{
admin = null;
}
}
catch (Exception e)
{
admin = null;
e.printStackTrace();
}
return admin;
}
public boolean updateOrderformState(int orderformId)
{
flag = false;
String sql =
"update orderform set orderformState=2 where orderformId=?";
try
{
this.prepar = conn.prepareStatement(sql);
prepar.setInt(1, orderformId);
int result = prepar.executeUpdate();
if (result > 0)
{
flag = true;
}
else
{
flag = false;
}
}
catch (Exception ex)
{
flag = false;
ex.printStackTrace();
}
return flag;
}
public UserBean getUser(String userName)
{
UserBean useBean = new UserBean();
String sql =
"select * from Users where userName=?";
try
{
prepar = conn.prepareStatement(sql);
prepar.setString(1, userName);
res = prepar.executeQuery();
res.next();
useBean.setUserId(res.getInt("userId"));
useBean.setUserMail(res.getString("userMail"));
useBean.setUserName(res.getString("userName"));
useBean.setUserPhone(res.getString("userPhone"));
useBean.setUserPwd(res.getString("userPwd"));
useBean.setUserAddress(res.getString("userAddress"));
useBean.setUserMerchendiseCount(res.getInt("userMerchandiseCount"));
}
catch (SQLException ex)
{
ex.printStackTrace();
}
return useBean;
}
public AdminBean getAdmin(String adminName)
{
AdminBean admin = new AdminBean();
String sql =
"select * from admin where adminName=?";
try
{
prepar = conn.prepareStatement(sql);
prepar.setString(1, adminName);
res = prepar.executeQuery();
res.next();
admin.setAdminFlag(res.getInt("adminFlag"));
admin.setAdminName(res.getString("adminName"));
admin.setAdminId(res.getInt("adminId"));
admin.setAdminPwd(res.getString("adminPwd"));
}
catch (SQLException ex)
{
ex.printStackTrace();
}
return admin;
}
public ArrayList getUserMerchandiseBean(int userId)
{
ArrayList list = new ArrayList();
String sql =
"select * from merchandise where userId=?";
try
{
prepar = conn.prepareStatement(sql);
prepar.setInt(1, userId);
res = prepar.executeQuery();
while (res.next())
{
MerchandiseBean mb = new MerchandiseBean();
mb.setAdminId(res.getInt("adminId"));
mb.setFactoryId(res.getInt("factoryId"));
mb.setMerchandiseId(res.getInt("merchandiseId"));
mb.setMerchandiseName(res.getString("merchandiseName"));
mb.setMerchandisePrice(res.getInt("merchandisePrice"));
mb.setUserId(res.getInt("userId"));
mb.setMerchandiseTime(res.getString("merchandiseTime"));
mb.setMerchandiseCount(res.getInt("merchandiseCount"));
list.add(mb);
}
}
catch (SQLException ex)
{
ex.printStackTrace();
}
return list;
}
public boolean updateMerchandise(int merchandiseId, int merchandisePrice)
{
flag = false;
String sql =
"update merchandise set merchandisePrice=? where merchandiseId=?";
try
{
this.prepar = conn.prepareStatement(sql);
prepar.setInt(1, merchandisePrice);
prepar.setInt(2, merchandiseId);
int result = prepar.executeUpdate();
if (result > 0)
{
flag = true;
}
else
{
flag = false;
}
}
catch (Exception ex)
{
flag = false;
ex.printStackTrace();
}
return flag;
}
public boolean insertMerchandise(int factoryId, String merchandiseName,
int userId, int adminId,
int merchandiseCount)
{
flag = false;
String sql = "insert into merchandise (factoryId,merchandiseName,userId,adminId,merchandiseTime,merchandiseCount) values(?,?,?,?,?,?)";
try
{
this.prepar = conn.prepareStatement(sql);
prepar.setInt(1, factoryId);
prepar.setString(2, merchandiseName);
prepar.setInt(3, userId);
prepar.setInt(4, adminId);
prepar.setString(5, getDate());
prepar.setInt(6, merchandiseCount);
int result = prepar.executeUpdate();
if (result > 0)
{
flag = true;
}
else
{
flag = false;
}
}
catch (Exception ex)
{
flag = false;
ex.printStackTrace();
}
return flag;
}
private String getDate()
{
SimpleDateFormat lFormat;
Calendar MyDate = Calendar.getInstance();
MyDate.setTime(new java.util.Date());
java.util.Date date = MyDate.getTime();
//格式可以自己根据需要修改
lFormat = new SimpleDateFormat("yyyyMMddHHmmss");
String gRtnStr = lFormat.format(date);
return gRtnStr;
}
public int getAdminId(int adminfalgId)
{
String sql =
"select * from admin where adminFlag=?";
try
{
prepar = conn.prepareStatement(sql);
prepar.setInt(1, adminfalgId);
res = prepar.executeQuery();
res.next();
return res.getInt("adminId");
}
catch (SQLException ex)
{
ex.printStackTrace();
}
return 0;
}
public boolean updataUser(int userId, String userName, String userMail,
String userPhone, String userAddress,
String userPwd)
{
flag = false;
String sql = "update Users set userPwd=?,userName=?,userMail=?,userPhone=?,userAddress=? where userId=?";
try
{
this.prepar = conn.prepareStatement(sql);
prepar.setString(1, userPwd);
prepar.setString(2, userName);
prepar.setString(3, userMail);
prepar.setString(4, userPhone);
prepar.setString(5, userAddress);
prepar.setInt(6, userId);
int result = prepar.executeUpdate();
if (result > 0)
{
flag = true;
}
else
{
flag = false;
}
}
catch (Exception ex)
{
flag = false;
ex.printStackTrace();
}
return flag;
}
public boolean insertReason(int userId, int adminId, int reasonTypeId,
int merchandiseId)
{
flag = false;
String sql = "insert into reason (userId,adminId,reasonTypeId,reasonTime,merchandiseId) values(?,?,?,?,?)";
try
{
this.prepar = conn.prepareStatement(sql);
prepar.setInt(1, userId);
prepar.setInt(2, adminId);
prepar.setInt(3, reasonTypeId);
prepar.setString(4, getDate());
prepar.setInt(5, merchandiseId);
int result = prepar.executeUpdate();
if (result > 0)
{
flag = true;
}
else
{
flag = false;
}
}
catch (Exception ex)
{
flag = false;
ex.printStackTrace();
}
return flag;
}
public boolean insertOrderForm(int merchendiseId, int userId, int adminId,
int merchendisePrice, int merchendiseCount,
int delivergoodsId)
{
flag = false;
String sql = "insert into orderform (orderformTime,orderformState,merchendiseId,userId,adminId,merchendisePrice,merchendiseCount,delivergoodsId) values(?,?,?,?,?,?,?,?)";
try
{
this.prepar = conn.prepareStatement(sql);
prepar.setString(1, getDate());
prepar.setInt(2, 1);
prepar.setInt(3, merchendiseId);
prepar.setInt(4, userId);
prepar.setInt(5, adminId);
prepar.setInt(6, adminId);
prepar.setInt(7, merchendisePrice);
prepar.setInt(8, delivergoodsId);
int result = prepar.executeUpdate();
if (result > 0)
{
flag = true;
//deleteMerchendise(merchendiseId);
}
else
{
flag = false;
}
}
catch (Exception ex)
{
flag = false;
ex.printStackTrace();
}
return flag;
}
public void deleteMerchendise(int id)
{
String sql = "DELETE FROM merchandise WHERE merchandiseId = ?";
try
{
this.prepar = conn.prepareStatement(sql);
prepar.setInt(1, id);
int result = prepar.executeUpdate();
}
catch (Exception ex)
{
ex.printStackTrace();
}
}
public boolean checkParameter(String para) //过滤非法字符
{
int flag = 0;
flag += para.indexOf("'") + 1;
flag += para.indexOf(";") + 1;
flag += para.indexOf("1=1") + 1;
flag += para.indexOf("|") + 1;
flag += para.indexOf("<") + 1;
flag += para.indexOf(">") + 1;
if (flag != 0)
{
System.out.println("提交了非法字符!!!");
return false;
}
return true;
}
public boolean regUser(String userName, String userPwd, String userMail,
String userPhone, String userAddress)
{
flag = false;
String sql = "insert into Users (userName,userPwd,userMail,userPhone,userAddress) values(?,?,?,?,?)";
try
{
this.prepar = conn.prepareStatement(sql);
prepar.setString(1, userName);
prepar.setString(2, userPwd);
prepar.setString(3, userMail);
prepar.setString(4, userPhone);
prepar.setString(5, userAddress);
int result = prepar.executeUpdate();
if (result > 0)
{
flag = true;
}
else
{
flag = false;
}
}
catch (Exception ex)
{
flag = false;
ex.printStackTrace();
}
return flag;
}
public void Close()
{
try
{
if (res != null)
{
res.close();
}
if (prepar != null)
{
prepar.close();
}
if (conn != null)
{
conn.close();
}
}
catch (SQLException ex)
{
ex.printStackTrace();
}
System.out.println("关闭成功");
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -