jdbc，全称为java database connectivity（java数据库连接），主要用于java与数据库的连接。
整个连接过程如下图所示：
-
数据库驱动：Driver
加载MySQL驱动：
Class.forName("com.mysql.jdbc.Driver");加载Oracle驱动：
Class.forName("oracle.jdbc.driver.OracleDriver");加载相应的驱动需要导入相应的包，例如对于MySQL，需要导入
mysql-connector-java-5.1.13-bin.jar，否则无法正常执行。 -
获取数据库连接：Connection
Connection类主要用于连接数据库，通常通过DriverManager.getConnection()来获取一个连接对象。该方法有三个参数，分别是url、user和password，对应的是要连接的数据库、用户名和密码。例如：url=jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf-8，user=root，password=root。 -
执行SQL语句：Statement
Statement对象用于执行SQL语句，有以下三种：（1）
Statement对象用于执行不带参数的简单SQL语句；（2）
PreparedStatement对象用于执行带或不带参数的预编译SQL语句；（3）
CallableStatement对象用于执行对数据库已存储过程的调用。Statement的常用方法：（1）
executeQuery()方法：运行查询语句，返回ResultSet对象。（2）
executeUpdate()方法：运行增、删、改操作，返回更新的行数。（3）
addBatch(String sql)：将多条SQL语句放到一个批处理中。（4）
executeBatch()：向数据库发送一批SQL语句执行。 -
结果集：ResultSet
执行
executeQuery()方法后返回的结果集。常用方法：
（1）
getString(String columnName)：获取当前行的某一String类型的字段。（2）
getFloat(String columnName)：获取当前行的某一Float类型的字段。（3）
getDate(String columnName)：获取当前行的某一Date类型的字段。（4）
getBoolean(String columnName)：获取当前行的某一Boolean类型的字段。（5）
getObject(String columnName)：获取当前行的某一任意类型的字段。（6）
next()：移动到下一行。
实际代码：
首先，建立一个配置文件，内容如下：
<code>#数据库驱动 driver=com.mysql.jdbc.Driver #连接数据库的URL url=jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf-8 #用户名 user=root #密码 password=root</code>
接着，编写一个连接数据库的通用工具类：
public class DBUtil {
private static String driver;
private static String url;
private static String user;
private static String password;
<pre class="brush:php;toolbar:false;"><code>static {
try {
//读取配置文件
InputStream in = DBUtil.class.getResourceAsStream("db.properties");
Properties properties = new Properties();
//加载配置文件
properties.load(in);
//获取配置文件中的数据
driver = properties.getProperty("driver");
url = properties.getProperty("url");
user = properties.getProperty("user");
password = properties.getProperty("password");
//加载数据库连接驱动
Class.forName(driver);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 获取一个数据库连接
*/
public static Connection getConnection() throws SQLException {
return DriverManager.getConnection(url, user, password);
}}
实现简单的增删改查：
public class jdbcTest {
/**</p><ul><li>创建表
*/
public static void createTable() throws SQLException {
String sql = "CREATE TABLE IF NOT EXISTS <code>user(" +
"<code>id</code> INT UNSIGNED AUTO_INCREMENT," +
" <code>user_name</code> VARCHAR(100)," +
" <code>user_password</code> VARCHAR(100)," +
" <code>user_age</code> INT(11)," +
"PRIMARY KEY ( <code>id</code> )" +
")ENGINE=InnoDB DEFAULT CHARSET=utf8;";
Connection conn = DBUtil.getConnection();
//开启事务
conn.setAutoCommit(false);
PreparedStatement preparedStatement = conn.prepareStatement(sql);
preparedStatement.executeUpdate();
//提交事务
conn.commit();
//要注意关闭连接（在实际中最好不要像这样关闭，最好标准一点）
conn.close();
}</li></ul><pre class="brush:php;toolbar:false;"><code>/**
* 增加数据
*/
public static void add() throws SQLException {
String sql = "INSERT INTO USER (user_name,user_password,user_age) VALUES('老王','123456',18)";
Connection conn = DBUtil.getConnection();
conn.setAutoCommit(false);
PreparedStatement preparedStatement = conn.prepareStatement(sql);
preparedStatement.executeUpdate();
conn.commit();
conn.close();
}
/**
* 删除数据
*/
public static void delete() throws SQLException {
String sql = "DELETE FROM USER WHERE USER.user_name = '老王'";
Connection conn = DBUtil.getConnection();
conn.setAutoCommit(false);
PreparedStatement preparedStatement = conn.prepareStatement(sql);
preparedStatement.executeUpdate();
conn.commit();
conn.close();
}
/**
* 修改数据
*/
public static void update() throws SQLException {
String sql = "UPDATE USER SET USER.user_name = '老李'";
Connection conn = DBUtil.getConnection();
conn.setAutoCommit(false);
PreparedStatement preparedStatement = conn.prepareStatement(sql);
preparedStatement.executeUpdate();
conn.commit();
conn.close();
}
/**
* 查找数据
*/
public static void query() throws SQLException {
String sql = "SELECT * FROM USER";
Connection conn = DBUtil.getConnection();
conn.setAutoCommit(false);
PreparedStatement preparedStatement = conn.prepareStatement(sql);
//执行查询语句并返回结果集
ResultSet resultSet = preparedStatement.executeQuery();
while (resultSet.next()) {
//注意：这里要与数据库里的字段对应
String username = resultSet.getString("user_name");
String password = resultSet.getString("user_password");
String age = resultSet.getString("user_age");
System.out.println(username + " " + password + " " + age);
}
conn.commit();
conn.close();
}</code>}
这是我的文件结构：
注意要导入相应的包，大家需要自行下载MySQL的依赖包。
