Java 连接mysql的jdbcutil代码-白红宇

Java 连接mysql的jdbcutil代码

阅读量：400 次

发布时间：2019-03-05

本文共 2796 字，大约阅读时间需要 9 分钟。

Java JDBC 连接 HBase 数据库的实现与使用说明

1. JDBC 连接 HBase 数据库

在本节中，我们将详细介绍如何使用 JDBC 连接 HBase 数据库，实现数据库的 CRUD 操作（即创建、读取、更新、删除操作）。本文将分为两部分：连接数据库的实现与数据库操作的实现。

1.1 JDBC 连接数据库的实现

为了实现 JDBC 连接 HBase 数据库，本项目使用了标准的 JDBC 接口。以下是实现的主要步骤：

加载 JDBC 驱动程序：

通过 Class.forName("com.mysql.jdbc.Driver") 加载 JDBC 驱动程序。

获取数据库连接：

使用 DriverManager.getConnection() 方法获取数据库连接。

配置数据库参数：

需要配置以下数据库参数：

数据库驱动程序类名：DBDRIVER = "com.mysql.jdbc.Driver"

数据库 URL：DBURL = "jdbc:mysql://localhost:3306/my_test"

数据库用户账号：DBUSER = "root"

数据库密码：DBPASS = ""

1.2 JDBC 操作数据库

通过 JDBC 接口实现数据库操作，主要包括以下方法：

初始化连接：

在使用数据库之前，需要先初始化数据库连接：

public void initConnection() {    try {        Class.forName(DBDRIVER);        con = DriverManager.getConnection(DBURL, DBUSER, DBPASS);    } catch (ClassNotFoundException e) {        e.printStackTrace();    } catch (SQLException e) {        e.printStackTrace();    }}

执行查询操作：

使用 prepareStatement() 方法准备查询语句，并执行查询操作：

public ResultSet queryData(String sql, Object[] obj) {    try {        if (con == null) {            initConnection();        }        ps = con.prepareStatement(sql);        for (int i = 0; i < obj.length; i++) {            ps.setObject(i + 1, obj[i]);        }        rs = ps.executeQuery();    } catch (SQLException e) {        e.printStackTrace();    }    return rs;}

执行增删改操作：

使用 prepareStatement() 方法准备增删改语句，并执行操作：

public int updateAndDeleteData(String sql, Object[] obj) {    try {        if (con == null) {            initConnection();        }        ps = con.prepareStatement(sql);        for (int j = 0; j < obj.length; j++) {            ps.setObject(j + 1, obj[j]);        }        int i = ps.executeUpdate();    } catch (SQLException e) {        e.printStackTrace();    } finally {        closePs();    }    return i;}

关闭数据库连接：

使用 close() 方法关闭数据库连接：

public void closeConnection() {    try {        if (ps != null) {            ps.close();        }        if (rs != null) {            rs.close();        }        if (con != null) {            con.close();        }    } catch (SQLException e) {        e.printStackTrace();    }}

2. 查询结果展示

通过上述方法，我们可以成功获取数据库中的数据。以下是查询结果的展示：

序号	公司名称	CEO
1	阿里巴巴	马云
2	淘宝	孙正义
3	百度	李彦宏

2.1 查询结果分析

从查询结果可以看出，数据库中存储了三家公司的基本信息。以下是具体分析：

阿里巴巴：

公司名称：阿里巴巴

CEO：马云

淘宝：

公司名称：淘宝

CEO：孙正义

百度：

公司名称：百度

CEO：李彦宏

2.2 查询结果的获取过程

通过调用 queryData("select * from company", null) 方法，可以获取以上结果。以下是具体实现：

ResultSet rs = queryData("select * from company", null);try {    while (rs.next()) {        int id = rs.getInt(1);        String name = rs.getString(2);        String ceo = rs.getString(3);        System.out.println(id + "==" + name + "==" + ceo);    }} catch (SQLException e) {    e.printStackTrace();} finally {    closeConnection();}