Java使用JDBC连接mySQL数据库小例子

约定不等于承诺〃 2022-07-17 00:20 223阅读 0赞

Java连接mySQL数据库时，需要使用到一个Jar包，如："[mysql-connector-java-5.0.5-bin.jar][]"，此为连接数据库

的驱动包，将其导入所在工程的lib目录下，并Build Path，即可进行引用。

注意：如果你没有添加jar程序驱动包的话编译的时候发现以下问题：

Sorry,can\`t find the Driver!

java.lang.ClassNotFoundException: com.mysql.jdbc.Driver

atjava.net.URLClassLoader$1.run(Unknown Source)

atjava.security.AccessController.doPrivileged(Native Method)

atjava.net.URLClassLoader.findClass(Unknown Source)

atjava.lang.ClassLoader.loadClass(Unknown Source)

atsun.misc.Launcher$AppClassLoader.loadClass(Unknown Source)

atjava.lang.ClassLoader.loadClass(Unknown Source)

atjava.lang.Class.forName0(Native Method)

atjava.lang.Class.forName(Unknown Source)

这里可供下载驱动包：[http://dev.mysql.com/downloads/connector/j/][http_dev.mysql.com_downloads_connector_j]，导入Jar后，接下来进行操作。

1、新建一个名为BDHelper的工具类：为外界提供数据库连接对象。

package util;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    
    public class DBHelper {
    	
    	//mysql数据库驱动，固定写法。连接Oracle时又与之不同,为："oracle.jdbc.driver.OracleDriver"
    	private static final String driver = "com.mysql.jdbc.Driver"; 
    
    	/**
    	* 如下是连接数据库的URL地址，
    	* 其中，"jdbc:mysql://"   为固定写法
    	* "localhost"是连接本机数据库时的写法，当不是连接本机数据库时，要写数据库所在计算机的IP地址。如：172.26.132.253
    	* "shopping"是数据库的名称，一定要根据自己的数据库更改。
    	* "?useUnicode=true&characterEncoding=UTF-8" 指定编码格式，无需时可省略，
    	* 即地址直接为："jdbc:mysql://localhost:3306/shopping"
    	*/
    	private static final String url="jdbc:mysql://localhost:3306/shopping?useUnicode=true&characterEncoding=UTF-8"; 
    	
    	private static final String username="root";//数据库的用户名
    	private static final String password="123456";//数据库的密码:这个是自己安装数据库的时候设置的，每个人不同。
        
    	private static Connection conn=null;  //声明数据库连接对象
    	
    	//静态代码块负责加载驱动
    	static 
    	{
    		try
    		{
    			Class.forName(driver);
    		}
    		catch(Exception ex)
    		{
    			ex.printStackTrace();
    		}
    	}
    	
    	//单例模式返回数据库连接对象，供外部调用
    	public static Connection getConnection() throws Exception
    	{
    		if(conn==null)
    		{
    			conn = DriverManager.getConnection(url, username, password); //连接数据库
    			return conn;
    		}
    		return conn;
    	}
    	
    	//写main方法测试是否连接成功，可将本类运行为Java程序先进行测试，再做后续的数据库操作。
    	public static void main(String[] args) {
    		
    		try
    		{
    		   Connection conn = DBHelper.getConnection();
    		   if(conn!=null)
    		   {
    			   System.out.println("数据库连接正常！");
    		   }
    		   else
    		   {
    			   System.out.println("数据库连接异常！");
    		   }
    		}
    		catch(Exception ex)
    		{
    			ex.printStackTrace();
    		}
    		
    	}
    }

2、在已有的数据库中，建立数据库表tb\_user，这里使用的是Navicat数据库管理工具进行建表操作。

![Center][]

![Center 1][]

3、建立与tb\_user表对应的实体类：

package service;
    
    /**
     * 对应数据库在中的tb_user表
     */
    public class User {
    	
    	private int id;
    	
    	private String name;
    	
    	private String pwd;
    	
    	public int getId() {
    		return id;
    	}
    	public void setId(int id) {
    		this.id = id;
    	}
    	public String getName() {
    		return name;
    	}
    	public void setName(String name) {
    		this.name = name;
    	}
    	public String getPwd() {
    		return pwd;
    	}
    	public void setPwd(String pwd) {
    		this.pwd = pwd;
    	}
    }

4 、调用DBHelper 工具类进行数据库操作：

package service;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.util.ArrayList;
    import java.util.List;
    
    import util.DBHelper;
    
    public class dao{
    
    	// 数据库连接对象，注意：是导入“java.sql.Connection”此包下的连接对象。
    	private static Connection conn = null; 
    
    	// PreparedStatement对象用来执行SQL语句
    	private static PreparedStatement pst = null; 
    
    	//结果集
    	private static ResultSet rs = null;
    
    	//保存查询到的实体集合
    	List list = null;
    
    	/**
    	 * 查询数据库，获取一个User类型的list集合
    	 */
    	public List getUsers(){
    		list = new ArrayList<User>();
    
    		try {
    			conn=DBHelper.getConnection();  //从DBHelper获取连接对象
    
    			// 创建statement 执行数据库语句，第一不预处理，第二步才是正式。执行的语句可以修改.
    			// 不过为了防止SQl注入。骗取登录，所以最好创建它的子类PreparedStatement 
    			pst = conn.prepareStatement("SELECT * FROM users");// 预处理
    
    			rs = pst.executeQuery();// 这里才是执行，获得数据。 
    
    			// 遍历处理结果集，用while 方法next方法,相当于指针依次下移，获得每一行表的数据 
    
    			while (rs.next()) {
    
    				User user=new User(); 
    
    				/**
    				 * 两种get,
    				 * 一种是根据下标 从1开始每一列， 
    				 * rs.getInt(1); 
    				 * rs.getString(2); 
    				 * rs.getString(3);
    				 * 第二个是根据列名查找。根据表的列数据类型使用不同的个体方法 
    				 */
    
    				//为user属性赋值
    				user.setId(rs.getInt(1));
    				user.setName(rs.getString(2));
    				user.setPwd(rs.getString(3)); 
    
    				//将user对象添加到list集合中
    				list.add(user); 
    			}
    		} catch (Exception e) {
    			e.printStackTrace();
    		}finally {
    			// 关闭资源.一定要关闭资源。数据库的每一个连接都占据服务器资源。
    			// 我们写代码的时候感觉不到， 
    			// 但是一旦服务器运行个三五天，连接就会不断地增加，最终导致资源不足，
    			// 服务器将自动关机来强行关闭连接。 
    			// 而且这里面，不仅这里，全部过程都不要抛出异常，而是要捕捉处理异常，不然也会导致资源浪费。
    			//即使前面抛出异常，程序中断，也会执行关闭资源，而不影响浪费。
    			
    			try {
    				// 这里最好要先判断是否为空，不为空了，才去关闭。 
    				// 而且要从小到大的关闭，顺序不能乱 
    				if (rs != null) 
    					rs.close(); 
    				if (pst != null) 
    					pst.close(); 
    				/*if (conn != null) 
    					conn.close(); */    //注意：如果后续还要使用connection，则不用关闭
    			} catch (SQLException e) 
    			{ 
    				e.printStackTrace(); 
    			}
    		}
    		return list;
    	}
    }

5、获得此数据集合后，根据需要进行相应的操作。

[......][]

[mysql-connector-java-5.0.5-bin.jar]: http://download.csdn.net/detail/u012660464/9607656
[http_dev.mysql.com_downloads_connector_j]: http://dev.mysql.com/downloads/connector/j/
[Center]: /images/20220717/10868fec82fc44e0a9466900d9d11385.png
[Center 1]: /images/20220717/ba1b941bc05f4a37b4ca1055a1c35312.png
[......]: http://www.imooc.com/article/12421?block_id=tuijian_wz