###加载JDBC驱动 只需要在第一次连接数据库时加载,java6以后我们可以直接这样加载: *我在本系列教程中用mysql示例。
- 需要导入jar包:mysql-connector-java-5.0.8-bin.jar(版本和下载网站自己挑)
- 如果是web程序,把jar包放到WebRoot/WEB-INF/lib/下
- 如果是普通java项目,将jar包导入到自己项目的lib库中。
- 然后加载驱动如下
Class.forName("com.mysql.jdbc.Driver");复制代码
###打开连接 打开连接的话需要调用DriverManager类中的getConnection()方法,该方法有三个重载方法。如下所示
public static Connection getConnection(String url, java.util.Properties info) throws SQLException { return (getConnection(url, info, Reflection.getCallerClass())); }public static Connection getConnection(String url, String user, String password) throws SQLException { java.util.Properties info = new java.util.Properties(); if (user != null) { info.put("user", user); } if (password != null) { info.put("password", password); } return (getConnection(url, info, Reflection.getCallerClass()));} public static Connection getConnection(String url) throws SQLException { java.util.Properties info = new java.util.Properties(); return (getConnection(url, info, Reflection.getCallerClass())); }复制代码
大概看下它的参数名字应该知道它需要什么吧。在这里我只解释第一个方法。Properties info 这个参数其实也是user和password的打包。其实和方法二一样。
######实例:
public class Main { public static void main(String[] args) { String url = "jdbc:mysql://localhost:3306/user"; String user = "root"; String password = "root"; Connection connection = null; Statement statement = null; ResultSet resultSet = null; try { // 1.加载驱动//com.mysql.jdbc.Driver Class.forName("com.mysql.jdbc.Driver"); // 2.获取连接 connection = DriverManager.getConnection(url, user, password); // 3.获取用于向数据库发送SQL的Statement对象 statement = connection.createStatement(); // 4.执行sql,获取数据 resultSet = statement.executeQuery("SELECT * FROM user;"); // 解析数据 while (resultSet.next()) { int id = resultSet.getInt("id"); String name = resultSet.getString("username"); String psd = resultSet.getString("birthday"); String email = resultSet.getString("sex"); String birthday = resultSet.getString("address"); System.out.println(" " + name + " " + psd + " " + email + " " + birthday); } } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } finally { //5.关闭连接,释放资源 if (resultSet != null) { try { resultSet.close(); } catch (SQLException e) { e.printStackTrace(); } resultSet = null; } if (statement != null) { try { statement.close(); } catch (SQLException e) { e.printStackTrace(); } statement = null; } if (connection != null) { try { connection.close(); } catch (SQLException e) { e.printStackTrace(); } connection = null; } } }}复制代码
###数据查询 数据查询需要我们将sql发送给数据库,我们需要创建一个Statement对象。
Statement statement = connection.createStatement();复制代码
因为Statement对象可以执行sql
String sql = "select * from user";ResultSet resultSet = statement.executeQuery(sql);复制代码
当执行一个sql查询的时候,会得道一个ResultSet对象,它里面放着查询的结果。
ResultSet resultSet = statement.executeQuery("SELECT * FROM user;");复制代码
那怎样获取user表中对应列的数据呢?
resultSet .getString ("columnName"); resultSet .getLong ("columnName"); resultSet .getInt ("columnName"); resultSet .getDouble ("columnName"); resultSet .getBigDecimal("columnName");复制代码
或者通过第几列进行查询。
resultSet .getString (1); resultSet .getLong (2); resultSet .getInt (3); resultSet .getDouble (4); resultSet .getBigDecimal(5);复制代码
如果你想知道对应列名的index值(位于第几列),可以这样
int columnIndex = resultSet .findColumn("columnName");复制代码
###数据修改/删除
为什么要把修改和删除放一块说呢,因为他们和查询调用不一样的方法。 查询我们调用executeQuery()方法,修改和删除我们需要用executeUpdate()方法。 举个简单的例子:
//更新数据(也叫修改数据)String sql = "update user set name='fantj' where id=1";int rowsAffected = statement.executeUpdate(sql); //rowsAffected是影响行数的意思//删除数据String sql = "delete from user where id=123";int rowsAffected = statement.executeUpdate(sql);复制代码
###关闭连接 为了安全性和项目性能,我们尽量在执行完操作之后关闭连接(虽然高版本jvm会自动关闭它,但是这也需要检测浪费cpu资源)。 关闭连接分为三个部分。
- resultSet.close();
- statement.close();
- connection.close();
注意先后问题。