快捷導(dǎo)航

Java中String的JdbcTemplate連接SQLServer數(shù)據(jù)庫的方法

更新時間：2021年10月27日 11:07:11 作者：勝金

這篇文章主要介紹了Java中String的JdbcTemplate連接SQLServer數(shù)據(jù)庫的方法,在研發(fā)過程中我們需要與其他系統(tǒng)對接的場景，連接SQLServer拉取數(shù)據(jù)，所以就用jdbc連接數(shù)據(jù)庫的方式連接外部數(shù)據(jù)源，需要的朋友可以參考下

　　很久沒寫文章了，一方面是最近幾個月比較忙，沒太多時間，另一方面是最近拖延癥嚴重，寫文章的想法總是一拖再拖。今天找一個小案例寫一下，與懶惰對抗一下。

　　首先說一下背景，我們在項目中做數(shù)據(jù)持久化一般都是用mybatis或者hibernate開發(fā)框架，進行數(shù)據(jù)庫連接和操作，最近做GIS仿真產(chǎn)品研發(fā)，根據(jù)需求需要保存三部分數(shù)據(jù)：1、業(yè)務(wù)數(shù)據(jù)，數(shù)據(jù)量比較小；2、GIS數(shù)據(jù)，需要用到空間關(guān)系；3、物聯(lián)數(shù)據(jù)，數(shù)據(jù)量大，在我們開發(fā)自測階段數(shù)據(jù)量就可以達到每天百萬以上。根據(jù)以上數(shù)據(jù)特點，我們使用了傳統(tǒng)的MySQL數(shù)據(jù)庫、空間數(shù)據(jù)庫PostgreSQL、TD engine時序數(shù)據(jù)庫，項目中做了spring boot多數(shù)據(jù)源動態(tài)切換。今天的重點不是多數(shù)據(jù)源的實現(xiàn)，這個應(yīng)用以后會在另外一篇文章中介紹；在研發(fā)過程中我們需要與其他系統(tǒng)對接的場景，連接SQLServer拉取數(shù)據(jù)，項目本身已經(jīng)做了多數(shù)據(jù)源，如果繼續(xù)添加數(shù)據(jù)源就加大了系統(tǒng)的難度，所以就用jdbc連接數(shù)據(jù)庫的方式連接外部數(shù)據(jù)源，下面看代碼。

一、引入依賴jar包

　　項目用的是Spring Boot，創(chuàng)建好項目以后，引入下面依賴：

<dependencies>
        
        <dependency>
            <groupId>com.microsoft.sqlserver</groupId>
            <artifactId>mssql-jdbc</artifactId>
            <scope>runtime</scope>
        </dependency>

    </dependencies>

二、Utils開發(fā)

　　1、創(chuàng)建實體類，實現(xiàn)org.springframework.jdbc.core.RowMappe接口的mapRow(ResultSet rs, int rowNum)方法。

package com.johan.handler.task.iotSync.bean;
import lombok.Data;
import org.apache.commons.lang3.StringUtils;
import org.springframework.jdbc.core.RowMapper;

import java.sql.ResultSet;
import java.sql.SQLException;

/**
 * @author: Johan
 * @date: 2021/10/18
 * @desc: IOT信息
 */
@Data
public class IotDG implements RowMapper {
    /**
     * 標簽名稱
     */
    private String tagName;

    /**
     * 標簽描述
     */
    private String tagDesc;

    /**
     * 標簽值
     */
    private Double tagVal;

    /**
     * 標簽單位
     */
    private String tagUnit;

    /**
     * 類型，0 壓力，1 流量
     */
    private String type;


    @Override
    public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
        IotDG iotDG = new IotDG();
        iotDG.setTagName(rs.getString("TagName"));
        iotDG.setTagDesc(rs.getString("TagDesc"));
        iotDG.setTagVal(rs.getDouble("Value"));
        iotDG.setTagUnit(rs.getString("TagUnit"));
        iotDG.setType(rs.getString("Type"));

        return iotDG;
    }
}

　　2、連接數(shù)據(jù)庫，讀取表數(shù)據(jù)

package com.johan.handler.task.iotSync.iotConvert;

import com.johan.handler.task.iotSync.bean.IotDG;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DriverManagerDataSource;

import java.sql.*;
import java.util.List;

/**
 * @author johan
 * @Description SQL server
 * @time 2021/10/18 18:26
 */
public class JDBCUtils {

    private static JdbcTemplate jdbcTemplate;
    static {
        String driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
        String url ="jdbc:sqlserver://10.25.23.172:1433;databaseName=SCADA_Data_3040";//連接地址
        String user ="SLSL";//用戶
        String password ="Admin@3040";//密碼

        DriverManagerDataSource dataSource=new DriverManagerDataSource();
        dataSource.setUrl(url);
        dataSource.setDriverClassName(driver);
        dataSource.setUsername(user);
        dataSource.setPassword(password);

        jdbcTemplate=new JdbcTemplate(dataSource);
    }


    public static List<IotDG> listAll(int type){
        String sql = "SELECT * FROM RealData where Type=" + type;

//        System.out.println(iotDGList);
        return jdbcTemplate.query(sql,new IotDG());
    }


}

　　3、測試

　　方法是靜態(tài)的，直接調(diào)用即可。

package com.johan.domain.iot;

import com.johan.handler.task.iotSync.bean.IotDG;
import com.johan.handler.task.iotSync.iotConvert.JDBCUtils;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;

import java.util.List;

/**
 * @author johan
 * @time 2021/10/22 17:57
 */
@SpringBootTest
@Slf4j
public class IotDomainTest {

    @Test
    public void jdbcTest(){
        List<IotDG> iotDGList = JDBCUtils.listAll(0);
        System.out.println(iotDGList);
    }

}

　　不只是SQLServer，我們常用的MySQL、Oracle等都可以用JdbcTemplate連接。

到此這篇關(guān)于Java中String的JdbcTemplate連接SQLServer數(shù)據(jù)庫的文章就介紹到這了,更多相關(guān)java中JdbcTemplate連接SQLServer數(shù)據(jù)庫內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: