null - 程序员宅基地

MySQL学习之JDBC（5）_mysql5的jdbc语句-程序员宅基地

技术标签：数据库

1.JDBC是什么

JDBC（Java Database Connectivity）Java数据库连接，是Java语言用来规范客户端程序访问数据库的应用程序接口（API），提供了数据库操作的方法。

2.JDBC怎么用

2.1.导入JDBC的jar包

一般我们使用maven构建项目，引入JDBC的依赖：

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.18</version>
</dependency>

2.2.代码实现

步骤为：

注册驱动
建立连接
执行SQL
获取结果
关闭连接

import java.sql.*;

public class TestJDBC {
    
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
    
        //注册驱动
        Class.forName("com.mysql.cj.jdbc.Driver");

        //建立连接
        Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/myemployees?serverTimezone=Asia/Shanghai", "root", "root");

        //执行sql
        Statement statement = conn.createStatement();
        String sql = "SELECT id,name,department_id,salary,phone_number FROM t_employee";
        ResultSet rs = statement.executeQuery(sql);

        //获取结果
        while (rs.next()) {
    
            int id = rs.getInt("id");
            String name = rs.getString("name");
            int department_id = rs.getInt("department_id");
            double salary = rs.getDouble("salary");
            String phone_number = rs.getString("phone_number");
            System.out.println("[id="+id+", name="+name+", department_id="+department_id+", salary="+salary+", phone_number="+phone_number+"]");
        }

        //关闭连接
        rs.close();
        statement.close();
        conn.close();
    }
}

执行结果：
在这里插入图片描述
直接执行sql语句的结果：

3.JDBC详解

数据库建立连接形式比较固定，这里主要说“执行sql”和“获取结果”这个两个比较重要的部分。

3.1.执行sql

3.1.1.Statement对象

之前的案例中我们通过数据库连接获取一个statement，该statement无法传入参数，只能执行静态的SQL语句。
获取方式：

try{
    
	Statement statement = conn.createStatement();
	...
} catch(SQLException e) {
    
	...
}

Statement主要方法如下：

方法名	用法
boolean execute(String sql)	如果返回的结果集可以进行遍历则为true，反之为false
int executeUpdate(String sql)	主要执行INSERT、UPDATE和DELETE语句，返回值为sql语句影响的行数
ResultSet executeQuery(String sql)	执行SELECT语句返回结果集

3.1.2.PreparedStatement对象

为了执行动态的sql语句，我们有了PreparedStatement，预编译Statement。
获取方式：

try{
    
        PreparedStatement ps = conn.prepareStatement("SELECT id,name,department_id,salary,phone_number FROM t_employee WHERE id = ?");
	...
} catch(SQLException e) {
    
	...
}

该sql中我们发现了一个新的符号?，这就是占位符，再后续会赋予占位符具体的值。
常用方法和Statement一样，只不过多了一个设置占位符的值，通过以下案例进行实践操作：

import java.sql.*;

public class TestJDBC {
    
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
    
        //注册驱动
        Class.forName("com.mysql.cj.jdbc.Driver");

        //建立连接
        Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/myemployees?serverTimezone=Asia/Shanghai", "root", "root");

        //执行sql
        String sql = "SELECT id,name,department_id,salary,phone_number FROM t_employee WHERE id = ?";
        PreparedStatement ps = conn.prepareStatement(sql);
        ps.setInt(1, 1);
        ResultSet rs = ps.executeQuery();

        //获取结果
        while (rs.next()) {
    
            int id = rs.getInt("id");
            String name = rs.getString("name");
            int department_id = rs.getInt("department_id");
            double salary = rs.getDouble("salary");
            String phone_number = rs.getString("phone_number");
            System.out.println("[id="+id+", name="+name+", department_id="+department_id+", salary="+salary+", phone_number="+phone_number+"]");
        }

        //关闭连接
        rs.close();
        ps.close();
        conn.close();
    }
}

执行结果：
在这里插入图片描述
我们使用ps.setXxx(index, value)对占位符进行赋值，index就是第几个占位符，从1开始计数。

3.1.3.事务

和命令行操作数据库一样，这里如果使用事务，需要关闭事务的自动提交：

conn.setAutoCommit(false);

事务的提交、回滚和设置保存点：

conn.commit();
conn.rollback([String savepoint_name]);
conn.setSavepoint(String savepoint_name);

3.1.4.批处理

为了提升sql执行效率、减少通信的资源消耗，一次发送多个sql进行执行大大的提升了性能。

# 将sql加入批处理
statement.addBatch(String sql);

# 执行批处理，返回结果为每条sql语句影响的行数
int[] rel = statement.executeBatch();

当然一次执行多条sql语句，如果使用事务效果会更好。

3.2.获取结果

结果集类型取决于获取statement的方法参数：

Statement createStatement(int resultSetType, int resultSetConcurrency) throws SQLException;
PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency) throws SQLException;

resultSetType可选值有：

ResultSet.TYPE_FORWARD_ONLY：光标只能在结果集中向前移动，默认；
ResultSet.TYPE_SCROLL_INSENSITIVE：光标可以前后移动，其他的操作不会影响结果集数据；
ResultSet.TYPE_SCROLL_SENSITIVE：光标可以前后移动，其他的操作会影响结果集数据。

resultSetConcurrency可选值有：

ResultSet.CONCUR_READ_ONLY：只读结果集，默认；
ResultSet.CONCUR_UPDATABLE：可修改的结果集。

所以在无参数创建的statement获取结果集时，只能通过rs.next()将光标向前移动。
从结果集中获取数据：

# getXxx(...);获取指定指定列索引（索引值从1开始计数）或列名的值，Xxx表示数据类型
int getInt(int columnIndex) throws SQLException;
int getInt(String columnLabel) throws SQLException;

更新结果集中的数据：

# updateXxx(...);和获取类似
void updateInt(int columnIndex, int x) throws SQLException;
void updateInt(String columnLabel, int x) throws SQLException;

4.提升

当我们每次执行sql时都需要从开始步骤到建立连接池，这明显降低了性能，增加了通信资源消耗，数据库连接池就上场了，和线程池效果类似吧。

4.1.创建配置文件db.properties

jdbcDriver=com.mysql.cj.jdbc.Driver
jdbcUrl="jdbc:mysql://localhost:3306/myemployees?serverTimezone=Asia/Shanghai"
jdbcUsername="root"
jdbcPassword="root"
initPoolSize=5
maxPoolSize=10

4.2.创建JDBC连接获取工具类JdbcUtil

package com.liquor;

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

/**
 * JDBC连接池
 * @author by liwei
 * @email [email protected]
 * @create at 2020-08-14-15:47
 **/
public class JdbcUtil {
    

    private static LinkedList<Connection> pool = new LinkedList<Connection>();

    //一般这些属性从配置文件中获取
    private static String driver;
    private static String url;
    private static String username;
    private static String password;
    private static int initPoolSize;
    private static int maxPoolSize;

    static {
    
        try {
    
            Properties prop = new Properties();
            InputStream is = JdbcUtil.class.getClassLoader().getResourceAsStream("db.properties");
            prop.load(is);

            driver = prop.getProperty("jdbcDriver");
            url = prop.getProperty("jdbcUrl");
            username = prop.getProperty("jdbcUsername");
            password = prop.getProperty("jdbcPassword");
            initPoolSize = Integer.valueOf(prop.getProperty("initPoolSize"));
            maxPoolSize = Integer.valueOf(prop.getProperty("maxPoolSize"));
        } catch (IOException e) {
    
            e.printStackTrace();
        }
    }

    /**
     * 获取连接
     * @return
     */
    public static Connection getConnection() {
    
        Connection conn = null;
        try {
    
            Class.forName(driver);
            conn = DriverManager.getConnection(url, username, password);
        } catch (ClassNotFoundException e) {
    
            e.printStackTrace();
        } catch (SQLException e) {
    
            e.printStackTrace();
        }
        return null;
    }

    /**
     * 释放资源
     * @param conn
     * @param statement
     * @param rs
     */
    public static void closeConnection(Connection conn, Statement statement, ResultSet rs) {
    
        if (rs != null) {
    
            try {
    
                rs.close();
            } catch (SQLException e) {
    
                e.printStackTrace();
            }
        }
        if (statement != null) {
    
            try {
    
                statement.close();
            } catch (SQLException e) {
    
                e.printStackTrace();
            }
        }
        if (conn != null) {
    
            try {
    
                conn.close();
            } catch (SQLException e) {
    
                e.printStackTrace();
            }
        }
    }
}

从配置文件中读取数据库配置然后获取数据库连接。

4.3.创建数据库连接池

import javax.sql.DataSource;
import java.io.PrintWriter;
import java.sql.*;
import java.util.LinkedList;
import java.util.logging.Logger;

public class DataSourcePool implements DataSource {
    
	//存放数据库连接
    private static LinkedList<Connection> conns = new LinkedList<Connection>();

    static {
    
        for (int i = 0 ; i < 5; i++) {
    
            Connection conn = JdbcUtil.getConnection();
            conns.add(conn);
        }
    }

    /**
     * 获取连接
     * @return
     * @throws SQLException
     */
    public Connection getConnection() throws SQLException {
    
        Connection conn = null;
        if (conns.size() == 0) {
    
            for (int i = 0 ; i < 5; i++) {
    
                conn = JdbcUtil.getConnection();
                conns.add(conn);
            }
        }
        conn = conns.remove(0);
        return conn;
    }

    /**
     * 连接使用完后归还
     * @param conn
     */
    public void backConn(Connection conn) {
    
        conns.add(conn);
    }
    public void backConn(Connection conn, Statement statement, ResultSet rs) {
    
        if (rs != null) {
    
            try {
    
                rs.close();
            } catch (SQLException e) {
    
                e.printStackTrace();
            }
        }
        if (statement != null) {
    
            try {
    
                statement.close();
            } catch (SQLException e) {
    
                e.printStackTrace();
            }
        }
        conns.add(conn);
    }

    public Connection getConnection(String username, String password) throws SQLException {
    
        return null;
    }

    public <T> T unwrap(Class<T> iface) throws SQLException {
    
        return null;
    }

    public boolean isWrapperFor(Class<?> iface) throws SQLException {
    
        return false;
    }

    public PrintWriter getLogWriter() throws SQLException {
    
        return null;
    }

    public void setLogWriter(PrintWriter out) throws SQLException {
    

    }

    public void setLoginTimeout(int seconds) throws SQLException {
    

    }

    public int getLoginTimeout() throws SQLException {
    
        return 0;
    }

    public Logger getParentLogger() throws SQLFeatureNotSupportedException {
    
        return null;
    }
}

这里我们默认连接数为5。

4.4.测试

import java.sql.*;

public class TestJDBC {
    
    public static void main(String[] args) throws SQLException {
    
        //获取连接
        DataSourcePool pool = new DataSourcePool();

        for (int i = 0; i < 6; i++) {
    
            Connection conn = pool.getConnection();

            //执行sql
            String sql = "SELECT id,name,department_id,salary,phone_number FROM t_employee WHERE id = ?";
            PreparedStatement ps = conn.prepareStatement(sql);
            ps.setInt(1, 1);
            ResultSet rs = ps.executeQuery();

            //获取结果
            while (rs.next()) {
    
                int id = rs.getInt("id");
                String name = rs.getString("name");
                int department_id = rs.getInt("department_id");
                double salary = rs.getDouble("salary");
                String phone_number = rs.getString("phone_number");
                System.out.println("[id="+id+", name="+name+", department_id="+department_id+", salary="+salary+", phone_number="+phone_number+"]");
            }

            //归还连接
            System.out.println(conn);
            pool.backConn(conn, ps, rs);
        }
    }
}

这里我们连续获取6次连接，第6次连接应该和第一次一样就没问题了。
执行结果：
在这里插入图片描述
这是比较简单的数据库连接池，开发中我们一般使用第三方连接池，包含的配置更加全面以及优化更好一些。而后面学习持久层框架后对数据库的操作将会更加简单、开发也快捷不少。

本文链接：https://blog.csdn.net/liquorpp/article/details/108002792

原作者删帖不实内容删帖广告或垃圾文章投诉

智能推荐

c# 调用c++ lib静态库_c#调用lib-程序员宅基地

文章浏览阅读2w次，点赞7次，收藏51次。四个步骤1.创建C++ Win32项目动态库dll 2.在Win32项目动态库中添加外部依赖项 lib头文件和lib库3.导出C接口4.c#调用c++动态库开始你的表演...①创建一个空白的解决方案，在解决方案中添加 Visual C++ , Win32 项目空白解决方案的创建：添加Visual C++ , Win32 项目这......_c#调用lib

deepin/ubuntu安装苹方字体-程序员宅基地

文章浏览阅读4.6k次。苹方字体是苹果系统上的黑体，挺好看的。注重颜值的网站都会使用，例如知乎：font-family: -apple-system, BlinkMacSystemFont, Helvetica Neue, PingFang SC, Microsoft YaHei, Source Han Sans SC, Noto Sans CJK SC, W..._ubuntu pingfang

html表单常见操作汇总_html表单的处理程序有那些-程序员宅基地

文章浏览阅读159次。表单表单概述表单标签表单域按钮控件demo表单标签表单标签基本语法结构<form action="处理数据程序的url地址“ method=”get|post“ name="表单名称”></form><!--method将表单中的数据传送给服务器处理，get方式直接显示在url地址中，数据可以被缓存，且长度有限制；而post方式数据隐藏传输，_html表单的处理程序有那些

PHP设置谷歌验证器（Google Authenticator）实现操作二步验证_php otp 验证器-程序员宅基地

文章浏览阅读1.2k次。使用说明:开启Google的登陆二步验证（即Google Authenticator服务）后用户登陆时需要输入额外由手机客户端生成的一次性密码。实现Google Authenticator功能需要服务器端和客户端的支持。服务器端负责密钥的生成、验证一次性密码是否正确。客户端记录密钥后生成一次性密码。下载谷歌验证类库文件放到项目合适位置(我这边放在项目Vender下面)https://github.com/PHPGangsta/GoogleAuthenticatorPHP代码示例://引入谷_php otp 验证器

【Python】matplotlib.plot画图横坐标混乱及间隔处理_matplotlib更改横轴间距-程序员宅基地

文章浏览阅读4.3k次，点赞5次，收藏11次。matplotlib.plot画图横坐标混乱及间隔处理_matplotlib更改横轴间距

docker — 容器存储_docker 保存容器-程序员宅基地

文章浏览阅读2.2k次。①Storage driver 处理各镜像层及容器层的处理细节，实现了多层数据的堆叠，为用户提供了多层数据合并后的统一视图②所有 Storage driver 都使用可堆叠图像层和写时复制（CoW）策略③docker info 命令可查看当系统上的 storage driver主要用于测试目的，不建议用于生成环境。_docker 保存容器

随便推点

网络拓扑结构_网络拓扑csdn-程序员宅基地

文章浏览阅读834次，点赞27次，收藏13次。网络拓扑结构是指计算机网络中各组件（如计算机、服务器、打印机、路由器、交换机等设备）及其连接线路在物理布局或逻辑构型上的排列形式。这种布局不仅描述了设备间的实际物理连接方式，也决定了数据在网络中流动的路径和方式。不同的网络拓扑结构影响着网络的性能、可靠性、可扩展性及管理维护的难易程度。_网络拓扑csdn

JS重写Date函数，兼容IOS系统_date.prototype 将所有 ios-程序员宅基地

文章浏览阅读1.8k次，点赞5次，收藏8次。IOS系统Date的坑要创建一个指定时间的new Date对象时，通常的做法是：new Date("2020-09-21 11:11:00")这行代码在 PC 端和安卓端都是正常的，而在 iOS 端则会提示 Invalid Date 无效日期。在IOS年月日中间的横岗许换成斜杠，也就是new Date("2020/09/21 11:11:00")通常为了兼容IOS的这个坑，需要做一些额外的特殊处理，笔者在开发的时候经常会忘了兼容IOS系统。所以就想试着重写Date函数，一劳永逸，避免每次ne_date.prototype 将所有 ios