不同数据源连接数据库

た入场券 2024-03-30 18:00 33阅读 0赞

一：不同数据源连接数据库

1.原生jdbc连接数据库

2.Druid数据源连接数据库

二：不同数据源连接数据库的配置

1.原生jdbc连接数据库

1.1：原生jdbc配置环境

hamcrest-core-1.3.jar
    junit-4.12.jar
    mysql-connector-java-5.1.7-bin.jar

1.2：编写db.properties

#连接MySQL数据库的配置文件 注：等号前后不要有空格
    #驱动名
    jdbcName=com.mysql.jdbc.Driver
    #获取数据库连接(book)是数据库的名称
    dbUrl=jdbc:mysql://localhost:3306/book
    #数据库的连接账号(账号基本上都是root)
    dbName=root
    #数据库的连接密码(每个人的数据库密码可能不一样，需要修改)
    dbPwd=root

1.3：创建工具类

package com.xxx.utils;
    
    import java.io.InputStream;
    import java.sql.*;
    import java.util.Properties;
    
    public class jdbcUtils {
        //得到配置文件对象
        private static Properties properties=new Properties();
    
        static {
            try{
                //加载配置文件(输入流)
                InputStream inputStream =
                        jdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");
                //通过load()方法将输入流的内容加载到配置文件中
                properties.load(inputStream);
                //通过配置文件对象的getProperty()方法获取驱动名，并加载驱动
                Class.forName(properties.getProperty("jdbcName"));
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    
        /**
         * 获取数据库连接
         * @return
         */
        public static Connection getconnection(){
            Connection connection=null;
            try {
                //得到数据库连接的相关信息
                String dbUrl=properties.getProperty("dbUrl");
                String dbName=properties.getProperty("dbName");
                String dbPwd=properties.getProperty("dbPwd");
                //得到数据库连接
                connection= DriverManager.getConnection(dbUrl,dbName,dbPwd);
            } catch (SQLException e) {
                e.printStackTrace();
            }
            return connection;
        }
    
        /**
         * 关闭资源
         * @param resultSet
         * @param connection
         * @param preparedStatement
         */
        public static void close(ResultSet resultSet,Connection connection,PreparedStatement preparedStatement){
            //判断资源对象 如果不为空，则关闭
            try {
                if (resultSet!=null){
                    resultSet.close();
                }
                if (connection!=null){
                    connection.close();
                }
                if (preparedStatement!=null){
                    preparedStatement.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

1.4：测试工具类

package com.xxx.test;
    
    import com.xxx.utils.jdbcUtils;
    import org.junit.Test;
    
    public class JdbcUtilsTest {
        /**
         * 单元测试方法
         * 1.方法的返回值，建议使用void,一般没有返回值
         * 2.参数列表，建议空参，一般是没有参数
         * 3.方法上都需要设置@Test注解
         * 4.每个方法都能独立运行
         *
         * 判断是否成功
         *  绿色：成功
         *  红的：失败
         */
        @Test
        public void TestJdbcUtils(){
            System.out.println(jdbcUtils.getconnection());
        }
    }

2.Druid数据源连接数据库

2.1：Druid数据源配置环境

druid-1.1.9.jar
    hamcrest-core-1.3.jar
    junit-4.12.jar
    mysql-connector-java-5.1.7-bin.jar

2.2：编写jdbc.properties

#获取数据库的连接账号
    username=root
    #数据库的连接密码(每个人的数据库密码可能不一样，需要修改)
    password=root
    #获取数据库连接(book是数据库的名称)
    url=jdbc:mysql://localhost:3306/book
    #连接MySQL数据库的配置文件 注：等号前后不要写空格
    #驱动名
    driverClassName=com.mysql.jdbc.Driver
    #连接池初始化的时候连接数
    initialSize=5
    #连接池中连接的最大个数
    maxActive=10

2.3：编写工具类

package com.xxx.utils;
    
    import com.alibaba.druid.pool.DruidDataSource;
    import com.alibaba.druid.pool.DruidDataSourceFactory;
    
    import java.io.InputStream;
    import java.sql.Connection;
    import java.sql.SQLException;
    import java.util.Properties;
    
    public class JdbcUtils {
        //得到dataSource对象
        private static DruidDataSource dataSource;
    
        //静态代码，初始化执行
        static {
            try{
                //得到配置文件对象
                Properties properties=new Properties();
                //加载配置文件(输入流)
                InputStream inputStream = JdbcUtils.class.getClassLoader().getResourceAsStream("jdbc.properties");
                //通过load()方法将输入流的内容加载到配置文件中
                properties.load(inputStream);
                //获得数据库连接池
                dataSource= (DruidDataSource) DruidDataSourceFactory.createDataSource(properties);
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    
        /**
         * 获取数据库连接池中的连接
         * @return 如果返回null,说明获取连接失败；有值说明成功
         */
        public static Connection getConnection(){
            Connection conn=null;
            try {
                conn= dataSource.getConnection();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            return conn;
        }
    
        /**
         * 关闭连接，放回数据库连接池
         * @param conn
         */
        public static void close(Connection conn){
            if (conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }

2.4：创建测试类

package com.xxx.test;
    
    import com.xxx.utils.JdbcUtils;
    import org.junit.Test;
    
    import java.sql.Connection;
    import java.sql.SQLException;
    
    public class jdbcUtilsTest {
        /**
         * 单元测试方法
         * 1.方法的返回值，建议使用void,一般没有返回值
         * 2.参数列表，建议空参，一般是没有参数的
         * 3.方法上需要放置@Test注解
         * 4.每个方法都能独立运行
         *
         * 运行成功的判断方法
         *  绿色：成功
         *  红的：失败
         */
    
        @Test
        public void TestJdbcUtils(){
            for (int i=0;i<5;i++){
                System.out.println(JdbcUtils.getConnection());
            }
    
            try {
                JdbcUtils.getConnection().close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

最后，创作不易，请大家多多支持