Java中使用JDBC操作数据库简单实例

下面是详细的Java中使用JDBC操作数据库的完整攻略。

1. JDBC简介

Java Database Connectivity (JDBC) 是一种能够让Java程序与各种数据库进行连接、查询、更新、插入和删除等操作的API。使用JDBC API进行数据库操作的通常步骤如下：

1. 加载JDBC驱动程序。
2. 建立JDBC连接。
3. 创建JDBC Statement或PreparedStatement对象。
4. 执行SQL查询语句或更新语句。
5. 处理查询结果。
6. 关闭JDBC连接。

2. JDBC操作数据库步骤详解

2.1 加载JDBC驱动程序

JDBC的不同数据库厂商会提供不同的驱动程序，需要根据实际情况选择相应的驱动程序。一般情况下，需要将驱动程序jar包添加到Java项目的classpath中。可以使用Class.forName()方法动态加载驱动程序，例如：

Class.forName("com.mysql.jdbc.Driver");

2.2 建立JDBC连接

JDBC连接需要指定数据库的连接信息，例如数据库的URL、用户名和密码等。连接数据库的过程通常使用DriverManager类进行管理，例如：

Connection conn = DriverManager.getConnection(
  "jdbc:mysql://localhost:3306/dbname",
  "username", "password");

其中，localhost:3306代表数据库所在的主机和端口，dbname代表数据库的名称，username和password代表连接数据库所需的用户名和密码。

2.3 创建JDBC Statement或PreparedStatement对象

创建Statement对象后，可以使用它来执行一条不带参数的SQL语句，例如：

Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT * FROM table");

创建PreparedStatement对象后，需要使用?占位符来代替SQL语句的变量部分，例如：

PreparedStatement pstmt = conn.prepareStatement(
  "SELECT * FROM table WHERE id = ?");
pstmt.setInt(1, 1);
ResultSet rs = pstmt.executeQuery();

2.4 执行SQL查询语句或更新语句

可以使用executeQuery方法执行SQL查询语句，例如：

ResultSet rs = stmt.executeQuery("SELECT * FROM table");
while (rs.next()) {
  String name = rs.getString("name");
  int age = rs.getInt("age");
  //对查询结果进行处理
}

可以使用executeUpdate方法执行SQL更新语句，例如：

int rows = stmt.executeUpdate("INSERT INTO table VALUES (1, 'name', 20)");
System.out.println(rows + " rows affected");

2.5 处理查询结果

使用ResultSet对象可以对查询结果进行处理，例如：

while (rs.next()) {
  String name = rs.getString("name");
  int age = rs.getInt("age");
  //对查询结果进行处理
}

其中，next方法用于将ResultSet对象指针向下移动一行，如果下一行不为空，则返回true。使用getString、getInt等方法可以获取不同数据类型的查询结果。

2.6 关闭JDBC连接

在使用完之后，需要关闭JDBC连接，例如：

rs.close();
stmt.close();
conn.close();

详细示例：

import java.sql.*;

public class MySQLJDBC{
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/TEST";
   static final String USER = "username";
   static final String PASS = "password";

   public static void main(String[] args) {
      Connection conn = null;
      Statement stmt = null;

      try{
         Class.forName("com.mysql.jdbc.Driver");

         System.out.println("连接数据库...");
         conn = DriverManager.getConnection(DB_URL,USER,PASS);

         System.out.println(" 实例化Statement对象...");
         stmt = conn.createStatement();
         String sql;
         sql = "SELECT id, name, age FROM Employees";
         ResultSet rs = stmt.executeQuery(sql);

         while(rs.next()){
            int id  = rs.getInt("id");
            String name = rs.getString("name");
            int age = rs.getInt("age");

            System.out.print("ID: " + id);
            System.out.print(", 名字: " + name);
            System.out.println(", 年龄: " + age);
         }
         rs.close();
         stmt.close();
         conn.close();
      }catch(SQLException se){
         se.printStackTrace();
      }catch(Exception e){
         e.printStackTrace();
      }finally{
         try{
            if(stmt!=null) stmt.close();
         }catch(SQLException se2){
         }
         try{
            if(conn!=null) conn.close();
         }catch(SQLException se){
            se.printStackTrace();
         }
      }
   }
}

该示例使用JDBC连接数据库，查询Employees表，并将结果输出到控制台。

如果需要使用PreparedStatement对象，可以按照以下方式执行SQL查询语句：

String sql = "SELECT id, name, age FROM Employees WHERE id = ?";
PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setInt(1, 1001);
ResultSet rs = pstmt.executeQuery();