在项目有时会用到不同数据库,项目写了一个连接不同数据库(包括mysql,SQL server, oracle ,access)的工具类: import java.io.File;import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.ResultSetMet
在项目有时会用到不同数据库,项目写了一个连接不同数据库(包括mysql,SQL server, oracle ,access)的工具类:
import java.io.File; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; public class ConnectionDbUtils { /** * 获取数据库连接对象(sql server) * * @param server * 服务器 * @param database * 数据库名 * @param user_id * 用户名 * @param password * 密码 * @return Connection * @throws ClassNotFoundException * @throws SQLException */ public static Connection getSqlServerConnection(String server, String database, String user_id, String password) throws ClassNotFoundException, SQLException { Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver"); Connection con = DriverManager.getConnection("jdbc:sqlserver://" + server + ":1433;DatabaseName=" + database, user_id, password); return con; } /** * 获取数据库连接对象(MySql) * * @param server * 服务器 * @param database * 数据库名 * @param user_id * 用户名 * @param password * 密码 * @return Connection * @throws ClassNotFoundException * @throws SQLException */ public static Connection getMySqlConnection(String server, String database, String user_id, String password) throws ClassNotFoundException, SQLException { Class.forName("com.mysql.jdbc.Driver"); return DriverManager.getConnection("jdbc:mysql://"+server+":3306/" + database, user_id, password); } /** * JDBC连接oracle * @param server IP * @param database 数据库 * @param user_id 用户名 * @param password 密码 * @param sql * @return * @throws ClassNotFoundException * @throws SQLException */ public static Connection getOracleConnection(String server, String database, String user_id, String password) throws ClassNotFoundException, SQLException { Class.forName("oracle.jdbc.driver.OracleDriver"); Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@" + server + ":1521:" + database, user_id, password); return conn; } /** * JDBC连接Access * @param database 数据库路径 * @param user_id 用户名 * @param password 密码 * @param sql * @return * @throws ClassNotFoundException * @throws SQLException * @throws IllegalAccessException * @throws InstantiationException */ public static Connection getAccessConnection(String database, String user_id, String password) throws ClassNotFoundException, SQLException, InstantiationException, IllegalAccessException { System.out.println("==============" + database); Class.forName("com.hxtt.sql.access.AccessDriver").newInstance(); Connection conn = DriverManager.getConnection("jdbc:Access:///" + database, user_id, password); System.out.println("连接成功"); return conn; } /** * Access 查询数据 * @param database * @param user_id * @param password * @param strSql * @return * @throws Exception */ public static List<Map<String, Object>> queryAccessData(String database, String user_id, String password, String strSql) throws Exception { File file = new File(database); if (file.exists()){ if (file.canWrite()) { System.out.println("不只读"); } else { System.out.println("只读"); file.setWritable(true); } } else { System.out.println("不存在"); } Connection con = ConnectionDbUtils.getAccessConnection(database, user_id, password); Statement stmt = con.createStatement(); ResultSet rs = stmt.executeQuery(strSql); List<Map<String, Object>> listMap = new ArrayList<Map<String, Object>>(); while (rs.next()) { Map<String, Object> map = new HashMap<String, Object>(); ResultSetMetaData rsmd = rs.getMetaData(); for (int i = 1; i <= rsmd.getColumnCount(); i++) { String columnName = rsmd.getColumnName(i); Object objValue = rs.getObject(columnName); map.put(columnName, objValue); } listMap.add(map); } return listMap; } /** * Access增删改 * @param database * @param user_id * @param password * @param sql */ public static void createAccessSQLExecute(String database, String user_id, String password, String sql) { Statement stmt = null; try { Connection con = ConnectionDbUtils.getAccessConnection(database, user_id, password); stmt = con.createStatement(); int i = stmt.executeUpdate(sql); System.out.println("执行sql语句:" + sql); System.out.println("处理成功!处理条数为" + i); } catch (Exception e) { e.printStackTrace(); System.out.println("执行失败,请检查远程数据库是否打开服务"); } finally { try { if (null != stmt) { stmt.close(); } } catch (SQLException e) { e.printStackTrace(); } } } /** * oracle 查询数据 * @param server * @param database * @param user_id * @param password * @param strSql * @return * @throws Exception */ public static List<Map<String, Object>> queryOracleData(String server, String database, String user_id, String password, String strSql) throws Exception { Connection con = ConnectionDbUtils.getOracleConnection(server, database, user_id, password); Statement stmt = con.createStatement(); ResultSet rs = stmt.executeQuery(strSql); List<Map<String, Object>> listMap = new ArrayList<Map<String, Object>>(); while (rs.next()) { Map<String, Object> map = new HashMap<String, Object>(); ResultSetMetaData rsmd = rs.getMetaData(); for (int i = 1; i <= rsmd.getColumnCount(); i++) { String columnName = rsmd.getColumnName(i); Object objValue = rs.getObject(columnName); map.put(columnName, objValue); } listMap.add(map); } return listMap; } /** * oracle增删改 * @param server * @param database * @param user_id * @param password * @param sql */ public static void createOracleSQLExecute(String server, String database, String user_id, String password, String sql) { Statement stmt = null; try { Connection con = ConnectionDbUtils.getOracleConnection(server, database, user_id, password); stmt = con.createStatement(); System.out.println("执行sql语句:" + sql); int i = stmt.executeUpdate(sql); System.out.println("处理成功!处理条数为" + i); } catch (Exception e) { e.printStackTrace(); System.out.println("执行失败,请检查远程数据库是否打开服务"); } finally { try { if (null != stmt) { stmt.close(); } } catch (SQLException e) { e.printStackTrace(); } } } /** * 查询数据(sql server) * * @param server 服务器 * @param database 数据库名 * @param user_id 用户名 * @param password 密码 * @param strSql sql语句 * @return List<Map<String,Object>> * @throws Exception */ public static List<Map<String, Object>> querySqlServerData(String server, String database, String user_id, String password, String strSql) throws Exception { Connection con = ConnectionDbUtils.getSqlServerConnection(server, database, user_id, password); Statement stmt = con.createStatement(); System.out.println("querySqlServerData的sql语句===========" + strSql); ResultSet rs = stmt.executeQuery(strSql); List<Map<String, Object>> listMap = new ArrayList<Map<String, Object>>(); while (rs.next()) { Map<String, Object> map = new HashMap<String, Object>(); ResultSetMetaData rsmd = rs.getMetaData(); for (int i = 1; i <= rsmd.getColumnCount(); i++) { String columnName = rsmd.getColumnName(i); Object objValue = rs.getObject(columnName); map.put(columnName, objValue); } listMap.add(map); } return listMap; } /** * 执行sql的添加、修改、删除操作 * * @param conn * @param sql */ public static void createSQLExecute(String server, String database, String user_id, String password, List<String> sql) { Statement stmt = null; try { Connection con = ConnectionDbUtils.getSqlServerConnection(server, database, user_id, password); stmt = con.createStatement(); for (String s : sql) { System.out.println("执行sql语句:" + sql); int i = stmt.executeUpdate(s); System.out.println("处理成功!处理条数为" + i); } } catch (Exception e) { e.printStackTrace(); System.out.println("执行失败,请检查远程数据库是否打开服务"); } finally { try { if (null != stmt) { stmt.close(); } } catch (SQLException e) { e.printStackTrace(); } } } /** * 执行sql的添加、修改、删除操作 * * @param conn * @param sql */ public static void createSQLExecute(String server, String database, String user_id, String password, String sql) { Statement stmt = null; try { System.out.println("执行sql语句:" + sql); Connection con = ConnectionDbUtils.getSqlServerConnection(server, database, user_id, password); stmt = con.createStatement(); int i = stmt.executeUpdate(sql); System.out.println("处理成功!处理条数为" + i); } catch (Exception e) { e.printStackTrace(); System.out.println("执行失败,请检查远程数据库是否打开服务"); } finally { try { if (null != stmt) { stmt.close(); } } catch (SQLException e) { e.printStackTrace(); } } } /** * MySql 查询数据 * @param server * @param database * @param user_id * @param password * @param strSql * @return * @throws Exception */ public static List<Map<String, Object>> queryMySqlData(String server, String database, String user_id, String password, String sql) throws Exception { Connection con = ConnectionDbUtils.getMySqlConnection(server, database, user_id, password); Statement stmt = con.createStatement(); ResultSet rs = stmt.executeQuery(sql); List<Map<String, Object>> listMap = new ArrayList<Map<String, Object>>(); while (rs.next()) { Map<String, Object> map = new HashMap<String, Object>(); ResultSetMetaData rsmd = rs.getMetaData(); for (int i = 1; i <= rsmd.getColumnCount(); i++) { String columnName = rsmd.getColumnName(i); Object objValue = rs.getObject(columnName); map.put(columnName, objValue); } listMap.add(map); } return listMap; } /** * 执行MySql的增删改 * @param server * @param database * @param user_id * @param password * @param sql */ public static void createMySqlExecute(String server,String database,String user_id,String password,String sql){ Connection con=null; Statement stmt = null; try { System.out.println("执行sql语句:" + sql); con= ConnectionDbUtils.getMySqlConnection(server, database, user_id, password); stmt = con.createStatement(); int successCount = stmt.executeUpdate(sql); System.out.println("处理成功!处理条数为" + successCount); } catch (Exception e) { e.printStackTrace(); System.out.println("执行失败,请检查远程数据库是否打开服务"); } finally { try { if (null != stmt) { stmt.close(); } } catch (SQLException e) { e.printStackTrace(); } } } }

win11无法连接局域网打印机怎么办?有不少用户的win11系统在使用局域网打印机功能的时候,无法正常连接到共享打印机,出现这个问题,可能是连接步骤或者是某项功能服务没打开。今天小编就给大家带来了多种解决方法,很多小伙伴不知道怎么详细操作,小编下面整理了win11电脑不能连共享打印机解决技巧,如果你感兴趣的话,跟着小编一起往下看看吧!win11电脑不能连共享打印机解决技巧1、首先,按键盘上的Win+X组合键,或右键点击任务栏上的Windows开始图标,在打开的隐藏菜单项中,选择运行;2、运行窗口

MariaDB是一种开源的关系型数据库管理系统,它是MySQL的一个分支。PHP作为一种开源的服务器端脚本语言,被广泛应用于Web开发中。在很多Web开发项目中,需要使用PHP连接到MariaDB数据库,以便在Web应用程序中存储和检索数据。这篇文章将介绍如何使用PHP编写代码来连接MariaDB数据库。一、安装MariaDB服务器在使用PHP连接Maria

MySQL连接错误1203,如何解决?MySQL是一种广泛使用的关系型数据库管理系统,但是在使用MySQL时,一些连接错误可能会出现。其中一个常见的错误是错误代码1203,它表示数据库连接已中断。在遇到这个错误时,可以采取一些措施来解决问题。首先,我们需要确定错误1203的确切原因。这个错误通常是由于连接超时或连接过多引起的。连接超时可能是由于数据库服务器负

随着现代程序开发的不断发展,软件项目往往需要同时使用多个任务库来处理不同的任务。PHP语言一直是Web开发的重要工具,其在7.0版本中引入了新的并发处理特性,使得PHP在处理任务库时更加高效、灵活。在8.0版本中,PHP又新增了对连接多个任务库的支持,这为我们在处理大量数据和并发请求时提供了极大的便利。在本文中,我们将探讨PHP8.0中连接多个任务库的方法和

Python连接阿里云接口,实现邮件发送功能阿里云提供了一系列的服务接口,其中包括了邮件发送服务。通过Python脚本连接阿里云接口,我们可以实现邮件的快速发送。本篇文章将向您展示如何使用Python脚本连接阿里云接口,并实现邮件发送功能。首先,我们需要在阿里云上申请邮件发送服务,获取相应的接口信息。在阿里云管理控制台中,选择邮件推送服务,然后创建一个新的邮

Java连接数据库的SQLException异常常见原因是什么?在Java开发中,Database操作是非常关键的一环。其中,对于常用的CRUD操作,特别是SELECT和INSERT操作,都需要使用到JDBC来实现。但是,在JDBC应用开发中,与数据库的连接操作、SQL语言的执行过程、以及结果集的处理等阶段,可能会发生SQLException异常。本文将分析

MySQL连接错误2059,该如何解决?在使用MySQL数据库时,有时会遇到连接错误2059的问题。这个错误通常是由于MySQL服务器与客户端之间的连接问题引起的。在本文中,我将解释导致此错误的一些常见原因,并提供一些可能的解决方案。防火墙问题:在一些情况下,防火墙设置可能会阻止MySQL服务器与客户端之间的通信。这种情况下,你需要检查防火墙设置并确保MyS

如何在Java程序中优化MySQL连接的写入性能和并发性能?在开发Java程序时,我们经常需要使用到数据库,而MySQL作为一种常见的数据库管理系统,其连接的写入性能和并发性能是我们需要关注的重点。本文将介绍如何在Java程序中优化MySQL连接的写入性能和并发性能,以提升程序的效率。使用连接池管理连接:连接池可以管理数据库连接的创建、销毁和复用,避免频繁地


热AI工具

Undresser.AI Undress
人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool
免费脱衣服图片

Clothoff.io
AI脱衣机

AI Hentai Generator
免费生成ai无尽的。

热门文章

热工具

螳螂BT
Mantis是一个易于部署的基于Web的缺陷跟踪工具,用于帮助产品缺陷跟踪。它需要PHP、MySQL和一个Web服务器。请查看我们的演示和托管服务。

MinGW - 适用于 Windows 的极简 GNU
这个项目正在迁移到osdn.net/projects/mingw的过程中,你可以继续在那里关注我们。MinGW:GNU编译器集合(GCC)的本地Windows移植版本,可自由分发的导入库和用于构建本地Windows应用程序的头文件;包括对MSVC运行时的扩展,以支持C99功能。MinGW的所有软件都可以在64位Windows平台上运行。

SublimeText3 Mac版
神级代码编辑软件(SublimeText3)

SublimeText3 英文版
推荐:为Win版本,支持代码提示!

禅工作室 13.0.1
功能强大的PHP集成开发环境