Java中String的JdbcTemplate连接SQLServer数据库的方法

<dependencies>

         <dependency>

             <groupId>com.microsoft.sqlserver</groupId>

             <artifactId>mssql-jdbc</artifactId>

             <scope>runtime</scope>

         </dependency>

     </dependencies>

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

import lombok.Data;

import org.apache测试数据mons.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;

     }

}

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());

     }

}

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);

     }

}