JDBC

1.利用工具类Dbutils

package cn.neusoft.util;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class Dbutils {
    private static final String driver="com.mysql.jdbc.Driver";
    private static final String url="jdbc:mysql://localhost:3306/shopping";
    private static final String name="root";
    private static final String pwd="root";
    
    private static Connection con=null;
    private static PreparedStatement ps=null;
    private static ResultSet rs=null;
    //加载驱动
    static{
        try {
            Class.forName(driver);
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    //获取连接
    private static void getConnection(){
        try {
            con=DriverManager.getConnection(url,name,pwd);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    //关闭所有连接
    private static void closeAll(){
        if(null!=rs){
            try {
                rs.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        
        if(null!=ps){
            try {
                ps.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        
        if(null!=con){
            try {
                con.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }
    
    //查询公用方法
    public static ResultSet executeQuery(String sql,Object[] obj){
        getConnection();
        try {
            ps=con.prepareStatement(sql);
            if(null!=obj){
                for(int i=0;i<obj.length;i++){
                    ps.setObject(i+1, obj[i]);
                }
            }
            rs=ps.executeQuery();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            closeAll();
        }
        return rs;
    }
    
    //增删改公用方法
    public static int executeUpdate(String sql,Object[] obj){
        int count=0;
        getConnection();
        try {
            ps=con.prepareStatement(sql);
            if(null!=obj){
                for(int i=0;i<obj.length;i++){
                    ps.setObject(i+1, obj[i]);
                }
            }
            count=ps.executeUpdate();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            closeAll();
        }
        return count;
    }
}

2.编写测试model,dao和daoimpl

package cn.neusoft.test;

public class User {

    public String uname;
    
    public String pwd;

    public String getUname() {
        return uname;
    }

    public void setUname(String uname) {
        this.uname = uname;
    }

    public String getPwd() {
        return pwd;
    }

    public void setPwd(String pwd) {
        this.pwd = pwd;
    }

    public User(String uname, String pwd) {
        super();
        this.uname = uname;
        this.pwd = pwd;
    }

    public User() {
        super();
    }
    
}

package cn.neusoft.test;

public interface UserDao {
    public int addUser(User user);
}

package cn.neusoft.test;

import cn.neusoft.util.Dbutils;

public class UserDaoImpl implements UserDao {

    @Override
    public int addUser(User user){
        String sql="insert into tbl_user (uname,pwd) values(?,?)";
        Object[] obj=new Object[]{user.getUname(),user.getPwd()};
        int a=0;
        a=Dbutils.executeUpdate(sql, obj);
        return a;
    }
}

3.测试

package cn.neusoft.test;

import cn.neusoft.util.Dbutils;

public class TestUserDao {
    static UserDao userdao=new UserDaoImpl();
    public static int testUser(User user){
        int a=userdao.addUser(user);
        System.out.println(a);
        return a;
    }
    public static void main(String[] args) {
        User user=new User("8","8");
        testUser(user);
    }
}

4.测试成功！

　　单独测试的话需要加入mysql-connector-java-5.0.8-bin.jar包，并右击Add to bulid path