java实现连接mysql数据库单元测试查询数据项目分享

1、按照javaweb项目的要求逐步建立搭建起机构，具体的类包有：model 、db、dao、test;具体的架构详见下图：

2、根据搭建的项目架构新建数据库test和数据库表t_userinfo并且添加对应的测试数据; (这里我使用的是绿色版的数据库，具体的下载地址：http://pan.baidu.com/s/1mg88YAc) 具体的建立数据库操作详见下图：

3、编写包中的各种类代码，具体参考代码如下：

UserInfo.java

/**  * FileName:     UserInfo.java  * @Description: TODO封装对象的信息  * Copyright: personage    * Company  personage      * @author:    gaoxing  * @version    V1.0   * Createdate:         2014-5-25 下午2:26:41  *  * Modification  History:  * Date         Author        Version        Discription  * -----------------------------------------------------------------------------------  * 2014-5-25       GX          1.0             1.0  * Why & What is modified: <修改原因描述>  */ package com.org.user.model;  /**  * @ClassName:     UserInfo  * @Description:TODO封装对象的信息  * @author:   gaoxing  * @date:        2014-5-25 下午2:26:41  */ public class UserInfo {   private  int userid;     private String username;     private String password;      /**   * @Title:        UserInfo   * @Description:    TODO(描述这个方法的作用)   * @param:    @param userid   * @param:    @param username   * @param:    @param password   * @throws   */  public UserInfo(int userid, String username, String password) {   super();   this.userid = userid;   this.username = username;   this.password = password;  }   /**  * @Title:        UserInfo  * @Description:    TODO无参的构造方法  * @param:      * @throws  */ public UserInfo() {  super(); }  public int getUserid() {   return userid;  }  public void setUserid(int userid) {   this.userid = userid;  }  public String getUsername() {   return username;  }  public void setUsername(String username) {   this.username = username;  }  public String getPassword() {   return password;  }  public void setPassword(String password) {   this.password = password;  }   }

UserInfoDBManger.java

/**  * FileName:     UserInfoDBManger.java  * @Description: TODO 连接数据库的操作  * Copyright: personage    * Company  personage      * @author:    gaoxing  * @version    V1.0   * Createdate:         2014-5-25 下午2:47:38  *  * Modification  History:  * Date         Author        Version        Discription  * -----------------------------------------------------------------------------------  * 2014-5-25       GX          1.0             1.0  * Why & What is modified: <修改原因描述>  */ package com.org.user.db;  import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException;  import com.mysql.jdbc.Connection; import com.mysql.jdbc.PreparedStatement;  /**  * @ClassName: UserInfoDBManger  * @Description:TODO连接数据库的操作  * @author: gaoxing  * @date: 2014-5-25 下午2:47:38  */ public class UserInfoDBManger {  private  static Connection conn = null;  private PreparedStatement ps = null;  private ResultSet rs = null;   public static  Connection getConn() {   String url = "jdbc:mysql://localhost:3306/test";   try {    Class.forName("com.mysql.jdbc.Driver");    try {     conn = (Connection) DriverManager.getConnection(url, "root",       "mysql");    } catch (SQLException e) {     System.out.println(e.getMessage());    }   } catch (ClassNotFoundException e) {    System.out.println(e.getMessage());   }   return conn;  }   public void close() {   try {    rs.close();    ps.close();    conn.close();   } catch (SQLException e) {    e.getMessage();   }  }   }

UserInfoDao.java

/**  * FileName:     UserInfoDao.java  * @Description: TODO 处理通过数据库的连接进行操作对象信息  * Copyright: personage    * Company  personage      * @author:    gaoxing  * @version    V1.0   * Createdate:         2014-5-25 下午2:36:09  *  * Modification  History:  * Date         Author        Version        Discription  * -----------------------------------------------------------------------------------  * 2014-5-25       GX          1.0             1.0  * Why & What is modified: <修改原因描述>  */ package com.org.user.dao;  import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List;  import com.mysql.jdbc.Connection; import com.mysql.jdbc.PreparedStatement; import com.org.user.db.UserInfoDBManger; import com.org.user.model.UserInfo;  /**  * @ClassName:     UserInfoDao  * @Description:TODO处理通过数据库的连接进行操作对象信息  * @author:   gaoxing  * @date:        2014-5-25 下午2:36:09  */ public class UserInfoDao {  Connection conn=null;  PreparedStatement ps=null;  ResultSet rs=null;  public   List<UserInfo>  find(){   List<UserInfo> list=new ArrayList<UserInfo>();   String sql="select * from  t_userinfo ";   conn=UserInfoDBManger.getConn();   try {    ps=(PreparedStatement) conn.prepareStatement(sql);    rs=ps.executeQuery();    while (rs.next()) {     UserInfo ui=new UserInfo();      ui.setUserid(rs.getInt(1));      ui.setUsername(rs.getString(2));      ui.setPassword(rs.getString(3));     list.add(ui);         }   } catch (SQLException e) {    // TODO Auto-generated catch block    e.printStackTrace();     }   return list;  } }

UserInfoTest.java

/**  * FileName:     UserInfoTest.java  * @Description: TODO测试dao包的方法  * Copyright: personage    * Company  personage      * @author:    gaoxing  * @version    V1.0   * Createdate:         2014-5-25 下午5:43:03  *  * Modification  History:  * Date         Author        Version        Discription  * -----------------------------------------------------------------------------------  * 2014-5-25       GX          1.0             1.0  * Why & What is modified: <修改原因描述>  */ package com.org.user.test;  import static org.junit.Assert.*;  import java.util.List;  import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Test;  import com.org.user.dao.UserInfoDao; import com.org.user.model.UserInfo;  /**  * @ClassName:     UserInfoTest  * @Description:TODO 测试dao包的方法  * @author:   gaoxing  * @date:        2014-5-25 下午5:43:03  */ public class UserInfoTest {   /**   * @Title: setUpBeforeClass   * @Description: TODO(描述这个方法的作用)   * @param: @throws java.lang.Exception      * @return: void      * @throws   */  @BeforeClass  public static void setUpBeforeClass() throws Exception {  }   /**   * @Title: tearDownAfterClass   * @Description: TODO(描述这个方法的作用)   * @param: @throws java.lang.Exception      * @return: void      * @throws   */  @AfterClass  public static void tearDownAfterClass() throws Exception {  }   /**   * Test method for {@link com.org.user.dao.UserInfoDao#find()}.   */  @Test  public void testFind() {    UserInfoDao  udao=new UserInfoDao();    List<UserInfo>  list=udao.find();    for (int i = 0; i < list.size(); i++) {     UserInfo ui=list.get(i);     System.out.println("名称:  "+ui.getUsername()+"密码:  "+ui.getPassword());    }  }  }

4、在编写好类内容之后，在搭建项目过程中要加入辅助的JUnit的测试包junit.jar，同时也要导入数据库的连接mysq-connector-java-5.1.7-bin.jar  sqljdbc.jar,这样才可以连接到数据库；

5、所有的工作做好之后，就可以启动服务进行运行了查看结果了，如果在JUnit测试台和控制台出现如下结果就表示项目运行成功了。