首页 / MYSQL / 项目中连接数据库的工具类

项目中连接数据库的工具类

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了项目中连接数据库的工具类，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含10141字，纯文字阅读大概需要15分钟。

内容图文

在项目有时会用到不同数据库，项目写了一个连接不同数据库（包括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 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();
            }
        }
    }
}

内容总结

以上是互联网集市为您收集整理的项目中连接数据库的工具类全部内容，希望文章能够帮你解决项目中连接数据库的工具类所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/562945.html

来源：【匿名】

【上一篇】FAILEDTOREADMORRORSIDE1 【下一篇】用IE远程创建Mysql数据库的简易程序

更多 ►

【项目中连接数据库的工具类】教程文章相关的互联网学习教程文章

虚拟机中安装mysql，远程连接数据库慢【代码】【图】

解决方法：在my.ini或者/etc/my.cnf下面添加skip-name-resolve如下是linux，打开my.cnf添加skip-name-resolve并保存，重启服务vim /etc/my.cnf #添加以下代码到[mysqld][mysqld] skip-name-resolve#重启服务service mysql restart 原文：https://www.cnblogs.com/passedbylove/p/12909587.html

php+mysql+pdo连接数据库【代码】

1.$pdo = new PDO("mysql:host=localhost;dbname=test","root","123456");//连接数据库 2.pdo操作方法query() 主要是用于有记录结果返回的操作，特别是SELECT操作 exec() 主要是针对没有结果集合返回的操作，如INSERT、UPDATE等操作 lastInsertId() 返回上次插入操作，主键列类型是自增的最后的自增ID fetch() 是用来获取一条记录 fetchAll() 是获取所有记录集到一个中 3.查询实例　　 $sql = "select * from mytable";$arr = $pd...

MySQL通过增加用户实现远程连接数据库

命令行进入mysql.exe所在目录mysql -uroot -padmin 例子：grant all privileges on *.* to joe@localhost identified by ‘1‘;flush privileges; MySQL> grant 权限1,权限2,…权限n on 数据库名称.表名称 to 用户名@用户地址 identified by ‘连接口令’;权限1,权限2,…权限n代表select,insert,update,delete,create,drop,index,alter,grant,references,reload,shutdown,process,file等14个权限。当权限1,权限2,…权限n被all priv...

Java中JDBC连接数据库（MySQL）

打开eclipse

MySQL通过localhost无法连接数据库的解决【代码】

问题：一台服务器的PHP程序通过localhost地址无法连接数据库，但是如果设置为127.0.0.1则可以正常连接，连接其他数据库服务器也正常。MySQL的权限设置正确，且通过mysql命令行客户端可以正常连接数据库。分析：这是典型的socket没有正确设置的情况。连接MySQL数据库有两种方式：TCP/IP（一般理解的端口的那种）和Unix套接字（一般叫socket或者sock）。大部分情况下，可以用localhost代表本机127.0.0.1，但是在MySQL连接时，二者不可...

wampserver修改mysql数据库密码后phpMyAdmin无法连接数据库

phpMyAdmin开始能打开，但是我在权限里把root的密码改了，再打开phpMyAdmin就显示：“phpMyAdmin 试图连接到 MySQL 服务器，但服务器拒绝连接。您应该检查 config.inc.php 中的主机、用户名和密码，并且确定这些信息与 MySQL 服务器的管理员所给出的信息一致。”，奇怪的是我把config.inc.php里的$cfg[‘Servers‘][$i][‘password‘]项里已经填上密码了呀，为什么还是不行呢？而且为什么phpMyAdmin没有登陆界面呢? 这里就有我来...

Mysql学习之十二：JDBC连接数据库之DriverManager方法

JDBC连接数据库 ?创建一个以JDBC连接数据库的程序，包括7个步骤： 1、载入JDBC驱动程序：在连接数据库之前。首先要载入想要连接的数据库的驱动到JVM（Java虚拟机）。这通过java.lang.Class类的静态方法forName(String className)实现。比如： try{ //载入MySql的驱动类 Class.forName("com.mysql.jdbc.Driver") ; }catch(ClassNotFoundException e){ System.out.println("找不...

GORM操作MySQL数据库-连接数据库以及对表的操作【代码】【图】

一、连接数据库： dsn := "root:123456@tcp(127.0.0.1:3306)/more?charset=utf8mb4&parseTime=True&loc=Local"db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{})if err != nil{return}账号：密码@tcp(127.0.0.1:3306)/库名二、迁移表package mainimport ("gorm.io/driver/mysql""gorm.io/gorm""time" )type User struct {ID intName stringCreatedTime time.Time } func main() {dsn := "root:123456@tcp(127.0.0.1:3306)...

如何正确获得mysql，access的ADO连接字符串，并使用该连接字符串连接数据库【图】

如何正确获得mysql的ADO连接字符串，摘自网页http://blog.csdn.net/zyq5945/article/details/5486393首先你正确安装了MYSQL的数据库驱动程序（mysql-connector-odbc-5.1.6-win32.msi ）1.在桌面上新建一个空的文本文件mysql.txt,重命名为mysql.udl；2.双击这个mysql.udl文件，打开“数据库连接属性”对话框，在“提供程序”页选择”Micrsoft Ole DB Provider for ODBC Drivers“，点击下一步；3.在“连接”页的,"指定数据源"选择"...

mysql的1067错误导致无法连接数据库

修改mysql的root密码导致无法连接数据库安装环境：MS WINDOWS 2003 SP1MYSQL版本：mysql-essential-5.1.51-win32故障现象：本来只是想改变下MYSQL的配置（原来的端口为默认3306，不安全），使用MySql自带的MySQL Server Instance Config Wizard修改后，在最后一步，执行到启动服务时就无休止的等待，只好结束Config 任务。试图通过“服务管理”来手工启动MySQL，出现1067错误提示。－－－－－－－－－－－－－－－－－－－－－－－...

postman-8-xmysql连接数据库【代码】【图】

前面的两个安装自己百度哈！1.Nodejs2.Npm3.安装Xmysqlnpm install xmysql -g4.安装成功之后，连接xmysqlxmysql -h 数据库的IP地址 -u 数据库的用户名 -p 密码 -d 数据库库名5.连接到数据库之后，我们如何查询数据，语法如下http://localhost:3000/api/数据库要查询的表名/id1）知道表的id，通过id来获取数据库的返回id前面的user是表示表名 2）查询某几个返回的字段，比如上面的数据库返回的字段太多，可能会影响我们的接口执行效...

Linux -Mysql-连接数据库【代码】【图】

所用命令：mysql -uroot 刚安装的系统是没有密码的mysql -uroot -p 密码登陆 service mysqld status 查看服务状态 mysql is not running mysql服务是停止状态mysql running mysql服务是启动状态1.连接数据库mysql -uroot 备注：输入此命令之后，会报错，这条命令的目录路径为[root@localhost ~]# ls /usr/local/mysql/bin/mysql/usr/local/mysql/bin/mysqlvi但是，这条命令并没有在环境变量path里面...

python使用mysqldb连接数据库操作方法示例详解

# -*- coding: utf-8 -*- #mysqldb # site www.jbxue.com import time, MySQLdb #连接 conn=MySQLdb.connect(host="localhost",user="root",passwd="",db="test",charset="utf8") cursor = conn.cursor() #写入 sql = "insert into user(name,created) values(%s,%s)" param = ("aaa",int(time.time())) n = cursor.execute(sql,param) print n #更新 sql = "update user set name=%s where id=3...

MySql命令行连接数据库【代码】

一、MySQL 连接本地数据库，用户名为“root”，密码“123”（注意：“-p”和“123” 之间不能有空格）C:\>mysql -h localhost -u root -p123二、MySQL 连接远程数据库（192.168.0.201），端口“3306”，用户名为“root”，密码“123”C:\>mysql -h 172.16.16.45 -P 3306 -u root -p123三、MySQL 连接本地数据库，用户名为“root”，隐藏密码C:\>mysql -h localhost -u root -p Enter password:四、MySQL 连接本地数据库，用户名为“...

jmeter连接数据库（MYSQL）【图】

在测试计划中导入数据库驱动jar包在线程组中添加JDBC Connection Configuration配置JDBC Connection Configuration在variable Name for created pool中填写要连接的数据库的名称--ECShop(任意名称)在Database Connection Configuration填写数据库相关参数数据库连接地址jdbc:mysql://数据库域名或IP:端口/数据库名称jdbc:mysq://ecshop.itsoso.cn:3306/ecshop选择数据库驱动数据库用户名数据库密码在线程组中添加JDBCrequestVari...

首页 / MYSQL / 项目中连接数据库的工具类

项目中连接数据库的工具类

内容导读

内容图文

内容总结

内容备注

内容手机端

【项目中连接数据库的工具类】教程文章相关的互联网学习教程文章

虚拟机中安装mysql，远程连接数据库慢【代码】【图】

php+mysql+pdo连接数据库【代码】

MySQL通过增加用户实现远程连接数据库

Java中JDBC连接数据库（MySQL）

MySQL通过localhost无法连接数据库的解决【代码】

wampserver修改mysql数据库密码后phpMyAdmin无法连接数据库

Mysql学习之十二：JDBC连接数据库之DriverManager方法

GORM操作MySQL数据库-连接数据库以及对表的操作【代码】【图】

如何正确获得mysql，access的ADO连接字符串，并使用该连接字符串连接数据库【图】

mysql的1067错误导致无法连接数据库

postman-8-xmysql连接数据库【代码】【图】

Linux -Mysql-连接数据库【代码】【图】

python使用mysqldb连接数据库操作方法示例详解

MySql命令行连接数据库【代码】

jmeter连接数据库（MYSQL）【图】

数据库 - 相关标签

项目 - 相关标签

MYSQL - 技术教程分类

MYSQL - 最新教程

MYSQL - 最热教程