JDBC+MYSQL初始学习

一、学习准备

Eclipse 开发工具 + mysql数据库+navicat 数据库连接工具

Mysql的数据库连接驱动jar包 + testing测试集成+maven工具集成

Jar的获取方法：

1、直接下载需要的jar，导入项目中使用。

2、在maven工程中加入依赖：本文使用的maven依赖：

<dependency>

            <groupId>mysql</groupId>

            <artifactId>mysql-connector-java</artifactId>

            <version>5.1.38</version>

</dependency>

<dependency>

            <groupId>org.testng</groupId>

            <artifactId>testng</artifactId>

            <version>6.0</version>

</dependency>

二、JDBC简单实用步骤：

Jdbc连接数据库操作，主要分为三个步骤：本文以mysql为例操作说明：

2.1加载驱动程序

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

2.2获取数据库连接

conn = DriverManager.getConnection(URL, USER, PASSWORD);

2.3对数据库的表结构进行CURD操作

三、JDBC增、删、改、查

3.1 通过navicat 连接本地mysql 创建user表结构：

3.2 建立相关的类来实现jdbc的crud的操作

3.1.1 模型类User

　　User类用于和数据库user表映射，方便CURD的实时操作。

/**

 *

 */

package com.lilin.maven.service.jdbc;

/**

 * @author lilin

 *

 */

public class User {

    private Integer id;

    /**

     * 用户名称

     */

    private String name;

    /**

     * 用户密码

     */

    private String password;

    public String getName() {

        return name;

    }

    public void setName(String name) {

        this.name = name;

    }

    public String getPassword() {

        return password;

    }

    public void setPassword(String password) {

        this.password = password;

    }

    public Integer getId() {

        return id;

    }

    public void setId(Integer id) {

        this.id = id;

    }

    public String toString() {

        return "user 的名称是" + name + " user的密码是：" + password;

    }

}

3.1.2 工具类JdbcUtil

　　工具类主要定义了数据库连接的相关属性：URL 、USER、PASSWORD

　　工具类在静态块中获取了数据库的连接，存放于私有CONN中，同时对外提供了访问连接的公共方法：getConnection

/**

 *

 */

package com.lilin.maven.service.jdbc;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

/**

 * @author lilin

 *

 */

public class JdbcUtil {

    public static final String URL = "jdbc:mysql://127.0.0.1:3306/test";

    public static final String USER = "root";

    public static final String PASSWORD = "1";

    private static Connection conn = null;

    /**

     * 静态块 获取数据库的连接

     */

    static {

        try {

            // 1.加载驱动程序

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

            // 2.获取数据库连接

            conn = DriverManager.getConnection(URL, USER, PASSWORD);

        } catch (ClassNotFoundException e) {

            e.printStackTrace();

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

    /**

     * 提供获取连接的调用方法

     *

     * @return

     */

    public static Connection getConnection() {

        return conn;

    }

}

3.1.3 逻辑层类UserService

　　UserService类，主要是通过调用工具类，获取数据库连接，然后使用连接，配合好编写的sql语句，来对数据库中的user表来进行CURD操作，包含了一系列的常用的处理。

/**

 *

 */

package com.lilin.maven.service.jdbc;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.Statement;

import java.util.ArrayList;

import java.util.List;

/**

 * @author lilin

 *

 */

public class UserService {

    private Connection connection = JdbcUtil.getConnection();

    /**

     * 新增用户信息

     *

     * @param user

     * @throws Exception

     */

    public void addUser(User user) throws Exception {

        String sql = " insert into user(NAME,PASS_WORD)values(?,?)";

        // 预编译sql语句 在excute的时候真正执行

        PreparedStatement ptmt = connection.prepareStatement(sql);

        // 传递参数 补充完整的sql

        ptmt.setString(1, user.getName());

        ptmt.setString(2, user.getPassword());

        ptmt.execute();

    }

    /**

     * 删除用户信息

     *

     * @param user

     * @throws Exception

     */

    public void deleteUser(Integer id) throws Exception {

        String sql = " delete from user where ID=?";

        // 预编译sql语句 在excute的时候真正执行

        PreparedStatement ptmt = connection.prepareStatement(sql);

        // 传递参数 补充完整的sql

        ptmt.setInt(1, id);

        ptmt.execute();

    }

    /**

     * 更新用户信息

     *

     * @param user

     * @throws Exception

     */

    public void updateUser(User user) throws Exception {

        String sql = " update user set NAME=? ,PASS_WORD=? where ID=?";

        // 预编译sql语句 在excute的时候真正执行

        PreparedStatement ptmt = connection.prepareStatement(sql);

        // 传递参数 补充完整的sql

        ptmt.setInt(3, user.getId());

        ptmt.setString(1, user.getName());

        ptmt.setString(2, user.getPassword());

        ptmt.execute();

    }

    /**

     * 查询单个用户信息

     *

     * @param user

     * @throws Exception

     */

    public User getUserByName(String name) throws Exception {

        String sql = " select * from  user where NAME=?";

        // 预编译sql语句 在excute的时候真正执行

        PreparedStatement ptmt = connection.prepareStatement(sql);

        // 传递参数 补充完整的sql

        ptmt.setString(1, name);

        ResultSet resultSet = ptmt.executeQuery();

        User user = null;

        while (resultSet.next()) {

            user = new User();

            user.setId(resultSet.getInt("ID"));

            user.setName(resultSet.getString("NAME"));

            user.setPassword(resultSet.getString("PASS_WORD"));

        }

        return user;

    }

    /**

     * 查询所有的用户信息

     *

     * @return

     * @throws Exception

     */

    public List<User> getUsers() throws Exception {

        // 3.操作数据库 实现增删改查

        Statement statement = connection.createStatement();

        ResultSet resultSet = statement.executeQuery("select * from user");

        List<User> list = new ArrayList<User>();

        User user = null;

        while (resultSet.next()) {

            user = new User();

            String name = resultSet.getString("NAME");

            String passWord = resultSet.getString("PASS_WORD");

            user.setName(name);

            user.setPassword(passWord);

            list.add(user);

        }

        return list;

    }

}

3.1.4 testNG测试类 jdbctest

　　JdbcTest中，实现了多个测试方法，userserice中的CURD的方法，全部有对应的测试function：通过运行测试方法，以及配合使用navicat实时查询数据库的user表的数据的实时变化，以便于验证JDBC对于mysql的数据库操作的正确性。

/**

 *

 */

package com.lilin.maven.service.jdbc;

import java.util.List;

import java.util.Scanner;

import org.testng.annotations.Test;

/**

 * @author lilin

 *

 */

public class JdbcTest {

    private UserService userService = new UserService();

    @Test

    public void testGetUsers() throws Exception {

        List<User> users = userService.getUsers();

        for (User user : users) {

            System.out.println(user);

        }

    }

    @Test

    public void testAddUser() throws Exception {

        User user = new User();

        user.setName("李林");

        user.setPassword("12345");

        userService.addUser(user);

    }

    @Test

    public void testUpdateUser() throws Exception {

        User user = new User();

        user.setId(1);

        user.setName("bb");

        user.setPassword("12345");

        userService.updateUser(user);

    }

    @Test

    public void testDeleteUser() throws Exception {

        userService.deleteUser(4);

    }

    @Test

    public void testgetUserByName() throws Exception {

        User user = userService.getUserByName("bb");

        System.out.println(user);

    }

}

巴特西

JDBC+MYSQL初始学习