Java JDBC连接数据库常见操作总结

 更新时间:2019年03月08日 10:20:07   作者:时间在这里停顿  
这篇文章主要介绍了Java JDBC连接数据库常见操作,结合实例形式总结分析了java基于jdbc连接mysql、Oracle数据库及连接池相关操作技巧,需要的朋友可以参考下

本文实例总结了Java JDBC连接数据库常见操作。分享给大家供大家参考,具体如下:

db.properties配置文件(MySql数据库)

# db.properties
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/demo?useUnicode=true&characterEncoding=UTF-8
jdbc.username=root
jdbc.password=123456
# paramter for BasicDataSource
initSize=2
maxActive=2

db.properties配置文件(Oracle数据库)

# db.properties
jdbc.driver=oracle.jdbc.OracleDriver
jdbc.url=jdbc:oracle:thin:localhost:1521:orcl
jdbc.username=root
jdbc.password=123456
# paramter for BasicDataSource
initSize=2
maxActive=2

JDBC直接连接数据库

package JDBC;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;
/**
 * JDBC连接数据库管理工具类
 */
public class JDBC {
  static String driver;
  static String url;
  static String username;
  static String password;
  static {
    try {
      Properties cfg = new Properties();
      InputStream in = JDBC.class.getClassLoader().getResourceAsStream("db.properties");
      cfg.load(in);  //将文件内容加载到Properties对象中(以散列表形式存在)
      driver = cfg.getProperty("jdbc.driver");
      url = cfg.getProperty("jdbc.url");
      username = cfg.getProperty("jdbc.username");
      password = cfg.getProperty("jdbc.password");
      in.close();
    } catch (IOException e) {
      e.printStackTrace();
      throw new RuntimeException(e);
    }
  }
  /**
   * 创建数据库连接
   */
  public static Connection getConnection() {
    try {
      Class.forName(driver); //注册驱动
      Connection conn = DriverManager.getConnection(url, username, password);
      return conn;
    } catch (Exception e) {
      e.printStackTrace();
      throw new RuntimeException(e);
    }
  }
  /*
   * 关闭数据库的连接
   */
  public static void close(Connection conn) {
    if (conn != null) {
      try {
        conn.close();
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
  }
}

通过连接池连接数据库

package JDBC;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;
import org.apache.commons.dbcp.BasicDataSource;
/**
 * 连接池版本的数据库连接管理工具类
 */
public class DBUtils {
  private static String driver;
  private static String url;
  private static String username;
  private static String password;
  private static int initSize;
  private static int maxActive;
  private static BasicDataSource dbs;
  static {
    dbs = new BasicDataSource();
    Properties cfg = new Properties();
    try {
      InputStream in = DBUtils.class.getClassLoader().getResourceAsStream("db.properties");
      cfg.load(in);
      // 初始化参数
      driver = cfg.getProperty("jdbc.driver");
      url = cfg.getProperty("jdbc.url");
      username = cfg.getProperty("jdbc.username");
      password = cfg.getProperty("jdbc.password");
      initSize = Integer.parseInt(cfg.getProperty("initSize"));
      maxActive = Integer.parseInt(cfg.getProperty("maxActive"));
      in.close();
      // 初始化连接池
      dbs.setDriverClassName(driver);
      dbs.setUrl(url);
      dbs.setUsername(username);
      dbs.setPassword(password);
      dbs.setInitialSize(initSize);
      dbs.setMaxActive(maxActive);
    } catch (IOException e) {
      e.printStackTrace();
      throw new RuntimeException(e);
    }
  }
  /**
   * 创建数据库连接,从连接池中获取连接,如果连接池满了,则等待.
   */
  public static Connection getConnection() {
    try {
      Connection conn = dbs.getConnection();
      return conn;
    } catch (SQLException e) {
      e.printStackTrace();
      throw new RuntimeException(e);
    }
  }
  /*
   * 关闭数据库的连接,归还到连接池
   */
  public static void close(Connection conn) {
    if (conn != null) {
      try {
        conn.close();
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
  }
  //回滚,仅在禁用自动提交时使用
  public static void rollback(Connection conn) {
    if (conn != null) {
      try {
        conn.rollback();
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
  }
}

连接数据库后的使用

Connection conn=null;
try{
  conn=DbUtils.getConnection();
  Statement st=conn.createStatement();
  String sql="select id, name from people";
  ResultSet rs=st.executeQuery(sql);
  while(rs.next()){
    int id=rs.getInt("id");
    String name=rs.getString("name");
    System.out.println(id+","+name);
  }
  //结果集元数据
  ResultSetMetaData meta = rs.getMetaData();
  int n = meta.getColumnCount(); //多少列
  for(int i=1; i<=n; i++){
    String name= meta.getColumnName(i); //获取列名
    System.out.println(name);
  }
  rs.close();//释放查询结果
  st.close();//释放语句对象
}catch(Exception e){
  e.printStackTrace();
}finally {
  DbUtils.close(conn);
}

预编译SQL执行 及 取消自动提交

try {
  conn = DBUtils.getConnection();
  conn.setAutoCommit(false);  //取消自动提交, 后续手动提交
  String sql="update people set name=? where id=? ";
  PreparedStatement ps= conn.prepareStatement(sql);
  //按照顺序发送参数
  ps.setString(1, "Lao Wang");
  ps.setInt(2, 100);
  //执行"执行计划"
  int n=ps.executeUpdate();
  conn.commit();  //手动提交
} catch (Exception e) {
  e.printStackTrace();
  DBUtils.rollback(conn); //异常回滚
}finally{
  DBUtils.close(conn);
}

Statement的addBatch(sql)executeBatch()方法可以批量执行sql。

Statement st=conn.createStatement();
st.addBatch(sql1); //sql1 添加到Statement的缓存中
st.addBatch(sql2);
st.addBatch(sql3);
int[] ary=st.executeBatch();  //执行一批SQL

PreparedStatement也支持批量参数的处理

PreparedStatement ps = conn.prepareStatement(sql);
ps.setInt(1, 1);
ps.setString(2, "wang");
ps.addBatch();   //将参数添加到ps缓存区
ps.setInt(1, 2);
ps.setString(2, "li");
ps.addBatch();   //将参数添加到ps缓存区
int[] ary = ps.executeBatch(); // 批量执行

PreparedStatement ps = conn.prepareStatement(sql);

还可以传入第二个参数用以获取自增主键或者序号自增的列

更多关于java相关内容感兴趣的读者可查看本站专题:《Java使用JDBC操作数据库技巧总结》、《Java+MySQL数据库程序设计总结》、《Java数据结构与算法教程》、《Java文件与目录操作技巧汇总》、《Java操作DOM节点技巧总结》和《Java缓存操作技巧汇总

希望本文所述对大家java程序设计有所帮助。

相关文章

  • springboot2.x整合redis知识点讲解

    springboot2.x整合redis知识点讲解

    在本篇文章中小编给大家分享的是一篇关于springboot2.x整合redis知识点内容,有兴趣的朋友们可以学习下。
    2020-01-01
  • Java定时清理过期文件的实例代码

    Java定时清理过期文件的实例代码

    这篇文章主要介绍了Java定时清理过期文件的实例代码,非常不错,具有一定的参考借鉴价值 ,需要的朋友可以参考下
    2018-12-12
  • SpringBoot整合Mybatis LocalDateTime 映射失效的解决

    SpringBoot整合Mybatis LocalDateTime 映射失效的解决

    这篇文章主要介绍了SpringBoot整合Mybatis LocalDateTime 映射失效的解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-01-01
  • SpringBoot整合mybatis通用Mapper+自定义通用Mapper方法解析

    SpringBoot整合mybatis通用Mapper+自定义通用Mapper方法解析

    这篇文章主要介绍了SpringBoot整合mybatis通用Mapper+自定义通用Mapper方法,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-03-03
  • java实现打印日历

    java实现打印日历

    这篇文章主要为大家详细介绍了java打印日历的实现代码,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-01-01
  • MybatisPlus使用@TableId主键id自增长无效的解决

    MybatisPlus使用@TableId主键id自增长无效的解决

    本文主要介绍了MybatisPlus使用@TableId主键id自增长无效的解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-04-04
  • SpringCloud服务注册和发现组件Eureka

    SpringCloud服务注册和发现组件Eureka

    对于微服务的治理而言,其核心就是服务的注册和发现。在SpringCloud 中提供了多种服务注册与发现组件,官方推荐使用Eureka。本篇文章,我们来讲解springcloud的服务注册和发现组件,感兴趣的可以了解一下
    2021-05-05
  • Java框架学习Struts2复选框实例代码

    Java框架学习Struts2复选框实例代码

    这篇文章主要介绍了Java框架学习Struts2复选框实例代码,分享了相关代码示例,小编觉得还是挺不错的,具有一定借鉴价值,需要的朋友可以参考下
    2018-02-02
  • Java关于重排链表详细解析

    Java关于重排链表详细解析

    在我们平时的代码过程中,链表是我们经常遇到的一个数据结构,面试题中链表占很大一部分,可见链表操作是非常重要的。本篇文章我们来探究一下如何进行重排链表
    2022-01-01
  • Java执行JavaScript代码

    Java执行JavaScript代码

    这篇文章主要为大家详细介绍了Java执行JavaScript代码的具体操作方法,感兴趣的小伙伴们可以参考一下
    2016-03-03

最新评论