JDBC补充 statement对象

JDBC补充 statement对象

statement对象

Jdbc中的statement对象用于向数据库发送SQL语句,想完成对数据库的增删改查,只需要通过这个对象向数据库发送增删改
查语句即可。

Statement对象的executeUpdate方法,用于向数据库发送增、删、改的sq|语句, executeUpdate执行完后,将会返回一个整
数(即增删改语句导致了数据库几行数据发生了变化)。
Statement.executeQuery方法用于向数据库发送查询语句,executeQuery方法返回代表查询结果的ResultSet对象。

CRUD操作-create

使用executeUpdate(String sq)方法完成数据添加操作,示例操作:

Statement st = conn.createstatement();
String sq1 = "insert into uer(...) values(....) ";
int num = st.executeupdate(sq1);
if (num>0){
System.out.print1n("插入成功!!!");
}

CRUD操作-delete

使用executeUpdate(String sq|)方法完成数据删除操作,示例操作:

Statement st = conn.CreateStatement();
String sq1 = "delete from user where id=1";
int num = st.executeupdate(sq1) ;
if (num>0){
System.out. print1n(“删除成功! ! ! ");
}

CRUD操作-update

使用executeUpdate(String sq|)方法完成数据修改操作,示例操作:

Statement st = conn.createStatement () ;
string sq1 = "update user set name='' where name='";
int num = st.executeupdate(sq1);
if(num>0){
	System.out.print1n(“修改成功! ! ! ");
}

CRUD操作-read

使用executeQuery(String sq|)方法完成数据查询操作,示例操作:

Statement st = conn.createStatement();
string sq1 = "select * fcom user where id=1";
Resultset rs = st.executeupdate(sq1);
while(rs.next(){
//根据 获取列的数据类型,分别调用rs的相应方法映射到java对象中
}

代码实现

1、提取工具类

package com.lantian.lesson02.utils;

import java.io.InputStream;
import java.sql.*;
import java.util.Properties;

public class jdbcUtils {

    private static String driver = null;
    private static String url = null;
    private static String username = null;
    private static String password = null;

    static {
        try {
            InputStream in = jdbcUtils.class.getClassLoader().getResourceAsStream("src/db.properties");
            Properties properties = new Properties();
            properties.load(in);

            driver = properties.getProperty("driver");
            url = properties.getProperty("url");
            username = properties.getProperty("username");
            password = properties.getProperty("password");

            //1. 驱动只用加载一次
            Class.forName(driver);

        } catch (Exception e){
            e.printStackTrace();
        }
    }

    //获取链接
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(url, username, password);
    }

    //释放资源
    public static void release(Connection connection, Statement statement, ResultSet resultSet){
        if (resultSet!=null){
            try {
                resultSet.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (statement!=null){
            try {
                statement.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (connection!=null){
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

    }
}

2、编写增删改查的方法 'executeUpdate'

3、查询

上一篇:MyBatis 整体架构【包含 SQL执行流程】


下一篇:mysql之PreparedStatement的增删改