Cyh的博客

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

          Spring--JDBC模板

          Posted on 2009-02-16 20:06 啥都寫點 閱讀(224) 評論(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;

                 }

          }



                                                                                                                 --    學海無涯
                  

          主站蜘蛛池模板: 陆河县| 马边| 宜君县| 莱州市| 沽源县| 弥渡县| 大安市| 瑞丽市| 荥阳市| 江城| 册亨县| 连江县| 波密县| 芜湖县| 梧州市| 且末县| 漠河县| 舞钢市| 光山县| 新丰县| 宜都市| 永丰县| 牡丹江市| 尖扎县| 大安市| 汾阳市| 天峻县| 德昌县| 隆回县| 鄂尔多斯市| 嵊泗县| 岐山县| 杭锦旗| 大竹县| 东乌珠穆沁旗| 泾源县| 梅河口市| 色达县| 丰台区| 福安市| 年辖:市辖区|