访问SQLServer(2)-springboot导入jdbc的jar包自定义DBUtil连接SQLServer

1. 先在网上下载sqljdbc4.jar

2. 将sqljdbc4.jar复制到自己的工程中；鼠标右键--Add as Library...

3. 配置SQL数据库的连接： 

 4. 创建静态类访问spring上下文

package com.cx.common;

import org.springframework.context.ApplicationContext;

public class SpringContextUtil {
    private static ApplicationContext applicationContext;

    public static void setApplicationContext(ApplicationContext context) {
        applicationContext = context;
    }

    public static Object getBean(String beanId) {
        return applicationContext.getBean(beanId);
    }
}

5. 创建自定义访问类DBUtil.java

package com.cx.common;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.env.Environment;
import org.springframework.stereotype.Component;

import java.sql.*;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;

@Component
public class DBUtil {
    @Autowired
    private Environment environment;

    private Connection conn=null;
    private Statement stmt = null;

    public DBUtil(){
        //构造函数
    }

    //对外提供一个方法来获取数据库连接
    public  Connection getConnection(){
        if (conn == null) {
            try {
                String url = environment.getProperty("spring.datasource.url");
                String user = environment.getProperty("spring.datasource.username");
                String pwd = environment.getProperty("spring.datasource.password");
                //1.加载驱动程序
                Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
                //2.获得数据库的连接
                conn = (Connection) DriverManager.getConnection(url, user, pwd);
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        return conn;
    }

    public String executeScalar(String p_sql){
        String result="";
        try {
            conn = getConnection();
            stmt = conn.createStatement();
            ResultSet set = stmt.executeQuery(p_sql);
            if (set.next()){
                result = set.getString(1);
            }
            stmt.close();
            return result;
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return "";
    }

    public boolean executeSQL(String sql){
        try {
            conn = getConnection();
            stmt = conn.createStatement();
            stmt.execute(sql);
            stmt.close();
            return true;
        }
        catch (Exception e){
            return  false;
        }
    }
}

6. 控制类调用：

7. 运行测试：