Spring中的面向对象查询

Spring JDBC的操作还是使用了sql语句，如果对sql不是非常熟悉的程序员可能在运用的过程中还有些麻烦，为此Spring提供了org.springframework.jdbc.object包来设计完全面向对象查询，只要封装一个面向对象的查询类，丝毫不用写任何的sql语句就可以完成JdbcTemplate所有的数据库操作功能。

publicclassUser...{
privateLongid;
privateStringuserName;
privateStringpassWord;
//set/get方法
}

1、org.springframework.jdbc.object.SqlQuery

SqlQuery是主查询类，他提供了强大的查询功能，不过他的查询返回值将会放到一个RowMapper中进行处理，所以在使用SqlQuery的时候要定义一个自己的RowMapper，然后给返回值放到自定义的RowMapper中，这样就完成了查询工作，示例如下：

首先定义一个UserRowMapper，该类实现RowMapper接口，代码如下：

publicclassUserRowMapperimplementsRowMapper...{
publicObjectmapRow(ResultSetrs,introwNum)throwsSQLException...{
Useruser=newUser();
user.setId(newLong(rs.getLong("id")));
user.setUserName(rs.getString("username"));
user.setPassWord(rs.getString("password"));
returnuser;
}
}

UserRowMapper类中只有一个mapRow方法，该方法就是将返回结果记录集ResultSet的值封装到User类中；

定义一个UserSqlQuery类，该类继承SqlQuery，代码如下：

publicclassUserSqlQueryextendsSqlQuery...{
publicUserSqlQuery(DataSourcedataSource)...{
super(dataSource,"select*fromuserwhereid=?");
int[]types=...{Types.LONGVARCHAR};
setTypes(types);
compile();
}
protectedRowMappernewRowMapper(Object[]args,Mapmap)...{
UserRowMapperurm=newUserRowMapper();
returnurm;
}
}

UserSqlQuery类首先定义了一个构造函数，在构造函数中调用了SqlQuery中的

SqlQuery(DataSourceds, Stringsql)完成数据源以及sql的注入，在sql中仍然用“？”作为占位符，int[] types数组为占位符设置sql字段属性，这里为LONGVARCHAR，最后调用compile()方法编译，执行sql返回值将有newRowMapper方法返回，这里我们直接使用了自定义的UserRowMapper来记录返回值，完成上述步骤后，就可以在UserDAO的find()方法中使用这个查询了：

publicUserfind(Longid)...{
Listlist=userSqlQuery.execute(newObject[]...{id});
return(User)list.get(0);
}

SqlQuery提供了很多的execute方法来执行查询，详情可以参考Spring的API文档，这里使用了execute传递一个id参数，因为返回值是一个数组而且数组中只有一个User对象，所以直接使用了(User)list.get(0)。

2、org.springframework.jdbc.object.MappingSqlQuery

MappingSqlQuery类是SqlQuery类的子类，使用MappingSqlQuery查询就不用使用RowMapper处理返回值了，直接写一个UserMappingSqlQuery类类继承MappingSqlQuery，代码如下：

publicclassUserMappingSqlQueryextendsMappingSqlQuery...{
publicUserMappingSqlQuery(DataSourcedataSource)...{
super(dataSource,"select*fromuserwhereid=?");
int[]types=...{Types.LONGVARCHAR};
setTypes(types);
compile();
}
protectedObjectmapRow(ResultSetrs,introwNum)throwsSQLException...{Useruser=newUser();
user.setId(newLong(rs.getLong("id")));
user.setUserName(rs.getString("username"));
user.setPassWord(rs.getString("password"));
returnuser;
}
}

UserMappingSqlQuery中首先还是使用SqlQuery中的构造函数完成数据源和sql的注入，返回值直接通过mapRow方法来完成，接着就可以这么使用它了：

UserMappingSqlQueryuserMappingSqlQuery=newUserMappingSqlQuery(dataSource);
userMappingSqlQuery.execute(newObject[]...{id});

返回值还是一个list，list中就是查询出来的User对象。

3、org.springframework.jdbc.object.SqlUpdate

SqlUpdate类用来表示一个类的更新，当然前面的SqlQuery和MappiingSqlQuery同样可以执行更新的sql语句，不过Spring为了适应人们的编程习惯，特意设计了SqlUpdate类来执行更新(update)、记录(insert)等操作，SqlUpdate类的使用更加简单，只要通过构造函数完成数据源和sql注入即可，定义一个自己的UserSqlUpdate，代码如下：
构造方法和上面的SqlQuery、MappingSqlQuery一样，这里不过多重复，接着就可以如下来使用了：

publicclassUserSqlUpdateextendsSqlUpdate...{
publicUserSqlUpdate(DataSourcedataSource)...{
super(dataSource,"insertintouser(username,password)values(?,?)");
int[]types=...{java.sql.Types.VARCHAR,java.sql.Types.VARCHAR};
setTypes(types);
compile();
}
}

UserSqlUpdateuserSqlUpdate=newUserSqlUpdate(dataSource);
Useruser=newUser();
user.setUserName("erikchang");
user.setPassWord("123456");
userSqlUpdate.update(newObject[]...{user.getUserName(),user.getPassWord});

SqlUpdate实例直接调用update方法来完成参数的传递以及sql的执行。

4、org.springframework.jdbc.object.SqlFunction

SqlFunction类是MappingSqlQuery的一个子类，他也就是具备了MappingSqlQuery的所有功能，不过SqlFunction实例的调用使用run或runGeneric方法来完成，同样可以在run()或runGeneric()方法中传递一个数组作为sql的参数，其中run()方法返回int类型的，一般用在数量的查询，runGenetic()方法返回一个对象，使用时首先定义一个UserSqlFucntion如下：

publicclassUserSqlFunctionextendsSqlFunction...{
publicUserSqlFunction(DataSourcedataSource)...{
super(dataSource,"select*fromuserwhereid=?");
int[]types=...{Types.LONGVARCHAR};
setTypes(types);
compile();
}
}

接着就可以如下来查询：

UserSqlFunctionuserSqlFunction=newUserSqlFunction(dataSource);
(User)userSqlFunction.runGeneric(newObject[]...{id});

如果在UserSqlFunction的构造函数中sql为:select count(*) from user,在使用的时候就直接使用userSqlFunction.run();
文章系eirkchang所有，转载注明作者！