JDBC 링크 데이터베이스에 대한 튜토리얼(코드 예)-java지도 시간-php.cn

이 기사는 JDBC 링크 데이터베이스에 대한 튜토리얼(코드 예제)을 제공합니다. 도움이 필요한 친구들이 참고할 수 있기를 바랍니다.

JDBC 소개

JDBC의 전체 이름은 Java Data Base Connectivity(Java 데이터베이스 연결)이며, 다양한 데이터베이스에 대한 통합 액세스를 제공할 수 있습니다. JDBC는 Sun에서 개발한 데이터베이스 액세스 프로그래밍 인터페이스 세트입니다. Java 언어로 작성되었으므로 크로스 플랫폼 특성이 뛰어납니다. JDBC를 사용하여 작성된 데이터베이스 애플리케이션은 다른 플랫폼에서 다른 애플리케이션을 작성할 필요 없이 Java를 지원하는 모든 플랫폼에서 실행할 수 있습니다.

JDBC 프로그래밍 단계

(1) 드라이버 로드:

드라이버 패키지 다운로드: http://dev.mysql.com/downloads/connector/j/

압축을 풀고 jar 파일을 가져옵니다. 이 파일을 Java 프로젝트 디렉터리 Java Resources/Libraries/, → buildpath에 복사합니다.

(2) 데이터베이스 연결 얻기

(3) Create State 개체:

(4) 데이터베이스에 SQL 명령 보내기

(5) 데이터베이스의 반환 결과 처리(ResultSet 클래스)

package com.baidu.emp.jdbcTest;
 
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
 
import com.mysql.jdbc.Driver;
/**
 * 开始使用jdbc连接数据库
 * @author Admin
 *
 */
public class Test001 {
 
    public static void main(String[] args) throws Exception {
 
        /**
         * 加载驱动
         */
        // 方法一：
        /*
         * import java.sql.DriverManager; import com.mysql.jdbc.Driver;
         */
        // Driver driver = new Driver();
        // DriverManager.registerDriver(driver);
 
        // 方法二：(推荐使用)
        Class.forName("com.mysql.jdbc.Driver");
 
        /**
         * 创建链接
         */
        String url = "jdbc:mysql://localhost:3306/testjdbc";
        String user = "root";
        String password = "root";
        Connection connection = DriverManager.getConnection(url, user, password);
 
        // 创建statement对象
        Statement statement = connection.createStatement();
 
        /**
         * 执行SQL，获取结果集
         */
        String sql = "select * from test01";
        ResultSet result = statement.executeQuery(sql);
 
        // 遍历结果集
        while (result.next()) {
            String name = result.getString("name");
            int id = result.getInt("id");
            System.out.println(name + "\t" + id);
        }
 
        /**
         * 关闭链接，释放资源
         */
        result.close();
        statement.close();
        connection.close();
    }
}

로그인 후 복사

SQL 주입 방지 변경 prepareStatement

package com.boya.emp.jdbcTest;
 
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
/**
 * SQL注入，使用prepareStatement对象进行预编译
 * @author Admin
 *
 */
public class Test002 {
 
    public static void main(String[] args) throws Exception {
 
        /**
         * 加载驱动
         */
        Class.forName("com.mysql.jdbc.Driver");
 
        /**
         * 创建链接
         */
        String url = "jdbc:mysql://localhost:3306/testjdbc";
        String user = "root";
        String password = "root";
        Connection connection = DriverManager.getConnection(url, user, password);
 
        // 写SQL 
        String sql = "select * from test01 where id = ?";
        //创建statement对象，预编译
        PreparedStatement statement = connection.prepareStatement(sql);
        //设置参数
        statement.setInt(1, 2);
        /**
         * 执行SQL，获取结果集
         */
        ResultSet result = statement.executeQuery();
 
        // 遍历结果集
        while (result.next()) {
            String name = result.getString("name");
            int id = result.getInt("id");
            System.out.println(name + "\t" + id);
        }
 
        /**
         * 关闭链接，释放资源
         */
        result.close();
        statement.close();
        connection.close();
    }
}

로그인 후 복사

를 사용하여 코드를 최적화하고, 구성 파일, 도구 클래스를 설정하고, 추가 및 삭제를 확인하세요.

데이터베이스 수정 및 사용자 로그인을 용이하게 하기 위해 구성 파일을 추가하세요. . .

jdbc.properties(구성 파일 이름)

driverName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/testjdbc
userName=root
password=root

로그인 후 복사

구성 파일 작성 시 공백, 따옴표 등을 사용할 수 없다는 점에 유의하세요.

Tool 클래스: 향상된 코드 재사용성

100

101

102

package com.baidu.emp.utils;
 
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;
 
import org.junit.Test;
 
 
 
public class JdbcUtils {
 
    static String driverClassName;
    static String url;
    static String user;
    static String password;
 
    static {
        // 创建配置文件对象
        Properties properties = new Properties();
        // 加载配置文件输入流
        InputStream inputStream = JdbcUtils.class.getClassLoader().getResourceAsStream("jdbc.properties");
        // 重新加载配置文件
        try {
            properties.load(inputStream);
            // 获取配置文件的值
            driverClassName = properties.getProperty("driverName");
            url = properties.getProperty("url");
            user = properties.getProperty("userName");
            password = properties.getProperty("password");
            Class.forName(driverClassName);
 
        } catch (Exception e) {
            // 抛出异常
            throw new RuntimeException(e);
        }
    }
 
    /**
     * 获取连接
     */
    @Test
    public void testName() throws Exception {
         
        System.out.println(driverClassName);
    }
    public static Connection getConnection() {
        Connection connection = null;
        try {
            connection = DriverManager.getConnection(url, user, password);
        } catch (SQLException e) {
            // 抛出异常
            throw new RuntimeException(e);
        }
        return connection;
    }
 
    /**
     * 关闭链接，释放资源
     */
    public static void close(Connection connection, PreparedStatement statement, ResultSet resultSet) {
 
        try {
            if (resultSet != null) {
                resultSet.close();
            }
            resultSet = null; // 垃圾及时清除
            //注意，不要弄成死循环
            close(connection, statement);
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
 
    }
 
    /**
     * 增删改释放资源
     */
    public static void close(Connection connection, PreparedStatement statement) {
 
        try {
            if (connection != null) {
                connection.close();
            }
                 
            connection = null;
            if (statement != null) {
                statement.close();
            }
            statement = null;
 
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
 
    }
 
}

로그인 후 복사

추가, 삭제, 수정 테스트 그리고 확인합니다:

100

101

102

103

104

105

106

107

108

109

110

111

112

113

package com.baidu.emp.jdbcTest;
 
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
 
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
 
import com.baidu.emp.utils.JdbcUtils;
 
/**
 * 使用jdbcUtils连接数据库进行增删改查
 * 
 * @author Admin
 *
 */
public class Test003 {
 
    // 初始化值
    Connection connection = null;
    PreparedStatement statement = null;
    ResultSet result = null;
 
    @Before
    public void start() throws Exception {
        // 创建链接
        connection = JdbcUtils.getConnection();
        System.out.println("创建链接");
    }
 
    @After
    public void end() throws Exception {
        // 关闭链接
        JdbcUtils.close(connection, statement, result);
        System.out.println("关闭链接");
    }
     
    /**
     *插入数据
     * @throws Exception
     */
    @Test
    public void add() throws Exception {
        String sql = "insert into test01 values(null,?)";
        statement = connection.prepareStatement(sql);
        statement.setString(1, "李四");
        int result = statement.executeUpdate();
        if (result!=0) {
            System.out.println("添加成功");
        }
    }
    /**
     * 删除数据
     * @throws Exception
     */
    @Test
    public void del() throws Exception {
        String sql = "delete from test01 where id =?";
        statement = connection.prepareStatement(sql);
        statement.setInt(1,3);
        int result = statement.executeUpdate();
        if (result!=0) {
            System.out.println("删除成功");
        }
    }
    /**
     * 修改数据
     * @throws Exception
     */
    @Test
    public void change() throws Exception {
        String sql = "update test01 set name = ? where id = ?";
        statement = connection.prepareStatement(sql);
        statement.setString(1, "张飞");
        statement.setInt(2, 2);
        int result = statement.executeUpdate();
        if (result!=0) {
            System.out.println("修改成功");
        }
    }
     
    /**
     * 查询全部数据
     * @throws Exception
     */
    @Test
    public void findAll() throws Exception {
        String sql = "select id , name from test01";
        statement = connection.prepareStatement(sql);
        result = statement.executeQuery();
        if (result.next()) {
            System.out.println("查询成功");
        }
    }
     
    /**
     * 条件查询数据
     * @throws Exception
     */
    @Test
    public void findOne() throws Exception {
        String sql = "select id , name from test01 where id = ?";
        statement = connection.prepareStatement(sql);
        statement.setInt(1, 2);
        result = statement.executeQuery();
        if (result.next()) {
            System.out.println("查询成功");
        }
    }
 
}