Cyh的博客

Email:kissyan4916@163.com
posts - 26, comments - 19, trackbacks - 0, articles - 220

Spring--JDBC模板

Posted on 2009-02-16 20:06 啥都写点 阅读(216) 评论(0)  编辑  收藏 所属分类: J2EE

àapplicationContext:

<beans>

       <bean id="dataSource"

              class="org.springframework.jdbc.datasource.DriverManagerDataSource">

              <property name="driverClassName">

                     <value>org.gjt.mm.mysql.Driver</value>

              </property>

              <property name="url">

                     <value>jdbc:mysql://localhost:3306/mldn</value>

              </property>

              <property name="username">

                     <value>root</value>

              </property>

              <property name="password">

                     <value>mysqladmin</value>

              </property>

       </bean>

       <bean id="def" class="cn.mldn.lxh.demo11.DefaultTemplate">

              <property name="jt">

                     <ref bean="template"/>

              </property>

       </bean>

       <bean id='template'

              class="org.springframework.jdbc.core.JdbcTemplate">

              <property name="dataSource">

                     <ref bean="dataSource"/>

              </property>

       </bean>

</beans>

à DefaultTemplate

public class DefaultTemplate {

       private JdbcTemplate jt;

       public void insert(Person person) {

              String sql = "INSERT INTO person(name,password) VALUES (?,?)";

              // 全部的值应该变为对象数组

              Object params[] = new Object[] { person.getName(), person.getPassword() };

              int type[] = new int[] { Types.VARCHAR, Types.VARCHAR };

              jt.update(sql, params, type);

       }

       public void update(Person person) {

              String sql = "UPDATE person SET name=?,password=? WHERE id=?";

              Object params[] = new Object[] { person.getName(),

                            person.getPassword(), new Integer(person.getId()) };

              int type[] = new int[] { Types.VARCHAR, Types.VARCHAR, Types.INTEGER };

              jt.update(sql, params, type);

       }

       public Person getPerson(int id) {

              final Person per = new Person();

              String sql = "SELECT id,name,password FROM person WHERE id=?";

              Object[] params = new Object[] { new Integer(id) };

              jt.query(sql, params, new RowCallbackHandler() {

                     public void processRow(ResultSet rs) throws SQLException {

                            per.setId(rs.getInt(1));

                            per.setName(rs.getString(2));

                            per.setPassword(rs.getString(3));

                     }

              });

              return per;

       }

       public int getCount() {

              final Person per = new Person() ;

              String sql = "SELECT COUNT(id) FROM person";

              Object[] params = new Object[] {};

              jt.query(sql, params, new RowCallbackHandler() {

                     public void processRow(ResultSet rs) throws SQLException {

                            per.setCount(rs.getInt(1)) ;

                     }

              });

              return per.getCount();

       }

       public List queryAll() {

              final List<Person> all = new ArrayList<Person>();

              String sql = "SELECT id,name,password FROM person";

              Object[] params = new Object[] {};

              jt.query(sql, params, new RowCallbackHandler() {

                     public void processRow(ResultSet rs) throws SQLException {

                            Person per = new Person();

                            per.setId(rs.getInt(1));

                            per.setName(rs.getString(2));

                            per.setPassword(rs.getString(3));

                            all.add(per);

                     }

              });

              return all;

       }

       public List<Person> queryAll(int currentPage, int lineSize) {

              final List<Person> all = new ArrayList<Person>();

              String sql = "SELECT id,name,password FROM person LIMIT "

                            + (currentPage - 1) * lineSize + "," + lineSize;

              Object[] params = new Object[] {};

              jt.query(sql, params, new RowCallbackHandler() {

                     public void processRow(ResultSet rs) throws SQLException {

                            Person per = new Person();

                            per.setId(rs.getInt(1));

                            per.setName(rs.getString(2));

                            per.setPassword(rs.getString(3));

                            all.add(per);

                     }

              });

              return all;

       }

       public void delete(int id) {

              String sql = "DELETE FROM person WHERE id=?";

              Object params[] = new Object[] { new Integer(id) };

              int type[] = new int[] { Types.INTEGER };

              jt.update(sql, params, type);

       }

       public JdbcTemplate getJt() {

              return jt;

       }

       public void setJt(JdbcTemplate jt) {

              this.jt = jt;

       }

}



                                                                                                       --    学海无涯
        


只有注册用户登录后才能发表评论。


网站导航: