jdbc.java

网上商店代码

package com.ata.shoping.user;


import java.sql.*;
import java.util.ArrayList;
import java.util.Iterator;


public class JDBC {

		public static Connection getConnection()throws SQLException,InstantiationException,IllegalAccessException,ClassNotFoundException{
		
		Connection conn=null;
		
		//加载数据库驱动
		Class.forName("com.mysql.jdbc.Driver");
		//数据库连接
		String url="jdbc:mysql://192.168.2.187:3306/My_db";
		//数据库用户名称
		String user="root";
		//数据库密码
		String password="root";
		//根据数据库取得一个数据库的链接
		conn=DriverManager.getConnection(url,user,password);
		return conn;
		
	}
	
	
	
	//根据SQL语句返回一个对象的链表
	public ArrayList select(String sql)throws Exception{
		ArrayList<User> result=new ArrayList<User>();
		Connection conn=null;
		Statement stmt=null;
		ResultSet rs=null;
		
		try{
			conn=getConnection();
			stmt=conn.createStatement();
			rs=stmt.executeQuery(sql);
			while(rs.next()){
				User user1=new User();
				user1.setUsername(rs.getString("username"));

//				product1.setNumber(rs.getInt("number"));
				
				
				result.add(user1);
				
				
				
			}
			
			
			
			
		}
		catch(SQLException sqle){
			sqle.printStackTrace();
		}
		catch(Exception e){
			e.printStackTrace();
		}
		finally{
			try{
			if(rs !=null){
				rs.next();
			}
			}
			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;
	}
	
	//使用链表进行插入
	
	
	
	
	
	
	//根据传入的对象向数据库插入一条数据
	
	

}