Java中String的JdbcTemplate連接SQLServer數(shù)據(jù)庫(kù)的方法
很久沒(méi)寫文章了,一方面是最近幾個(gè)月比較忙,沒(méi)太多時(shí)間,另一方面是最近拖延癥嚴(yán)重,寫文章的想法總是一拖再拖。今天找一個(gè)小案例寫一下,與懶惰對(duì)抗一下。
首先說(shuō)一下背景,我們?cè)陧?xiàng)目中做數(shù)據(jù)持久化一般都是用mybatis或者h(yuǎn)ibernate開發(fā)框架,進(jìn)行數(shù)據(jù)庫(kù)連接和操作,最近做GIS仿真產(chǎn)品研發(fā),根據(jù)需求需要保存三部分?jǐn)?shù)據(jù):1、業(yè)務(wù)數(shù)據(jù),數(shù)據(jù)量比較??;2、GIS數(shù)據(jù),需要用到空間關(guān)系;3、物聯(lián)數(shù)據(jù),數(shù)據(jù)量大,在我們開發(fā)自測(cè)階段數(shù)據(jù)量就可以達(dá)到每天百萬(wàn)以上。根據(jù)以上數(shù)據(jù)特點(diǎn),我們使用了傳統(tǒng)的MySQL數(shù)據(jù)庫(kù)、空間數(shù)據(jù)庫(kù)PostgreSQL、TD engine時(shí)序數(shù)據(jù)庫(kù),項(xiàng)目中做了spring boot多數(shù)據(jù)源動(dòng)態(tài)切換。今天的重點(diǎn)不是多數(shù)據(jù)源的實(shí)現(xiàn),這個(gè)應(yīng)用以后會(huì)在另外一篇文章中介紹;在研發(fā)過(guò)程中我們需要與其他系統(tǒng)對(duì)接的場(chǎng)景,連接SQLServer拉取數(shù)據(jù),項(xiàng)目本身已經(jīng)做了多數(shù)據(jù)源,如果繼續(xù)添加數(shù)據(jù)源就加大了系統(tǒng)的難度,所以就用jdbc連接數(shù)據(jù)庫(kù)的方式連接外部數(shù)據(jù)源,下面看代碼。
一、引入依賴jar包
項(xiàng)目用的是Spring Boot,創(chuàng)建好項(xiàng)目以后,引入下面依賴:
<dependencies>
<dependency>
<groupId>com.microsoft.sqlserver</groupId>
<artifactId>mssql-jdbc</artifactId>
<scope>runtime</scope>
</dependency>
</dependencies>
二、Utils開發(fā)
1、創(chuàng)建實(shí)體類,實(shí)現(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 {
/**
* 標(biāo)簽名稱
*/
private String tagName;
/**
* 標(biāo)簽描述
*/
private String tagDesc;
/**
* 標(biāo)簽值
*/
private Double tagVal;
/**
* 標(biāo)簽單位
*/
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ù)庫(kù),讀取表數(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、測(cè)試
方法是靜態(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ù)庫(kù)的文章就介紹到這了,更多相關(guān)java中JdbcTemplate連接SQLServer數(shù)據(jù)庫(kù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- java連接sql server 2008數(shù)據(jù)庫(kù)代碼
- java連接SQL Server數(shù)據(jù)庫(kù)的方法
- 用Java連接sqlserver數(shù)據(jù)庫(kù)時(shí)候幾個(gè)jar包的區(qū)別分析
- java 連接sql server2008數(shù)據(jù)庫(kù)配置
- java連接SQL?Server數(shù)據(jù)庫(kù)的超詳細(xì)教程
- Java連接sqlserver2008數(shù)據(jù)庫(kù)代碼
- java連接mysql數(shù)據(jù)庫(kù) java連接sql server數(shù)據(jù)庫(kù)
- 通過(guò)Java連接SQL?Server數(shù)據(jù)庫(kù)的超詳細(xì)操作流程
相關(guān)文章
Spring定時(shí)任務(wù)無(wú)故停止又不報(bào)錯(cuò)的解決
這篇文章主要介紹了Spring定時(shí)任務(wù)無(wú)故停止又不報(bào)錯(cuò)的解決,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-11-11
Spring Security無(wú)法調(diào)用接口錯(cuò)誤的問(wèn)題解決
記錄一下之前在寫程序的時(shí)候遇到的問(wèn)題,Spring Security無(wú)法調(diào)用接口錯(cuò)誤的問(wèn)題,本文就來(lái)介紹一下解決方法,感興趣的可以了解一下2023-08-08
SpringCloud Gateway網(wǎng)關(guān)功能介紹與使用
SpringCloud Gateway 是 Spring Cloud 的一個(gè)全新項(xiàng)目,它旨在為微服務(wù)架構(gòu)提供一種簡(jiǎn)單有效的統(tǒng)一的 API 路由管理方式。這篇文章主要介紹了SpringCloud Gateway網(wǎng)關(guān)作用,需要的朋友可以參考下2022-12-12
MyBatis映射文件中parameterType與resultType的用法詳解
MyBatis中的ParameterType指的是SQL語(yǔ)句中的參數(shù)類型,即傳入SQL語(yǔ)句中的參數(shù)的類型,下面這篇文章主要給大家介紹了關(guān)于MyBatis映射文件中parameterType與resultType用法的相關(guān)資料,需要的朋友可以參考下2023-04-04
java字符串轉(zhuǎn)數(shù)字及各種數(shù)字轉(zhuǎn)字符串的3種方法
這篇文章主要介紹了java字符串轉(zhuǎn)數(shù)字及各種數(shù)字轉(zhuǎn)字符串的3種方法,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2023-09-09
Javaweb使用cors完成跨域ajax數(shù)據(jù)交互
本文由跨域、cors的概念開始,進(jìn)而向大家介紹了Javaweb使用cors完成跨域ajax數(shù)據(jù)交互的相關(guān)內(nèi)容,需要的朋友可以了解下。2017-09-09

