使用JDBC做的增删改查

业务类

public class UserDaoImpl implements UserDao{

// 定义一个Jdbc

private JdbcTemplate jt;

// 必须有set 方法，因为是通过set方法装配的

public void setJt(JdbcTemplate jt) {

this.jt = jt;

}

@Override

public void delete(int id) {

// TODO Auto-generated method stub

String sql="delete from user where id="+id;

int temp=this.jt.update(sql);

if(temp>0){

System.out.println("删除成功！");

}else{

System.out.println("删除失败！");

}

}

@Override

public void insert(User entity) {

// TODO Auto-generated method stub

String sql="insert into user(name,age,sex) values(?,?,?)";

Object obj[]={entity.getName(),entity.getAge(),entity.getSex()};

int temp=this.jt.update(sql,obj);

if(temp>0){

System.out.println("插入成功！");

}else{

System.out.println("插入失败！");

}

}

@Override

public List selectAll() {

String sql="select * from user";

List list=this.jt.query(sql,new RowMapper(){

@Override

public Object mapRow(ResultSet rs, int row) throws SQLException {

// TODO Auto-generated method stub

User user=new User();

user.setId(rs.getInt("id"));

user.setName(rs.getString("name"));

user.setAge(rs.getInt("age"));

user.setSex(rs.getString("sex"));

return user;

}

});

System.out.println(list.size());

// TODO Auto-generated method stub

return list;

}

@Override

public User selectById(int id) {

// TODO Auto-generated method stub

String sql="select id,name,age,sex from user where id="+id;

User user=(User)jt.queryForObject(sql, new RowMapper(){

@Override

public Object mapRow(ResultSet rs, int arg1) throws SQLException {

// TODO Auto-generated method stub

User user=new User();

user.setId(rs.getInt("id"));

user.setName(rs.getString("name"));

user.setAge(rs.getInt("age"));

user.setSex(rs.getString("sex"));

return user;

}

});

return user;

}

@Override

public void update(User entity) {

// TODO Auto-generated method stub

String sql="update user set name=?,age=?,sex=? where id=?";

Object obj[]={entity.getName(),entity.getAge(),entity.getSex(),entity.getId()};

int temp=jt.update(sql,obj);

if(temp>0){

System.out.println("更新成功！");

}else{

System.out.println("更新失败！");

}

}

}

Xml中的部分代码

1.   

2. <context:property-placeholder location="jdbc.properties" />  

3.   

4. "comboPooledDataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">  

5.       

6.     "driverClass">  

7.         ${driverClass}  

8.       

9.       

10.     "user">  

11.         ${username}  

12.       

13.       

14.     "password">  

15.         ${password}  

16.       

17.       

18.     "jdbcUrl">  

19.         ${url}  

20.       

21.       

22.     "maxPoolSize">  

23.         ${c3p0.pool.max}  

24.       

25.       

26.     "minPoolSize">  

27.         ${c3p0.pool.min}  

28.       

29.       

30.     "initialPoolSize">  

31.         ${c3p0.pool.init}  

32.       

33.   

34.   

35. "background-color: #ffff00;">"background-color: #f9b3ec;">"background-color: #f9b3ec;">"background-color: #ff0000;">"jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">  

36.     arg ref="comboPooledDataSource" />  

37.   

38.   

39. "userDaoImpl" class="cn.csdn.dao.UserDaoImpl">  

40.     "jt" ref="jdbcTemplate" />  

41.   

使用NamedParameterJdbcTemplate类，实现JDBC，参数是用Map集合传递的

业务类：

1. public class UserDaoImpl2 implements UserDao{  

2. //  定义一个Jdbc  

3.     private NamedParameterJdbcTemplate npjt;  

4. //  必须有set 方法，因为NamedParameterJdbcTemplate类是用set方法加载的  

5.     public void setNpjt(NamedParameterJdbcTemplate npjt){  

6.         this.npjt=npjt;  

7.     }  

8.     @Override  

9.     public void delete(int id) {  

10.         // TODO Auto-generated method stub  

11.         String sql="delete from user where id=:id";  

12.         Map<String,Object> map=new HashMap<String,Object>();  

13.         map.put("id", id);  

14.         int temp=this.npjt.update(sql,map);  

15.         if(temp>0){  

16.             System.out.println("删除成功！");  

17.         }else{  

18.             System.out.println("删除失败！");  

19.         }  

20.     }  

21.   

22.     @Override  

23.     public void insert(User entity) {  

24.         // TODO Auto-generated method stub  

25.         String sql="insert into user(name,age,sex) values(:name,:age,:sex)";  

26.         Map<String,Object> map=new HashMap<String,Object>();  

27.         map.put("name", entity.getName());  

28.         map.put("age", entity.getAge());  

29.         map.put("sex", entity.getSex());  

30.         int temp=npjt.update(sql, map);  

31.         if(temp>0){  

32.             System.out.println("插入成功！");  

33.         }else{  

34.             System.out.println("插入失败！");  

35.         }  

36.     }  

37. //  

38. //    

39. //  

40.     @Override  

41.     public List selectAll() {  

42.         String sql="select * from user";  

43. //      List list=this.npjt.queryForList(sql, new HashMap());  

44.         List list=npjt.query(sql, new HashMap(),new RowMapper(){  

45.   

46.             @Override  

47.             public Object mapRow(ResultSet rs, int arg1) throws SQLException {  

48.                 // TODO Auto-generated method stub  

49.                 User user=new User();  

50.                 user.setId(rs.getInt("id"));  

51.                 user.setName(rs.getString("name"));  

52.                 user.setAge(rs.getInt("age"));  

53.                 user.setSex(rs.getString("sex"));                 

54.                 return user;  

55.             }  

56.               

57.         });  

58.         System.out.println(list.size());  

59.         return list;  

60.     }  

61.       

62.     @Override  

63.     public User selectById(int id) {  

64.         // TODO Auto-generated method stub  

65.         String sql="select id,name,age,sex from user where id=1";  

66.           

67.         Map map=new HashMap();          

68.         map.put("id", id);  

69.         User user=(User)npjt.queryForObject(sql, map, new RowMapper(){  

70.   

71.             @Override  

72.             public Object mapRow(ResultSet rs, int arg1) throws SQLException {  

73.                 User user=new User();  

74.                 user.setId(rs.getInt("id"));  

75.                 user.setName(rs.getString("name"));  

76.                 user.setAge(rs.getInt("age"));  

77.                 user.setSex(rs.getString("sex"));                 

78.                 return user;  

79.             }  

80.               

81.         });  

82.         return user;      

83.     }  

84. //  

85.     @Override  

86.     public void update(User entity) {  

87.         // TODO Auto-generated method stub  

88.         String sql="update user set name=:name,age=:age,sex=:sex where id=:id";  

89.         Map<String,Object> map=new HashMap<String,Object>();  

90.         map.put("name", entity.getName());  

91.         map.put("age", entity.getAge());  

92.         map.put("sex", entity.getSex());  

93.         map.put("id", entity.getId());  

94.         int temp=npjt.update(sql, map);  

95.         if(temp>0){  

96.             System.out.println("更新成功！");  

97.         }else{  

98.             System.out.println("更新失败！");  

99.         }  

100.     }  

101.   

102. }

xml中的代码：

1.   

2.     "jdbc.properties" />  

3.       

4.     "comboPooledDataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">  

5.           

6.         "driverClass">  

7.             ${driverClass}  

8.           

9.           

10.         "user">  

11.             ${username}  

12.           

13.           

14.         "password">  

15.             ${password}  

16.           

17.           

18.         "jdbcUrl">  

19.             ${url}  

20.           

21.           

22.         "maxPoolSize">  

23.             ${c3p0.pool.max}  

24.           

25.           

26.         "minPoolSize">  

27.             ${c3p0.pool.min}  

28.           

29.           

30.         "initialPoolSize">  

31.             ${c3p0.pool.init}  

32.           

33.       

34.       

35.       

36.       

37.     "background-color: #ff0000;">  

38.     "namedParameterJdbcTemplate" class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate">  

39.     arg ref="comboPooledDataSource"/>  

40.       

41.       

42.     "userDaoImpl" class="cn.csdn.dao.UserDaoImpl2">  

43.         "npjt" ref="namedParameterJdbcTemplate" />  

44.     

3、使用SimpleJdbcTemplate类，实现JDBC，参数是用可变参数传递的

业务类：

1. public class UserDaoImpl3 implements UserDao{  

2. //  定义一个Jdbc  

3.     private SimpleJdbcTemplate sjt;  

4. //  必须有set 方法  

5.     public void setSjt(SimpleJdbcTemplate sjt){  

6.         this.sjt=sjt;  

7.     }  

8.       

9.     @Override  

10.     public void delete(int id) {  

11.         // TODO Auto-generated method stub  

12.         String sql="delete from user where id=?";         

13.         int temp=this.sjt.update(sql, id);  

14.         if(temp>0){  

15.             System.out.println("删除成功！");  

16.         }else{  

17.             System.out.println("删除失败！");  

18.         }  

19.     }  

20.   

21.     @Override  

22.     public void insert(User entity) {  

23.         // TODO Auto-generated method stub  

24.         String sql="insert into user(name,age,sex) values(?,?,?)";  

25.   

26.         int temp=sjt.update(sql,entity.getName(),entity.getAge(),entity.getSex());  

27.         if(temp>0){  

28.             System.out.println("插入成功！");  

29.         }else{  

30.             System.out.println("插入失败！");  

31.         }  

32.     }  

33.   

34.     @Override  

35.     public List selectAll() {  

36.         String sql="select * from user";  

37.         List list=this.sjt.queryForList(sql);  

38.   

39.         System.out.println(list.size());  

40.         return list;  

41.     }  

42.   

43.     @Override  

44.     public User selectById(int id) {  

45.         // TODO Auto-generated method stub  

46.         String sql="select id,name,age,sex from user where id=?";  

47.         User user=(User) sjt.queryForObject(sql, new ParameterizedRowMapper() {  

48.   

49.             @Override  

50.             public Object mapRow(ResultSet rs, int arg1) throws SQLException {  

51.                 User user=new User();  

52.                 user.setId(rs.getInt("id"));  

53.                 user.setName(rs.getString("name"));  

54.                 user.setAge(rs.getInt("age"));  

55.                 user.setSex(rs.getString("sex"));                 

56.                 return user;  

57.             }  

58.         }, id);  

59.         return user;  

60.     }  

61.   

62.     @Override  

63.     public void update(User entity) {  

64.         // TODO Auto-generated method stub  

65.         /**第一种方法*/  

66. //      String sql="update user set name=?,age=?,sex=? where id=?";  

67.           

68. //      int temp=sjt.update(sql, entity.getName(),entity.getAge(),entity.getSex(),entity.getId());  

69.     /**第二种方法*/    

70.         String sql="update user set name=:name,age=:age,sex=:sex where id=:id";  

71.         Map<String,Object> map=new HashMap<String,Object>();  

72.         map.put("name", entity.getName());  

73.         map.put("age", entity.getAge());  

74.         map.put("sex", entity.getSex());  

75.         map.put("id", entity.getId());  

76.         int temp=sjt.update(sql, map);  

77.         if(temp>0){  

78.             System.out.println("更新成功！");  

79.         }else{  

80.             System.out.println("更新失败！");  

81.         }  

82.     }  

83.   

84. }

xml中的部分代码

1.   

2.     "jdbc.properties" />  

3.       

4.     "comboPooledDataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">  

5.           

6.         "driverClass">  

7.             ${driverClass}  

8.           

9.           

10.         "user">  

11.             ${username}  

12.           

13.           

14.         "password">  

15.             ${password}  

16.           

17.           

18.         "jdbcUrl">  

19.             ${url}  

20.           

21.           

22.         "maxPoolSize">  

23.             ${c3p0.pool.max}  

24.           

25.           

26.         "minPoolSize">  

27.             ${c3p0.pool.min}  

28.           

29.           

30.         "initialPoolSize">  

31.             ${c3p0.pool.init}  

32.           

33.       

34.       

35.       

36.       

37.     "background-color: #ff0000;">  

38.     "simpleJdbcTemplate" class="org.springframework.jdbc.core.simple.SimpleJdbcTemplate">  

39.     arg ref="comboPooledDataSource"/>  

40.       

41.       

42.     "userDaoImpl" class="cn.csdn.dao.UserDaoImpl3">  

43.         "sjt" ref="simpleJdbcTemplate" />  

44.       

本文来源：https://www.2haoxitong.net/k/doc/faaab381e518964bce847c10.html