Java入门系列-26-JDBC-低调大师

Java入门系列-26-JDBC

2018-11-13 600

认识 JDBC

JDBC (Java DataBase Connectivity) 是 Java 数据库连接技术的简称，用于连接常用数据库。

Sun 公司提供了 JDBC API ，供程序员调用接口和类，集成在 java.sql 和 javax.sql 包中。

Sun 公司还提供了 DriverManager 类用来管理各种不同的JDBC驱动。

不同数据库厂商提供各自的JDBC驱动，所以我们想要连接数据库除了要了解 JDBC API 还需要下载各数据库厂商的驱动 jar 包。

JDBC API

JDBC API主要用于与数据库建立连接、执行SQL语句、处理结果，其中核心类和接口如下：

DriverManager：依据数据库的不同，管理JDBC驱动
Connection：负责连接数据库并担任传送数据的任务
Statement：由 Connection 产生、负责执行SQL语句
ResultSet:负责保存 Statement 执行后所产生的查询结果

JDBC 编码模板

1、与数据库建立连接并获取连接

Connection connection=DriverManager.getConnection(URL,数据库用户名,密码);

2、发送SQL语句，得到执行结果

Statement stmt=connection.createStatement();
ResultSet rs=stmt.executeQuery(SQL语句);

3、处理返回结果

while(rs.next()){
    int a=rs.getInt("a");
    String b=rs.getString("b");
    Date d=rs.getDate("d");
    ……
}

4、释放资源

rs.close();
stmt.close();
connection.close();

使用 JDBC 连接到 MySQL 数据库

本例适合已经会使用 MySQL 数据库的同学，首先我们下载 JDBC 的驱动 jar 包。这个网址提供了 MySQL 各种语言连接数据库的驱动 https://www.mysql.com/products/connector/,MySQL Connector / J 8.0与从MySQL 5.5开始的所有MySQL版本兼容。
8.0下载地址
下载完成后解压，后将jar添加依赖到项目中。

连接到MySQL数据库

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class DemoConnectMySQL {
    public static void main(String[] args) {
        //连接MySQL的URL
        String url="jdbc:mysql://localhost:3306/mysql?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";
        //MySQL数据库用户名
        String user="root";
        //MySQL数据库的密码
        String password="1234";
        Connection connection=null;
        try {
            connection=DriverManager.getConnection(url, user, password);
            System.out.println("连接成功");
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            try {
                connection.close();
                System.out.println("连接关闭");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

url指定数据库的连接字符串，格式为：

jdbc:数据库://ip或域名:端口号?参数&参数……
这里的参数 useUnicode=true 使用Unicode字符，characterEncoding=utf8 设置编码防止中文乱码，serverTimezone=UTC 设置时区，useSSL=false 不使用SSL

jdbc4.0不需要加载驱动

PreparedStatement 增删改

PreparedStatement 继承了 Statement 接口，表示预编译的 SQL 语句对象，SQL 语句被预编译并存储在 PreparedStatement 对象中，可以使用此对象多次高效地执行该语句。(还避免了 SQL 注入的隐患)

先准备好数据库 books

表 book

字段	类型	属性
id	整数	主键,自增
bName	字符串	非空
price	小数	非空

脚本也准备好了

#创建数据库
CREATE DATABASE books;
USE books;
#创建表
CREATE TABLE book ( 
    id INT primary key    auto_increment, 
    bName VARCHAR ( 255 ) NOT NULL, 
    price FLOAT NOT NULL 
);

PreparedStatement添加数据

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class TestInsert {

    public static void main(String[] args) {
        Connection connection=null;
        PreparedStatement pstmt=null;
        String url="jdbc:mysql://localhost:3306/books?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";
        String user="root";
        String password="1234";
        try {
            connection=DriverManager.getConnection(url,user,password);
            //sql语句
            String sql="insert into book(bName,price) values (?,?)";
            pstmt=connection.prepareStatement(sql);
            //传入参数
            pstmt.setString(1, "《java入门到改行》");
            pstmt.setFloat(2, 11.11f);
            int result=pstmt.executeUpdate();
            System.out.println("受影响行数："+result);
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            if (pstmt!=null) {
                try {
                    pstmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (connection!=null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

说明：

1、连接字符串要修改数据库名字为 books

String url="jdbc:mysql://localhost:3306/books?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";

2、插入数据库的数据不能拼接而是要用 ? 代替

String sql="insert into book(bName,price) values (?,?)";

3、? 代替的参数要通过 set类型(位置,值) 传入

pstmt.setString(1, "《java入门到改行》");
pstmt.setFloat(2, 11.11f);

pstmt.setXxx()的位置从 1 开始！

4、增删改的SQL语句都使用这个方法，返回受影响行数

int result=pstmt.executeUpdate();

删除数据

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class TestDelete {

    public static void main(String[] args) {
        Connection connection=null;
        PreparedStatement pstmt=null;
        String url="jdbc:mysql://localhost:3306/books?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";
        String user="root";
        String password="1234";
        try {
            connection=DriverManager.getConnection(url,user,password);
            //sql语句
            String sql="delete from book where id=?";
            pstmt=connection.prepareStatement(sql);
            //传入参数 要删除id
            pstmt.setInt(1, 1);
            int result=pstmt.executeUpdate();
            System.out.println("受影响行数："+result);
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            if (pstmt!=null) {
                try {
                    pstmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (connection!=null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

修改数据

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class TestUpdate {

    public static void main(String[] args) {
        Connection connection=null;
        PreparedStatement pstmt=null;
        String url="jdbc:mysql://localhost:3306/books?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";
        String user="root";
        String password="1234";
        try {
            connection=DriverManager.getConnection(url,user,password);
            //sql语句
            String sql="update book set bName=?,price=? where id=?";
            pstmt=connection.prepareStatement(sql);
            //传入参数 要删除id
            pstmt.setString(1, "《MySQL从删库到跑路》");
            pstmt.setFloat(2, 16.66f);
            pstmt.setInt(3, 2);
            int result=pstmt.executeUpdate();
            System.out.println("受影响行数："+result);
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            if (pstmt!=null) {
                try {
                    pstmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (connection!=null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

增、删、改操作的写法都一样，都调用 executeUpdate() 方法返回一个受影响行数，唯一不同的 SQL语句。

PreparedStatement 查询数据

查询数据需要用到 ResultSet 类保存返回的结果集，我们获取数据要操作 ResultSet 获取。

ResultSet 常用方法

方法名	说明
boolean next()	将游标从当前位置向下移动一行
void close()	关闭 ResultSet 对象
int getInt(int colIndex)	以int形式获取结果集当前行指定列号值
int getInt(String colLabel)	以int形式获取结果集当前行指定列名值
float getFloat(String colLabel)	以float形式获取结果集当前行指定列名值
String getString(String colLabel)	以 String 形式获取结果集当前行指定列名值

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class TestSelect {

    public static void main(String[] args) {
        Connection connection=null;
        PreparedStatement pstmt=null;
        ResultSet rs=null;
        String url="jdbc:mysql://localhost:3306/books?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";
        String user="root";
        String password="1234";
        try {
            connection=DriverManager.getConnection(url,user,password);
            //sql语句
            String sql="select bName,price,id from book where id=?";
            pstmt=connection.prepareStatement(sql);
            //传入查询条件
            pstmt.setInt(1, 2);
            rs=pstmt.executeQuery();
            while(rs.next()) {
                //通过列名获取列的值
                int id=rs.getInt("id");
                //通过位置获取列的值
                String bName=rs.getString(1);
                float price=rs.getFloat("price");
                System.out.println(id+" "+bName+" "+price);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            if(rs!=null) {
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (pstmt!=null) {
                try {
                    pstmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (connection!=null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

关闭对象时注意关闭的顺序，后使用的先关闭：rs.close()->pstmt.close()->connection.close()

ResultSet 对象存在一个光标，光标所指行为当前行。想要获取列的数据需要先指向一行，所以要先指定 next() 方法用于指向一行，如果没有数据next()方法返回false，有数据返回true。

使用 getXxx() 方法获取列的数据时建议写列名，这样好识别

微信关注我们

原文链接：https://yq.aliyun.com/articles/669334

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

Spring小知识

两大核心功能：IOC、AOPIOC：动态注入，让一个对象的创建不用new了，可以自动的生产，实现原理利用java里的反射，反射就是在运行时动态的去创建、调用对象，Spring就是在运行时，跟xml Spring的配置文件来动态的创建对象，和调用对象里的方法的。 AOP：面向切面编程，可以为某一类对象进行监督和控制（也就是在调用这类对象的具体方法的前后去调用你指定的模块）从而达到对一个模块扩充的功能。这些都是通过配置类达到的。

2018-11-13

842

本文会通过Java语言实现：冒泡排序，插入排序，选择排序，归并排序，快速排序，桶排序，计数排序，基数排序，希尔排序 1 分析排序算法 1.1 执行效率最好的情况，最坏的情况，平均情况时间复杂度时间复杂度的系数，常数，低阶比较次数和交换次数 1.2 算法的内存消耗算法的内存消耗我们可以通过空间复杂度来度量。原地排序算法，就是特指空间复杂度是O(1)的排序算法。 1.3 排序算法的稳定性如果序列中有值相等的元素，经过排序之后，相等元素之间原有的先后顺序不变化。 2 冒泡排序稳定排序算法，原地排序算法，时间复杂度：O(n^2) 冒泡排序操作相邻的两个数据，每次冒泡操作都会对相邻的两个元素进行比较，看是否满足大小关系。每次冒泡都能选出最大的或者最小的值。 /** * 冒泡排序 * @param arr * @return */ public static int[] bubbleSort(int[] arr) { if (arr == null || arr.length == 0) { return null; } int n = arr.length; // 总共需要循环n...

2018-11-13

783

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

WebStorm

WebStorm 是jetbrains公司旗下一款JavaScript 开发工具。目前已经被广大中国JS开发者誉为“Web前端开发神器”、“最强大的HTML5编辑器”、“最智能的JavaScript IDE”等。与IntelliJ IDEA同源，继承了IntelliJ IDEA强大的JS部分的功能。