前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >使用单例模式创建一个全局的jdbc链接

使用单例模式创建一个全局的jdbc链接

作者头像
余生大大
发布2022-11-02 15:10:29
6490
发布2022-11-02 15:10:29
举报
文章被收录于专栏:余生大大

暴露的外部接口:

  • getInstance()
    • 唯一的初始化类的方法
  • getLink()
    • 获取Statement对象
  • closeLink()
    • 关闭数据库连接并将类置为null
  • performQuerySql(String sql)
    • 执行查询操作的sql
  • performUpdateSql(String sql)
    • 执行update操作的sql

创建JDBC链接的步骤:

1. 引入mysql包

代码语言:javascript
复制
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.1.31</version>
</dependency>

2. 加载驱动

代码语言:javascript
复制
// 注册JDBC驱动程序:需要初始化驱动程序,以便可以打开与数据库的通信通道。
Class.forName("com.mysql.jdbc.Driver").newInstance();

3. 创建链接

代码语言:javascript
复制
// 打开一个连接:需要使用DriverManager.getConnection()方法创建一个Connection对象,它表示与数据库的物理连接。
Connection conn = DriverManager.getConnection(url,name,pwd);

4. 执行查询

代码语言:javascript
复制
// 执行查询:需要使用一个类型为Statement或PreparedStatement的对象,并提交一个SQL语句到数据库执行查询。如下:
Statement statement = conn.createStatement();
ResultSet rs = statement.executeQuery(sql);

Statement知识:Statement 对象用于将 SQL 语句发送到数据库中。实际上有三种 Statement 对象,它们都作为在给定连接上执行 SQL语句的包容器:Statement、PreparedStatement(它从 Statement 继承而来)和CallableStatement(它从 PreparedStatement 继承而来)。它们都专用于发送特定类型的 SQL 语句:Statement 对象用于执行不带参数的简单 SQL 语句;PreparedStatement 对象用于执行带或不带 IN参数的预编译 SQL 语句;CallableStatement 对象用于执行对数据库已存储过程的调用。

5. 关闭资源

代码语言:javascript
复制
conn.close();
statement.close();
rs.close();

代码示例:

代码语言:javascript
复制
package com.an.learning.bean;

import java.sql.*;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * @author Anzepeng
 * @title: MysqlLink
 * @projectName learning
 * @description: TODO
 * @date 2020/8/14 0014下午 13:19
 */
public class MysqlLink {

    private static MysqlLink mysqlLink = null;
    private static final String url = "jdbc:mysql://" + "ip/库名" + "?useUnicode=true&characterEncoding=utf-8";
    private static final String name = "root";
    private static final String pwd = "";

    private static Connection conn;
    private static Statement statement;
    private static ResultSet rs;

    private MysqlLink(){
        try {
            // 注册JDBC驱动程序:需要初始化驱动程序,以便可以打开与数据库的通信通道。
            Class.forName("com.mysql.jdbc.Driver").newInstance();
            // 打开一个连接:需要使用DriverManager.getConnection()方法创建一个Connection对象,它表示与数据库的物理连接。
            conn = DriverManager.getConnection(url,name,pwd);
            // 执行查询:需要使用一个类型为Statement或PreparedStatement的对象,并提交一个SQL语句到数据库执行查询。如下:
            statement = conn.createStatement();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
       * @description: 执行查询sql
       * @param ${String sql}
       * @return List
       * @throws
       * @author Anzepeng
       * @date 2020/8/14 0014 下午 15:12
       */
    public static List performQuerySql(String sql){
        List list = new ArrayList();
        try {
            rs = statement.executeQuery(sql);
            ResultSetMetaData md = rs.getMetaData(); //获得结果集结构信息,元数据
            int columnCount = md.getColumnCount();   //获得列数
            while (rs.next()) {
                Map<String,Object> rowData = new HashMap<String,Object>();
                for (int i = 1; i <= columnCount; i++) {
                    rowData.put(md.getColumnName(i), rs.getObject(i));
                }
                list.add(rowData);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return list;
    }

    /**
      * @description: 执行update操作
      * @param ${String sql}
      * @return boolean
      * @throws
      * @author Anzepeng
      * @date 2020/8/14 0014 下午 15:19
      */
    public static boolean performUpdateSql(String sql){
        try {
            statement.executeUpdate(sql);
            return true;
        } catch (SQLException e) {
            e.printStackTrace();
            return false;
        }
    }
    
    /**
      * @description: 获取MysqlLink对象
      * @param ${tags}
      * @return MysqlLink
      * @throws
      * @author Anzepeng
      * @date 2020/8/14 0014 下午 15:14
      */
    public static MysqlLink getInstance(){
        if (mysqlLink == null){
            mysqlLink = new MysqlLink();
        }
        return mysqlLink;
    }

    /**
      * @description: 获取Statement对象
      * @param ${tags}
      * @return Statement
      * @throws
      * @author Anzepeng
      * @date 2020/8/14 0014 下午 15:15
      */
    public static Statement getLink(){
        return statement;
    }

    /**
      * @description: 关闭数据库连接
      * @param ${tags}
      * @return boolean
      * @throws
      * @author Anzepeng
      * @date 2020/8/14 0014 下午 15:13
      */
    public static boolean closeLink(){
        try {
            conn.close();
            statement.close();
            if (rs != null){
                rs.close();
            }
            mysqlLink = null;
            return true;
        } catch (SQLException e) {
            e.printStackTrace();
            return false;
        }
    }
}
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2020-08-14,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 暴露的外部接口:
  • 创建JDBC链接的步骤:
  • 代码示例:
相关产品与服务
数据库
云数据库为企业提供了完善的关系型数据库、非关系型数据库、分析型数据库和数据库生态工具。您可以通过产品选择和组合搭建,轻松实现高可靠、高可用性、高性能等数据库需求。云数据库服务也可大幅减少您的运维工作量,更专注于业务发展,让企业一站式享受数据上云及分布式架构的技术红利!
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档