Spring JDBCTemplate连接SQL Server之初体验

314598340

package com.autohome.dao;　　

　　
import com.autohome.model.User;
　　
import org.junit.BeforeClass;
　　
import org.junit.Test;
　　
import org.springframework.jdbc.core.JdbcTemplate;
　　
import org.springframework.jdbc.core.PreparedStatementSetter;
　　
import org.springframework.jdbc.core.RowCallbackHandler;
　　
import org.springframework.jdbc.datasource.DriverManagerDataSource;
　　

　　
import java.sql.PreparedStatement;
　　
import java.sql.ResultSet;
　　
import java.sql.SQLException;
　　
import java.sql.Types;
　　
import java.util.ArrayList;
　　
import java.util.Iterator;
　　
import java.util.List;
　　
import java.util.Map;
　　


　　
public>　　

　　
private static JdbcTemplate jdbcTemplate;
　　

　　
@BeforeClass
　　
public static void setUpClass(){
　　
DriverManagerDataSource dataSource=new DriverManagerDataSource();
　　
dataSource.setUrl("jdbc:sqlserver://127.0.0.1:1433;databaseName=test");
　　
dataSource.setDriverClassName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
　　
dataSource.setUsername("sa");
　　
dataSource.setPassword("");
　　

　　
jdbcTemplate=new JdbcTemplate(dataSource);
　　
}
　　

　　
@Test
　　
public void selectAll(){
　　
jdbcTemplate.query("select * from t_student", new RowCallbackHandler() {
　　
public void processRow(ResultSet resultSet) throws SQLException {
　　
System.out.println("====id:"+resultSet.getInt("id")+"===name:"+resultSet.getString("name"));
　　
}
　　
});
　　
}
　　

　　
@Test
　　
public void insert(){
　　
//SQL
　　
//int result = jdbcTemplate.update("insert into t_student (name,age) VALUES (?,?)",new Object[]{"Lin",30});
　　

　　
//避免sql参数注入
　　
int result = jdbcTemplate.update("insert into t_student (name,age) values(?,?)",
　　
new PreparedStatementSetter() {
　　
public void setValues(PreparedStatement ps) throws SQLException {
　　
ps.setString(1,"zhangsan");
　　
ps.setInt(2,35);
　　
}
　　
});
　　

　　
if(result>0){
　　
System.out.println("insert success...");
　　
}
　　
}
　　

　　
@Test
　　
public void update(){

　　
int result = jdbcTemplate.update("update t_student set Name=? ,Age=? where>　　
public void setValues(PreparedStatement ps) throws SQLException {
　　
ps.setString(1,"Linshuhao");
　　
ps.setInt(2,40);
　　
ps.setInt(3,3);
　　
}
　　
});
　　

　　
if(result>0){
　　
System.out.println("update success...");
　　
}
　　
}
　　

　　
@Test
　　
public void delete(){

　　
int result = jdbcTemplate.update("delete from t_student where>　　
if(result>0){
　　
System.out.println("delete success...");
　　
}
　　
}
　　

　　
@Test
　　
public void listAll(){
　　

　　
List<User> allUser = jdbcTemplate.query("SELECT * FROM t_student",new User());
　　
for(User user:allUser){
　　
System.out.println("===id:"+user.getId()+",name:"+user.getName()+",age:"+user.getAge());
　　
}
　　
}
　　

　　
@Test
　　
public void selectUser(){

　　
String sql="SELECT * FROM t_student where>　　

　　
User user =  (User) jdbcTemplate.queryForObject(sql,new Object[]{2},new User());
　　

　　
System.out.println("===id:"+user.getId()+",name:"+user.getName()+",age:"+user.getAge());
　　
}
　　
}