ormdbproduct.java

采用java实现的网上商店

package com.ata.java2.shoppingcart;
import java.sql.*;
import java.sql.Date;
import java.util.*;
public class ORMDBProduct {
	public ORMDBProduct() {
		super();     
	}
 
public Connection getConnection(){
	Connection conn=null;
	String url="jdbc:mysql://192.168.2.188:3306/shoppingweb?useUnicode=true&characterEncoding=gbk";
	String user="root";
	String password="root";
	try{
	Class.forName("com.mysql.jdbc.Driver");
	conn=DriverManager.getConnection(url,user,password);
	}catch(Exception e){
		e.printStackTrace();
	}
	return conn;
  
}

public ArrayList select(String sql){
	ArrayList result=new ArrayList();
	Connection conn=null;
	Statement stmt=null;
	ResultSet rs=null;
	try{
		conn=getConnection();
		stmt=conn.createStatement();
		rs=stmt.executeQuery(sql);
		while(rs.next()){
			Product pro=new Product();
			pro.setProductId(rs.getString("productId"));
			pro.setProductName(rs.getString("productName"));
			pro.setProductPrice(rs.getDouble("productPrice"));
			pro.setProductCount(rs.getInt("productCount"));
			pro.setProductImage(rs.getString("productImage"));
			pro.setProductBrand(rs.getString("productBrand"));
			pro.setProductInfo(rs.getString("productInfo"));
			pro.setProductType(rs.getString("productType"));
			result.add(pro);
		}	
	} catch(Exception e){
		e.printStackTrace();
	}finally{
		try{
			if(rs!=null)
				rs.close();
		}catch(Exception e){
			e.printStackTrace();
		}
		try{
			if(stmt!=null)
				stmt.close();
		}catch(Exception e){
			e.printStackTrace();
		}
		try{
			if(conn!=null)
				conn.close();
		}catch(Exception e){
			e.printStackTrace();
		}
	}
	return result;
}

public void insert(Product pro){
	Connection conn=null;
	PreparedStatement ps=null;
	String sql="insert into product values(?,?,?,?,?,?,?,?)";
	try{
		conn=getConnection();
		ps=conn.prepareStatement(sql);
		
		ps.setString(1,pro.getProductId());
		ps.setString(2,pro.getProductName()); 
		ps.setDouble(3,pro.getProductPrice());
		ps.setInt(4,pro.getProductCount());
		ps.setString(5,pro.getProductImage());
		ps.setString(6,pro.getProductBrand());
		ps.setString(7,pro.getProductInfo());
		ps.setString(8,pro.getProductType());
		ps.executeUpdate();
		
	}
	catch(Exception e){
		e.printStackTrace();
	}finally{
		try{
			if(ps!=null)
				ps.close();
		}catch(Exception e){
			e.printStackTrace();
		}
		try{
			if(conn!=null)
				conn.close();
		}catch(Exception e){
			e.printStackTrace();
		}
	}
}    
 
public void delete(Product pro){
	String id=pro.getProductId();
	String name=pro.getProductName();
	Connection conn=null;
	PreparedStatement ps=null;
	String sql="delete from product where productId=? AND productName=?";
	try{
		conn=getConnection();
		ps=conn.prepareStatement(sql);
		ps.setString(1, id);
		ps.setString(2, name);
		ps.executeUpdate();
		}
	catch(Exception e){
		e.printStackTrace();    
	}finally{
		try{
			if(ps!=null)
				ps.close();
		}catch(Exception e){
			e.printStackTrace();
		} 
		try{
			if(conn!=null)
				conn.close();
		}catch(Exception e){
			e.printStackTrace();
		}
	}
} 

 
public static void main(String[] args) {
	 ORMDBProduct dbp=new ORMDBProduct();
	 String sql="select *from product";
	 ArrayList list=dbp.select(sql);
	 Product pro = (Product)list.get(0);
	 dbp.delete(pro);
	  
		 
	
}
}