项目中连接数据库的工具类
不同
工具
数据库
连接
在项目有时会用到不同数据库，项目写了一个连接不同数据库（包括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();
}
}
}
}
登录后复制
本站声明
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn
热AI工具
Undresser.AI Undress
人工智能驱动的应用程序，用于创建逼真的裸体照片
AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。
Undress AI Tool
免费脱衣服图片
Clothoff.io
AI脱衣机
AI Hentai Generator
免费生成ai无尽的。
热门文章
R.E.P.O.能量晶体解释及其做什么（黄色晶体）
3 周前
By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳图形设置
3 周前
By 尊渡假赌尊渡假赌尊渡假赌
刺客信条阴影：贝壳谜语解决方案
1 周前
By DDD
R.E.P.O.如果您听不到任何人，如何修复音频
3 周前
By 尊渡假赌尊渡假赌尊渡假赌
在哪里可以找到原子中的起重机控制钥匙卡
1 周前
By DDD
热工具
记事本++7.3.1
好用且免费的代码编辑器
SublimeText3汉化版
中文版，非常好用
禅工作室 13.0.1
功能强大的PHP集成开发环境
Dreamweaver CS6
视觉化网页开发工具
SublimeText3 Mac版
神级代码编辑软件(SublimeText3)
Gitee Pages静态网站部署失败：单个文件404错误如何排查和解决？
Apr 04, 2025 pm 11:54 PM
GiteePages静态网站部署失败：404错误排查与解决在使用Gitee...
H5页面制作是否需要持续维护
Apr 05, 2025 pm 11:27 PM
H5页面需要持续维护，这是因为代码漏洞、浏览器兼容性、性能优化、安全更新和用户体验提升等因素。有效维护的方法包括建立完善的测试体系、使用版本控制工具、定期监控页面性能、收集用户反馈和制定维护计划。
如何获取58同城工作页面上的实时申请和浏览人数数据？
Apr 05, 2025 am 08:06 AM
如何在爬虫时获取58同城工作页面的动态数据？在使用爬虫工具爬取58同城的某个工作页面时，可能会遇到这样�...
为什么Flex布局中的紫色斜线区域会被误认为是'溢出空间”？
Apr 05, 2025 pm 05:51 PM
关于Flex布局中紫色斜线区域的疑问在使用Flex布局时，你可能会遇到一些令人困惑的现象，比如在开发者工具（d...
H5页面制作的素材从哪里获取
Apr 05, 2025 pm 11:33 PM
H5页面素材来源主要有：1. 专业素材网站（付费，质量高、版权清晰）；2. 自制素材（独特性高，但耗时费力）；3. 开源素材库（免费，需仔细筛选）；4. 图片/视频网站（需核实版权）。此外，素材风格统一、尺寸适配、压缩处理、版权保护是需要注意的关键点。
网站标题关键词更新后，搜索引擎为何仍显示旧标题？
Apr 04, 2025 pm 09:00 PM
网站标题关键词更新后为何搜索引擎未显示？许多站长在优化网站时，会修改网站的SEO设置和结构化数据，期望...
