Jdbc系列三：Statement接口

深碍√TFBOYSˉ_ 2022-01-27 05:55 225阅读 0赞

一、访问数据库  
 数据库连接被用于向数据库服务器发送命令和 SQL 语句，在连接建立后，需要对数据库进行访问，执行 sql 语句。  
 在 java.sql 包中有 3 个接口分别定义了对数据库的调用的不同方式：  
  Statement  
  PrepatedStatement  
  CallableStatement

二、Statement  
 通过调用 Connection 对象的 createStatement 方法创建该对象。  
 该对象用于执行静态的 SQL 语句，并且返回执行结果。  
 Statement 接口中定义了下列方法用于执行 SQL 语句：  
  ResultSet excuteQuery(String sql)  
  int excuteUpdate(String sql)  
1、使用Statement执行sql

/**
     * 通过 JDBC 向指定的数据表中插入一条记录.
     *
     * 1. Statement: 用于执行 SQL 语句的对象
     * 1). 通过 Connection 的 createStatement() 方法来获取
     * 2). 通过 executeUpdate(sql) 可以执行 SQL 语句.
     * 3). 传入的 SQL 可以是 INSRET, UPDATE 或 DELETE. 但不能是 SELECT
     *
     * 2. Connection、Statement 都是应用程序和数据库服务器的连接资源. 使用后一定要关闭.
     * 需要在 finally 中关闭 Connection 和 Statement 对象.
     *
     * 3. 关闭的顺序是: 先关闭后获取的. 即先关闭 Statement 后关闭 Connection
     */
    @Test
    public void testStatement() throws Exception{
        //1. 获取数据库连接
        Connection conn = null;
        Statement statement = null;
    
        try {
            conn = getConnection2();
    
            //3. 准备插入的 SQL 语句
            String sql = null;
    
            //sql = "INSERT INTO user (ID,NAME) VALUES('1','lizq')";
            //sql = "UPDATE user SET name = 'TOM' WHERE id = 1";
    		sql = "DELETE FROM user WHERE id = 1";
            System.out.println(sql);
    
            //4. 执行插入.
            //1). 获取操作 SQL 语句的 Statement 对象:
            //调用 Connection 的 createStatement() 方法来获取
            statement = conn.createStatement();
    
            //2). 调用 Statement 对象的 executeUpdate(sql) 执行 SQL 语句进行插入
            statement.executeUpdate(sql);
        } catch (Exception e) {
            e.printStackTrace();
        } finally{
            try {
                //5. 关闭 Statement 对象.
                if(statement != null)
                    statement.close();
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } finally{
                //2. 关闭连接
                if(conn != null)
                    conn.close();
            }
        }
    
    }

2、工具类JDBCTools

/**
     * 操作 JDBC 的工具类. 其中封装了一些工具方法 
     */
    public class JDBCTools {
    
    	public static void release(ResultSet rs, 
    			Statement statement, Connection conn) {
    		if(rs != null){
    			try {
    				rs.close();
    			} catch (SQLException e) {
    				e.printStackTrace();
    			}
    		}
    		
    		
    		if (statement != null) {
    			try {
    				statement.close();
    			} catch (Exception e2) {
    				e2.printStackTrace();
    			}
    		}
    
    		if (conn != null) {
    			try {
    				conn.close();
    			} catch (Exception e2) {
    				e2.printStackTrace();
    			}
    		}
    	}
    	
    	/**
    	 * 关闭 Statement 和 Connection
    	 * @param statement
    	 * @param conn
    	 */
    	public static void release(Statement statement, Connection conn) {
    		if (statement != null) {
    			try {
    				statement.close();
    			} catch (Exception e2) {
    				e2.printStackTrace();
    			}
    		}
    
    		if (conn != null) {
    			try {
    				conn.close();
    			} catch (Exception e2) {
    				e2.printStackTrace();
    			}
    		}
    	}
    
    	/**
    	 * 1. 获取连接的方法. 通过读取配置文件从数据库服务器获取一个连接.
    	 * 
    	 * @return
    	 * @throws Exception
    	 */
    	public static Connection getConnection() throws Exception {
    		// 1. 准备连接数据库的 4 个字符串.
    		// 1). 创建 Properties 对象
    		Properties properties = new Properties();
    
    		// 2). 获取 jdbc.properties 对应的输入流
    		InputStream in = JDBCTools.class.getClassLoader().getResourceAsStream(
    				"jdbc.properties");
    
    		// 3). 加载 2） 对应的输入流
    		properties.load(in);
    
    		// 4). 具体决定 user, password 等4 个字符串.
    		String user = properties.getProperty("user");
    		String password = properties.getProperty("password");
    		String jdbcUrl = properties.getProperty("jdbcUrl");
    		String driver = properties.getProperty("driver");
    
    		// 2. 加载数据库驱动程序(对应的 Driver 实现类中有注册驱动的静态代码块.)
    		Class.forName(driver);
    
    		// 3. 通过 DriverManager 的 getConnection() 方法获取数据库连接.
    		return DriverManager.getConnection(jdbcUrl, user, password);
    	}
    
    }

3、使用工具类

/**
      * 通用的更新的方法: 包括 INSERT、UPDATE、DELETE
      */
     public void update(String sql){
         Connection conn = null;
         Statement statement = null;
    
         try {
             conn = JDBCTools.getConnection();
             statement = conn.createStatement();
             statement.executeUpdate(sql);
         } catch (Exception e) {
             e.printStackTrace();
         } finally{
             JDBCTools.release(statement, conn);
         }
     }