dc.rar_网上购物

package com.dc.dao; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import com.dc.vo.Food; import com.dc.vo.Userinfo; /** * 用户表的增删改查 * @author 卢磊 * @version 1.0 2011-06-15 * * */ public class LinkDb { String DRIVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; // 数据库驱动 String URL = "jdbc:sqlserver://localhost:1433;DatabaseName=restrant"; // url String DBNAME = "sa"; // 数据库用户名 String DBPASS = "accp"; /** * 得到数据库连接对象 * @return conn 数据库连接对象 */ public Connection ldb() { Connection conn=null; try { Class.forName(DRIVER); //注册驱动 conn = DriverManager.getConnection(URL,DBNAME,DBPASS); } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } return conn; } /** * 登陆 * @param username 用户名称 * @param password 密麻 * @return f */ public Userinfo denglu(String username, String password) { Userinfo user=null; try { //得到数据库连接 Connection conn=ldb(); Statement st=conn.createStatement(); String sql="select * from userinfo where loginname='"+username+"' and loginpass='"+password+"'"; System.out.println(sql); ResultSet rt=st.executeQuery(sql); if(rt.next()){ user=new Userinfo(); user.userid=rt.getInt("userid"); user.userName=rt.getString("loginname"); user.realName=rt.getString("realname"); } rt.close(); st.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } return user; } /** * 添加用户 * @param name 用户名 * @param ps 密码 * @param realname 真实姓名 * @param phone 手机号码 */ public void addUser(String name,String ps,String realname,String phone){ try { Connection con=this.ldb(); Statement st=con.createStatement(); String sql="insert into userinfo values ('"+name+"','"+ps+"','"+realname+"','"+phone+"',10)"; st.executeUpdate(sql); st.close(); con.close(); } catch (SQLException e) { e.printStackTrace(); } } /** * 添加点评信息 * @param foodid * @param foodname * @param kouwei * @param nr * @param userid * @param realname */ public void addDianping(String foodid,String foodname,String kouwei,String nr,int userid,String realname){ try { Connection con=this.ldb(); Statement st=con.createStatement(); String sql="insert into dianping values ("+foodid+",'"+foodname+"','"+kouwei+"','"+nr+"',"+userid+",'"+realname+"',getdate())"; st.executeUpdate(sql); st.close(); con.close(); } catch (SQLException e) { e.printStackTrace(); } } /** * 修改密码 * @param name 用户名 * @param ps 密码 */ public void updateUser(String name,String uname){ try { Connection con=this.ldb(); Statement st=con.createStatement(); String sql="update userinfo set loginname='"+uname+"' where loginname='"+name+"'"; System.out.println(sql); st.executeUpdate(sql); st.close(); con.close(); } catch (SQLException e) { e.printStackTrace(); } } /** * 删除用户 * @param name 用户名称 */ public void deleteUser(String name){ try { Connection con=this.ldb(); Statement st=con.createStatement(); String sql="delete from userinfo where loginname='"+name+"'"; System.out.println(sql); st.executeUpdate(sql); st.close(); con.close(); } catch (SQLException e) { e.printStackTrace(); } } /** * 删除多个用户信息 * @param name */ public void deleteUserAll(String[] name){ try { Connection con=this.ldb(); Statement st=con.createStatement(); String x=""; for(int i=0;i<name.length;i++){ x=x+"'"+name[i]+"',"; } x=x+"'00'"; String sql="delete from userinfo where loginname in ("+x+")"; System.out.println(sql); st.executeUpdate(sql); st.close(); con.close(); } catch (SQLException e) { e.printStackTrace(); } } /** * 返回所有的用户名 * @return userlist */ public ArrayList findUserAll() { ArrayList userlist=new ArrayList(); try { //得到数据库连接 Connection conn=ldb(); Statement st=conn.createStatement(); String sql="select * from userinfo"; ResultSet rt=st.executeQuery(sql); while(rt.next()){ String name=rt.getString("loginname"); userlist.add(name); } rt.close(); st.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } return userlist; } /** * * @return */ public ArrayList findFoodAll() { ArrayList foodlist=new ArrayList(); try { //得到数据库连接 Connection conn=ldb(); Statement st=conn.createStatement(); String sql="select * from foodinfo"; ResultSet rt=st.executeQuery(sql); while(rt.next()){ String name=rt.getString("foodname"); int foodid=rt.getInt("foodid"); double price=rt.getDouble("foodprice"); Food food=new Food(); food.id=foodid; food.name=name; food.price=price; foodlist.add(food); } rt.close(); st.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } return foodlist; } /** * 根据餐品的id去 查询餐品的所有信息 * @param foodid * @return */ public Food findFoodById(String foodid) { Food food=null; try { //得到数据库连接 Connection conn=ldb(); Statement st=conn.createStatement(); String sql="select * from foodinfo where foodid="+foodid; ResultSet rt=st.executeQuery(sql); if(rt.next()){ String name=rt.getString("foodname"); int fid=rt.getInt("foodid"); double price=rt.getDouble("foodprice"); String remark=rt.getString("remark"); String desc=rt.getString("description"); String fimage=rt.getString("foodimage"); //把每个餐品的信息打包成一个餐品对象 food=new Food(); food.id=fid; food.name=name; food.price=price; food.desc=desc; food.fimage=fimage; food.remark=remark; } rt.close(); st.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } return food; } }