package nh.spring.tools.db;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class TestDBConnection {
/**
* 典型jdbc连接
* 1,与数据库建立连接
2,发送SQL语句
3,处理返回结果
*/
static Connection con = null;
static Statement stmt = null;
static ResultSet rs = null;
public static void main(String[] args) {
try {
// 1、加载MYSQL驱动,这里MySQL的JDBC驱动类是com.mysql.jdbc.Driver,要求类路径中包含相应的Driver类
Class.forName("com.mysql.jdbc.Driver").newInstance();
// 2、连接到MYSQL,通过DriverManger来创建Connection对象,获取数据库连接
con = DriverManager.getConnection("jdbc:mysql://localhost:3306/vShop", "root", "niuheng");
// 3、创建Statement用以执行SQL语句,或者可以使用PreparedStatement
Statement stmt = con.createStatement();
// 4、执行SQL,获取结果
ResultSet rs = stmt.executeQuery("select * from user");
// 或者执行增删改操作,如:stmt.executeUpdate("delete * from blog");
// 5、遍历并解析结果
while (rs.next()) {
long id = rs.getLong("id"); // 获取id列
String username = rs.getString("username"); // 获取username列
System.out.println("id:"+id+" Name:" +username);
}
} catch (Exception e) {
// 如果有异常,进行异常处理
System.out.print("MYSQL ERROR:" + e.getMessage());
} finally {
// 6、清理数据库连接相关的所有资源
try {
if (rs != null) {
rs.close();
}
if (stmt != null) {
stmt.close();
}
if (con != null) {
con.close();
}
} catch (SQLException ignored) {
}
}
}
}