《网上书店完整代码.doc》由会员分享，可在线阅读，更多相关《网上书店完整代码.doc（69页珍藏版）》请在三一文库上搜索。
1、 网上书店信息管理系统的设计与实现 第69页 共34页附录 全部源代码package com.shoeShop.db;import java.sql.Connection;import java.sql.DriverManager;import java.sql.SQLException;public class Connect private static Connection con = null;private static String url=jdbc:oracle:thin:localhost:1521:ORCL;private static String driver = ora
2、cle.jdbc.driver.OracleDriver;private static String user = scott;private static String pwd = tiger;public static Connection getConnection()try Class.forName(driver);con = DriverManager.getConnection(url, user, pwd);System.out.println(数据库连接成功！); catch (ClassNotFoundException e) System.out.println(驱动加载
3、失败！); catch (SQLException e) System.out.println(数据库连接失败！);return con;public static void main(String args) Connect.getConnection();package com.shoeShop.action;import java.awt.event.ActionEvent;import java.awt.event.ActionListener;import javax.swing.JPanel;import com.shoeShop.view.RegisterFrame;public
4、 class docMenuAction implements ActionListener RegisterFrame register = null;JPanel cusPanel = null;JPanel docPanel = null;public docMenuAction(RegisterFrame register)this.register = register;this.cusPanel = register.cusPanel;this.docPanel = register.docPanel;public void actionPerformed(ActionEvent
5、e) / TODO Auto-generated method stubregister.flag = 1;/System.out.println(register.flag);register.remove(cusPanel);register.add(docPanel);docPanel.updateUI();package com.shoeShop.dao;import java.sql.Connection;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import co
6、m.shoeShop.db.Connect;import com.shoeShop.entity.Buyer;import com.shoeShop.entity.Seller;public class BuyerDao private static Connection conn;private static Statement statement;private static ResultSet resultSet;/插入数据，用于注册public int insertBuyer(Buyer buyer)int flag = 0;conn = Connect.getConnection()
7、;try statement = conn.createStatement();String sql = insert into buyer values(+buyer.getId()+,+buyer.getName()+,+buyer.getPwd()+,+buyer.getAddress()+);/System.out.println(buyer+sql);flag = statement.executeUpdate(sql);statement.close();conn.close(); catch (SQLException e) / TODO Auto-generated catch
8、 blocke.printStackTrace();/System.out.println(flag);return flag;/通过用户名和密码查询，用于登录public static Buyer getBuyer(String name,String pwd)conn = Connect.getConnection();Buyer buyer = new Buyer();try statement = conn.createStatement();String sql = select * from buyer where buyer_id=+name+ and pwd = +pwd+;r
9、esultSet = statement.executeQuery(sql);while(resultSet.next()buyer.setId(resultSet.getString(buyer_id);buyer.setName(resultSet.getString(buyer_name);buyer.setPwd(resultSet.getString(pwd);buyer.setAddress(resultSet.getString(address);resultSet.close();statement.close();conn.close(); catch (SQLExcepti
10、on e) / TODO Auto-generated catch blocke.printStackTrace();return buyer;public static void main(String args) BuyerDao dao = new BuyerDao();System.out.println(dao.getBuyer(zxk, 654321);/Buyer buyer = new Buyer();/buyer.setId(lily);/buyer.setName(长理专卖);/buyer.setPwd(123456);/buyer.setAddress(湖南长沙);/da
11、o.insertBuyer(buyer);package com.shoeShop.dao;import java.sql.Connection;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import java.util.ArrayList;import com.shoeShop.db.Connect;import com.shoeShop.entity.Goods;import com.shoeShop.entity.Seller;import com.shoeShop.i
12、mp.User;public class GoodsDao private static Connection conn;private static Statement statement;private static ResultSet resultSet;/查询登录商家的所有商品，用于商家管理自己的商品public ArrayList getAllGoods()ArrayList list = new ArrayList();conn = Connect.getConnection();try statement = conn.createStatement();String sql =
13、 select * from goods a,seller b where a.seller_id=b.seller_id and b.seller_id=+User.getUserName()+;resultSet = statement.executeQuery(sql);while(resultSet.next()Seller seller = new Seller();seller.setName(resultSet.getString(seller_name);seller.setAddress(resultSet.getString(address);Goods goods = n
14、ew Goods();goods.setSeller(seller);goods.setId(resultSet.getInt(goods_id);goods.setName(resultSet.getString(goods_name);goods.setSeller_id(resultSet.getString(seller_id);goods.setDiscount(resultSet.getInt(discount);goods.setNum(resultSet.getInt(num);goods.setPrice(resultSet.getInt(price);/System.out
15、.println(goods.toString();list.add(goods); catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace();finallytry resultSet.close();statement.close();conn.close(); catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace();return list;/查询所有商家的所有商品.用于用户搜索商品public Arra
16、yList getAllSellerGoods()ArrayList list = new ArrayList();conn = Connect.getConnection();try statement = conn.createStatement();String sql = select * from goods a,seller b where a.seller_id=b.seller_id;resultSet = statement.executeQuery(sql);while(resultSet.next()Seller seller = new Seller();seller.
17、setName(resultSet.getString(seller_name);seller.setAddress(resultSet.getString(address);Goods goods = new Goods();goods.setSeller(seller);goods.setId(resultSet.getInt(goods_id);goods.setName(resultSet.getString(goods_name);goods.setSeller_id(resultSet.getString(seller_id);goods.setDiscount(resultSet
18、.getInt(discount);goods.setNum(resultSet.getInt(num);goods.setPrice(resultSet.getInt(price);/System.out.println(goods.toString();list.add(goods); catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace();finallytry resultSet.close();statement.close();conn.close(); catch (SQLExcepti
19、on e) / TODO Auto-generated catch blocke.printStackTrace();return list;/根据商品号查询商品信息public Goods getOneGoods(int id)Goods goods = new Goods();conn = Connect.getConnection();try statement = conn.createStatement();String sql = select * from goods where goods_id = +id;resultSet = statement.executeQuery(
20、sql);while(resultSet.next()goods.setId(id);goods.setName(resultSet.getString(goods_name);goods.setPrice(resultSet.getInt(price);goods.setNum(resultSet.getInt(num);goods.setDiscount(resultSet.getInt(discount);goods.setSeller_id(resultSet.getString(seller_id);goods.setNum(resultSet.getInt(num); catch
21、(SQLException e) / TODO Auto-generated catch blocke.printStackTrace();finallytry resultSet.close();statement.close();conn.close(); catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace();return goods;/修改商品信息public int updateGoods(Goods goods)int flag = 0;conn = Connect.getConnect
22、ion();try statement = conn.createStatement();String sql = update goods set goods_name=+goods.getName()+,price =+goods.getPrice()+,discount =+goods.getDiscount()+,num=+goods.getNum()+ where goods_id=+goods.getId();flag = statement.executeUpdate(sql); catch (SQLException e) / TODO Auto-generated catch
23、 blocke.printStackTrace();finallytry statement.close();conn.close(); catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace();return flag;/通过id删除商品public int deleteById(int id)int flag = 0;conn = Connect.getConnection();try statement = conn.createStatement();String sql = delete go
24、ods where goods_id = +id;flag = statement.executeUpdate(sql); catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace();finallytry statement.close();conn.close(); catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace();return flag;/添加public int insertGoods(Goods
25、 goods)int flag = 0;conn = Connect.getConnection();try statement = conn.createStatement();String sql = insert into goods values(select max(goods_id+1) from goods),+User.getUserName()+,+goods.getName()+,+goods.getPrice()+,+goods.getDiscount()+,+goods.getNum()+);flag = statement.executeUpdate(sql); ca
26、tch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace();finallytry statement.close();conn.close(); catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace();return flag;public static void main(String args) GoodsDao dao = new GoodsDao();/Goods goods = new Goods();/
27、goods.setName(c+);/goods.setPrice(50);/User.setUserName(niclascage);/goods.setDiscount(8);/goods.setNum(10);/System.out.println(main);/System.out.println(ii+dao.insertGoods(goods);/System.out.println(dao.deleteById(4);/Goods goods = new Goods();/goods.setId(1);/goods.setName(oracle);/goods.setPrice(
28、50);/goods.setDiscount(8);/goods.setNum(5);/System.out.println(dao.updateGoods(goods);dao.getAllSellerGoods();/System.out.println(dao.getOneGoods(1);package com.shoeShop.dao;import java.sql.Connection;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import java.util.A
29、rrayList;import com.shoeShop.db.Connect;import com.shoeShop.entity.Goods;import com.shoeShop.entity.Order;import com.shoeShop.entity.Seller;import com.shoeShop.imp.User;public class OrderDao private static Connection conn;private static Statement statement;private static ResultSet resultSet;/插入publi
30、c int inserOerderByGoods(Goods goods, int num)int flag = 0;conn = Connect.getConnection();try statement = conn.createStatement();String sql = insert into orders values(select max(order_id+1) from orders),+goods.getId()+,+goods.getSeller_id()+,+User.getUserName()+,+num+);flag = statement.executeUpdat
31、e(sql); catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace();finallytry statement.close();conn.close(); catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace();return flag;/查询登录用户的所有订单public ArrayList getOrder()ArrayList list = new ArrayList();conn = Connec
32、t.getConnection();try statement = conn.createStatement();String sql = select * from orders a,seller b,goods c where a.seller_id=b.seller_id and a.goods_id=c.goods_id and a.buyer_id = +User.getUserName()+;resultSet = statement.executeQuery(sql);while(resultSet.next()Order order = new Order();Goods go
33、ods = new Goods();Seller seller = new Seller();order.setId(resultSet.getInt(order_id);order.setNum(resultSet.getInt(num);order.setGoods_id(resultSet.getInt(goods_id);goods.setId(resultSet.getInt(goods_id);goods.setPrice(resultSet.getShort(price);goods.setPrice(resultSet.getInt(price);goods.setDiscou
34、nt(resultSet.getInt(discount);goods.setName(resultSet.getString(goods_name);seller.setName(resultSet.getString(seller_name);seller.setAddress(resultSet.getString(address);order.setSeller(seller);order.setGoods(goods);/System.out.println(order.toString();list.add(order); catch (SQLException e) / TODO
35、 Auto-generated catch blocke.printStackTrace();finallytry resultSet.close();statement.close();conn.close(); catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace();return list;/查询登录商家的所有订单public ArrayList getSellerOrder()ArrayList list = new ArrayList();conn = Connect.getConnecti
36、on();try statement = conn.createStatement();String sql = select * from orders a,seller b,goods c where a.seller_id=b.seller_id +and a.goods_id=c.goods_id and a.seller_id= +User.getUserName()+;resultSet = statement.executeQuery(sql);while(resultSet.next()Order order = new Order();Goods goods = new Go
37、ods();Seller seller = new Seller();order.setId(resultSet.getInt(order_id);order.setNum(resultSet.getInt(num);order.setGoods_id(resultSet.getInt(goods_id);order.setBuyer_id(resultSet.getString(buyer_id);goods.setId(resultSet.getInt(goods_id);goods.setPrice(resultSet.getShort(price);goods.setPrice(res
38、ultSet.getInt(price);goods.setDiscount(resultSet.getInt(discount);goods.setName(resultSet.getString(goods_name);seller.setName(resultSet.getString(seller_name);seller.setAddress(resultSet.getString(address);order.setSeller(seller);order.setGoods(goods);list.add(order); catch (SQLException e) / TODO
39、Auto-generated catch blocke.printStackTrace();finallytry resultSet.close();statement.close();conn.close(); catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace();return list;public static void main(String args) OrderDao dao = new OrderDao();dao.getOrder();package com.shoeShop.da
40、o;import java.sql.Connection;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import com.shoeShop.db.Connect;import com.shoeShop.entity.Seller;public class SellerDao private static Connection conn;private static Statement statement;private static ResultSet resultSet;/插入数据，用于注册public int insertSeller(Seller seller)int flag = 0;conn = Connect.getConnection();try statement = conn.createStatement();String sql = insert into seller values(+seller.getId()+,+seller.getName()+,+seller.getPwd()+,+seller.getAddress()+);flag = statement.executeUpdate