数据库连接

Posted 2020-08-30

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

public class Testmysql {
	public static void main(String[] args) {
		Connection con = null;
		Statement stat = null;
		ResultSet rs = null;
		try {
			/*
			 * 1.创建connection（注意：是Java.sql包中的Connection）；
			 * 创建这个connection需要指定相应的连接字符串，用户名和密码；
			 */
			String url = "jdbc:mysql://localhost:3306/hls";
			String user = "root";
			String password = "123456";
			con = DriverManager.getConnection(url, user, password);
			
			/*
			 * 2.创建SQL
			 * 执行SQL语句需要使用Statement;
			 */
			String sql = "select * from t_classroom";
			stat = con.createStatement();
			/*
			 * 在获取stat之后，如果执行的是更新，直接使用stat.executeLargeUpdate(sql)完成更新；
			 * 如果执行的是查询，需要通过stat.executeQuery(sql)完成，返回值是一个ResultSet的记录集；
			 */
			
			rs = stat.executeQuery(sql);
			/*
			 * 遍历记录集的统一方式是
			 */
			while (rs.next()){
				System.out.println(rs.getInt("id")+","+rs.getString("name"));
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally{
			/*
			 * 完成之后需要释放连接；释放顺序依次是 rs,stat,con;
			 */
			try {
				if (rs!=null) rs.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			try {
				if (stat!=null) stat.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			try {
				if (con!=null) con.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
}