安科网

2020想学习JAVA的同学看过来，最基础的编程CRUD你会了没？

lifeison

lifeison

2020-07-26

关注 关注

一 JDBC简介

Java DataBase Connectivity Java语言连接数据库

官方(Sun公司)定义的一套操作所有关系型数据库的规则(接口) 各个数据库厂商去实现这套接口 提供数据库驱动JAR包 可以使用这套接口(JDBC)编程 真正执行的代码是驱动JAR包中的实现类

二 JDBC初体验

1. 新建一个Maven项目

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.hy.jdbc</groupId>
    <artifactId>jdbc-demo</artifactId>
    <version>1.0-SNAPSHOT</version>

    <!-- 定义依赖版本号 -->
    <properties>
        <junit.version>4.12</junit.version>
        <mysql-connector-java.version>8.0.11</mysql-connector-java.version>
        <druid.version>1.1.10</druid.version>
    </properties>

    <!-- 管理jar版本号 -->
    <dependencyManagement>
        <dependencies>
            <!-- junit -->
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>${junit.version}</version>
            </dependency>
            <!-- mysql -->
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>${mysql-connector-java.version}</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid</artifactId>
                <version>${druid.version}</version>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <dependencies>
        <!-- junit -->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
        </dependency>
        <!-- mysql -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
        </dependency>
    </dependencies>
</project>

sql

CREATE TABLE account (
    aid INT PRIMARY KEY,
    aname VARCHAR(100),
    amoney DOUBLE
);

2. 插入

@Test
public void test01() {
    Connection connection = null;
    PreparedStatement statement = null;
    try {
        // 注册驱动 MySQL5之后的驱动JAR包可以省略该步骤
        Class.forName("com.mysql.cj.jdbc.Driver");
        // 获取数据库连接对象 Connection
        connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/demo_hy", "root", "root");
        // 开启事务
        connection.setAutoCommit(false);
        // 定义SQL
        String sql = "insert into account values(?, ?, ?)";
        // 获取执行SQL的对象 PreparedStatement
        statement = connection.prepareStatement(sql);
        // 设置参数
        statement.setInt(1, 1); //‘?‘ 位置的编号 从1开始
        statement.setString(2, "No1"); //‘?‘ 位置的编号 从1开始
        statement.setDouble(3, 2000); //‘?‘ 位置的编号 从1开始
        // 执行SQL 返回受影响的行数
        int count = statement.executeUpdate();
        // 提交事务
        connection.commit();
        // 处理结果
        System.out.println("count = " + count);

    } catch (Exception e) {
        e.printStackTrace();
        // 回滚事务
        if (null != connection) {
            try {
                connection.rollback();
            } catch (SQLException exception) {
                exception.printStackTrace();
            }
        }

    } finally {
        // 释放资源
        if (null != statement) {
            try {
                statement.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if (null != connection) {
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

3. 删除

@Test
public void test02() {
    Connection connection = null;
    PreparedStatement statement = null;
    try {
        // 注册驱动 MySQL5之后的驱动JAR包可以省略该步骤
        //Class.forName("com.mysql.cj.jdbc.Driver");
        // 获取数据库连接对象 Connection
        connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/demo_hy", "root", "root");
        // 开启事务
        connection.setAutoCommit(false);
        // 定义SQL
        String sql = "delete from account where aid = ?";
        // 获取执行SQL的对象 PreparedStatement
        statement = connection.prepareStatement(sql);
        // 设置参数
        statement.setInt(1, 1); //‘?‘ 位置的编号 从1开始
        // 执行SQL 返回受影响的行数
        int count = statement.executeUpdate();
        // 提交事务
        connection.commit();
        // 处理结果
        System.out.println("count = " + count);

    } catch (Exception e) {
        e.printStackTrace();
        // 回滚事务
        if (null != connection) {
            try {
                connection.rollback();
            } catch (SQLException exception) {
                exception.printStackTrace();
            }
        }

    } finally {
        // 释放资源
        if (null != statement) {
            try {
                statement.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if (null != connection) {
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

4. 修改

@Test
public void test03() {
    Connection connection = null;
    PreparedStatement statement1 = null;
    PreparedStatement statement2 = null;
    try {
        // 注册驱动 MySQL5之后的驱动JAR包可以省略该步骤
        Class.forName("com.mysql.cj.jdbc.Driver");
        // 获取数据库连接对象 Connection
        connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/demo_hy", "root", "root");
        // 开启事务
        connection.setAutoCommit(false);
        // 定义SQL
        String sql1 = "update account set amoney = amoney + ? where aid = ?";
        String sql2 = "update account set amoney = amoney - ? where aid = ?";
        // 获取执行SQL的对象 PreparedStatement
        statement1 = connection.prepareStatement(sql1);
        statement2 = connection.prepareStatement(sql2);
        // 设置参数
        statement1.setDouble(1, 500); //‘?‘ 位置的编号 从1开始
        statement1.setInt(2, 1); //‘?‘ 位置的编号 从1开始
        statement2.setDouble(1, 500); //‘?‘ 位置的编号 从1开始
        statement2.setInt(2, 2); //‘?‘ 位置的编号 从1开始
        // 执行SQL 返回受影响的行数
        statement1.executeUpdate();
        int i = 3 / 0; //模拟异常
        statement2.executeUpdate();
        // 提交事务
        connection.commit();

    } catch (Exception e) {
        e.printStackTrace();
        // 回滚事务
        if (null != connection) {
            try {
                connection.rollback();
            } catch (SQLException exception) {
                exception.printStackTrace();
            }
        }

    } finally {
        // 释放资源
        if (null != statement2) {
            try {
                statement2.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if (null != statement1) {
            try {
                statement1.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if (null != connection) {
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

5. 查询

@Test
public void test04() {
    Connection connection = null;
    PreparedStatement statement = null;
    ResultSet resultSet = null;
    try {
        // 注册驱动 MySQL5之后的驱动JAR包可以省略该步骤
        Class.forName("com.mysql.cj.jdbc.Driver");
        // 获取数据库连接对象 Connection
        connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/demo_hy", "root", "root");
        // 开启事务
        connection.setAutoCommit(false);
        // 定义SQL
        String sql = "select * from account";
        // 获取执行SQL的对象 PreparedStatement
        statement = connection.prepareStatement(sql);
        // 执行SQL 返回结果集
        resultSet = statement.executeQuery();
        // 提交事务
        connection.commit();
        // 处理结果
        while (resultSet.next()) {
            int id = resultSet.getInt(1); //代表列的编号 从1开始
            String name = resultSet.getString("aname"); //代表列的名称
            double money = resultSet.getDouble(3); //代表列的编号 从1开始
            System.out.println(id + "---" + name + "---" + money);
        }

    } catch (Exception e) {
        e.printStackTrace();
        // 回滚事务
        if (null != connection) {
            try {
                connection.rollback();
            } catch (SQLException exception) {
                exception.printStackTrace();
            }
        }

    } finally {
        // 释放资源
        if (null != resultSet) {
            try {
                resultSet.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if (null != statement) {
            try {
                statement.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if (null != connection) {
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

三 数据库连接池

一个存放数据库连接的容器

当系统初始化后 容器被创建 容器中会申请一些连接对象 当用户访问数据库时 从容器中获取连接对象 用户访问完之后 会将连接对象归还给容器 这样可以节约资源 提高访问效率

常见的数据库连接池有 Druid C3P0...

Druid初体验

druid.properties

url=jdbc:mysql://localhost:3306/demo_hy
driverClassName=com.mysql.cj.jdbc.Driver
username=root
password=root
maxActive=10
minIdle=5

XTest.java

@Test
public void test05() {
    InputStream stream = null;
    Connection connection = null;
    PreparedStatement statement = null;
    ResultSet resultSet = null;
    try {
        // 加载配置文件
        Properties properties = new Properties();
        stream = XTest.class.getClassLoader().getResourceAsStream("druid.properties");
        properties.load(stream);
        // 获取连接池对象
        DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
        // 获取数据库连接对象 Connection
        connection = dataSource.getConnection();
        // 开启事务
        connection.setAutoCommit(false);
        // 定义SQL
        String sql = "select * from account";
        // 获取执行SQL的对象 PreparedStatement
        statement = connection.prepareStatement(sql);
        // 执行SQL 返回结果集
        resultSet = statement.executeQuery();
        // 提交事务
        connection.commit();
        // 处理结果
        while (resultSet.next()) {
            int id = resultSet.getInt(1); //代表列的编号 从1开始
            String name = resultSet.getString("aname"); //代表列的名称
            double money = resultSet.getDouble(3); //代表列的编号 从1开始
            System.out.println(id + "---" + name + "---" + money);
        }

    } catch (Exception e) {
        e.printStackTrace();
        // 回滚事务
        if (null != connection) {
            try {
                connection.rollback();
            } catch (SQLException exception) {
                exception.printStackTrace();
            }
        }

    } finally {
        // 释放资源
        if (null != resultSet) {
            try {
                resultSet.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if (null != statement) {
            try {
                statement.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if (null != connection) {
            try {
                connection.close(); //归还连接
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if (null != stream) {
            try {
                stream.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

最后

学习java不易，需要持续的坚持，如果有想学习java的基础知识或者进阶java的可以私信“学习”获取学习联系方式

2020想学习JAVA的同学看过来，最基础的编程CRUD你会了没？

mysql数据库 mysql

lifeison

lifeison

0 关注 0 粉丝 0 动态

关注 关注

相关推荐

MySQL主从复制原理以及需要注意的地方

最近在写Mycat专题，由于不少小伙伴最近要出去面试，问我能不能简单写下MySQL的主从复制原理和注意事项，因为在之前的面试中被问到了这些问题。 Master 将数据改变记录到二进制日志中，也就是配置文件 log-bin 指定的文件， 这些记录叫做二进制日

emmm00 2020-11-17

Mysql联表update数据的示例详解

在MySQL中，可以在 UPDATE语句 中使用JOIN子句执行跨表更新。employees表将存储在员工编号，姓名，工作表现和工资的数据。employees 和 merits 表之间以是 performance 字段相关联的。对于 employees 表

王艺强 2020-11-17

mysql 8.0.22 安装配置图文教程

解压后的目录并没有的my.ini文件，没关系可以自行创建在安装根目录下添加的my.ini ，写入基本配置：。# 允许连接失败的次数。初始化MySQL，在安装时，避免权限问题出错我们尽量使用管理员身份运行CMD，否则在安装时会报错，会导致安装失败的情况，如下

aydh 2020-11-12

MySQL用truncate命令快速清空一个数据库中的所有表

用文本编辑器把每条truncate语句前后的“|”替换为空字符，方便后面一次复制多条执行。truncate与drop是DDL语句，执行后无法回滚；delete是DML语句，可回滚。truncate会清空表中的所有行，但表结构及其约束、索引等保持不变；dro

世樹 2020-11-11

修改MySQL8.0 默认的数据目录(快捷操作无配置)

使用场景：我们使用的是阿里云，单独购买了数据盘，MySQL 8.0 数据库默认装在系统盘上，为了考虑安全性和空间问题，我们需要将默认的数据库目录更改到其它位置。操作系统：CentOS 7.6 数据库：MySQL 8.0 查看我本人更多原创文章，请点击

zry 2020-11-11

阿里云服务器安装Mysql数据库的详细教程

由于在学习过程中需要安装zookeeper，我的虚拟机一直有问题，就够买了阿里云服务器。安装完zookeeper后想着把数据库也安装在服务器上，释放一下电脑的压力，在安装数据库的时候遇到了很多问题，通过查看有些大佬的作品终于安装好了数据库。现在就我遇到的问

URML 2020-11-11

MySQL中的undo日志

我们知道，MySQL中的redo日志记录了事务的行为，在服务器宕机的时候，可以通过重做事务来达到恢复数据的目的，然而，有的时候，事务还有回滚的需求，也就是说，我们需要知道某条在变成当前情况之前的样子，这种情况下，undo日志就派上用场了。也就是说，undo

spurity 2020-11-10

php7连接MySQL实现简易查询程序的方法

假设我们制作的是分班情况查询程序，将使用PHP7的环境以PDO的方式连接MySQL。通过学号和姓名查询自己所在班级。准备就绪，开始吧，现在！echo "<tr><th>学号</th><th>姓名&l

yifangs 2020-10-13

JDBC连接MySQL

String sql = "select * from users where name=?String id = rs.getString;//1代表数据库中表的列数，id在第一列也可以！！！

Andrea0 2020-09-18

Uber为什么放弃Postgres选择迁移到MySQL？

Uber 的早期架构包含了一个用 Python 开发的单体后端应用程序，这个应用程序使用 Postgres 作为数据存储。从那个时候开始，Uber 的架构已经发生了巨大变化，变成了微服务，并采用新的数据平台模型。具体地说，之前使用 Postgres 的地方

Ida 2020-09-16

聊聊MySQL中的参数

在前面一些文章中，经常能看到介绍某某参数的作用，可能有些小伙伴仍搞不清楚 MySQL 参数是啥。我们所说的参数在官方文档中称为 系统变量，不同的变量有着不同的作用。MySQL 服务端维护了许多表示其配置的系统变量，所有变量均有默认值。若会话变量未单独设置，

ltd00 2020-09-12

shell脚本定时备份MySQL数据库数据并保留指定时间

公司用到的MySQL数据库，经常有同事通过一顿骚操作把一些关键的配置数据误删，每次恢复都要花上不少时间，于是写了个shell脚本，结合corntab每天凌晨备份数据库，并保留7天。同样的备份脚本也可用于生产环境MySQL数据库定时备份。上述脚本中指定了要备

tufeiax 2020-09-03

Mysql误删数据解决方案及kill语句原理

使用flashback工具闪回，把数据恢复回来。原理是修改binlog的内容，拿回原库重放，需要确保binlog_format=row和binlog_row_imsge=Full. 如果是insert，将binlog event类型是write_rows

xjd0 2020-09-10

MySQL 如何修改root用户的密码

mysql> set password for 用户名@localhost = password;关闭正在运行的MySQL服务。打开DOS窗口，转到mysql\bin目录。--skip-grant-tables的意思是启动MySQL服务的时候跳过权限

greatboylc 2020-09-10

通过实例解析MySql CURRENT_TIMESTAMP函数

`text` varchar DEFAULT '' COMMENT '内容',那么如何设置一个具体的默认时间呢？

adsadadaddadasda 2020-09-08

mysql主从复制配置过程

配置完毕后，重启数据库： service mysqld restart. 通过phpmyadmin，添加新用户，并授予REPLICATION SLAVE权限。或者通过root用户登录到mysql，赋予权限：。其中repl是用户名，password是该用户的

疯狂老司机 2020-09-08

mysql如何将表结构导出到excel

导出表的结构，和字段备注信息，表名等。不需要借用第三方工具即可实现。我这里懒得一个个改了，效果已经达到。

coinone 2020-09-08

MySQL 数据库如何解决高并发问题

我们都知道初创公司一开始都是以单体应用为首要架构，一般都是单体单库的形式。但是版本以及版本的迭代，数据库需要承受更多的高并发已经成了 架构设计 需要考虑的点。高并发的情况下，可以将多个请求的查询合在一次进行，以减少对数据库的访问速度。我们都知道，只要数据库

sunnyxuebuhui 2020-09-07

MySQL中文乱码问题解决方案

编辑vi /etc/my.cnf 文件，添加图中标记三行。查看表的设计表中的字符集

menshen 2020-09-05

MySQL 参数相关概念及查询更改方法

在前面一些文章中，经常能看到介绍某某参数的作用，可能有些小伙伴仍搞不清楚 MySQL 参数是啥。我们所说的参数在官方文档中称为 系统变量 ，不同的变量有着不同的作用。MySQL 服务端维护了许多表示其配置的系统变量，所有变量均有默认值。若会话变量未单独设置

waveclouds 2020-09-04
lifeison

lifeison

W3CSchool教程
HTML 教程
CSS 教程
Bootstrap 教程
Javascript 教程
jQuery 教程
后端教程
C 教程
Java 教程
PHP 教程
Python 教程
Go 教程
移动开发
Android 教程
Swift 教程
Kotlin 教程
jQuery Mobile 教程
ionic 教程
关于我们
新闻动态
联系方式
招聘英才
安科实验室
帮助与反馈

安科网(Ancii)，中国第一极客网

Copyright © 2013 - 2019 Ancii.com

京ICP备18063983号 京公网安备11010802014868号