1. 包列表
  2. 类列表
  3. org.springframework.jdbc.core.namedparam.BeanPropertySqlParameterSource

Java 类org.springframework.jdbc.core.namedparam.BeanPropertySqlParameterSource 实例源码

项目：nbone    文件：NamedJdbcDao.java    
@Override
public Object add(Object object) {
    SqlModel<Object> sqlModel = sqlBuilder.insertSelectiveSql(object);
    checkSqlModel(sqlModel);

    SqlParameterSource paramSource =  new BeanPropertySqlParameterSource(object);
    KeyHolder generatedKeyHolder =  new  GeneratedKeyHolder();
    namedPjdbcTemplate.update(sqlModel.getSql(), paramSource, generatedKeyHolder);
    Number num = generatedKeyHolder.getKey();

    String[] primaryKeys = sqlModel.getPrimaryKeys();
    if(primaryKeys != null && primaryKeys.length > 0){
        BeanWrapper beanWrapper = PropertyAccessorFactory.forBeanPropertyAccess(object);
        beanWrapper.setPropertyValue(primaryKeys[0], num);
    }

    return object;
}
项目：nbone    文件：NamedJdbcDao.java    
@Override
public int[] batchUpdate(Collection<?> objects) {
    SqlParameterSource[] batchArgs = new BeanPropertySqlParameterSource[objects.size()];
    String sql = null;
    int index = 0;
    for (Object object : objects) {
        if(index == 0 ){
            //XXX: thinking 共享第一实体的sql
            SqlModel<Object> sqlModel = sqlBuilder.updateSql(object);
            sql = sqlModel.getSql();
        }
        batchArgs[index] = new BeanPropertySqlParameterSource(object);

        index ++;
    }
    int[] rows = namedPjdbcTemplate.batchUpdate(sql, batchArgs);
    return rows;
}
项目：mybatis-dynamic-sql    文件：SpringTest.java    
@Test
public void testInsert() {
    GeneratedAlwaysRecord record = new GeneratedAlwaysRecord();
    record.setId(100);
    record.setFirstName("Bob");
    record.setLastName("Jones");

    InsertStatementProvider<GeneratedAlwaysRecord> insertStatement = insert(record)
            .into(generatedAlways)
            .map(id).toProperty("id")
            .map(firstName).toProperty("firstName")
            .map(lastName).toProperty("lastName")
            .build()
            .render(RenderingStrategy.SPRING_NAMED_PARAMETER);

    SqlParameterSource parameterSource = new BeanPropertySqlParameterSource(insertStatement.getRecord());
    KeyHolder keyHolder = new GeneratedKeyHolder();

    int rows = template.update(insertStatement.getInsertStatement(), parameterSource, keyHolder);
    String generatedKey = (String) keyHolder.getKeys().get("FULL_NAME");

    assertThat(rows).isEqualTo(1);
    assertThat(generatedKey).isEqualTo("Bob Jones");

}
项目：nics-common    文件：ChatDAOImpl.java    
public int addChat(Chat chat) throws Exception {
    List<String> fields = Arrays.asList(
        SADisplayConstants.CHAT_ID, SADisplayConstants.COLLAB_ROOM_ID, SADisplayConstants.USER_ORG_ID,
        SADisplayConstants.CREATED, SADisplayConstants.SEQ_NUM, SADisplayConstants.MESSAGE);

    QueryModel model = QueryManager.createQuery(SADisplayConstants.CHAT_TABLE).insertInto(fields);

    //generate a chatid if not set
    if (chat.getChatid() <= 0) {
        QueryModel idModel = QueryManager.createQuery("chat_seq").selectNextVal();
        int id = this.template.queryForObject(idModel.toString(), new MapSqlParameterSource(), Integer.class);
        chat.setChatid(id);
    }

    try {
        this.template.update(model.toString(), new BeanPropertySqlParameterSource(chat));
        return chat.getChatid();
    } catch(Exception e) {
        throw new Exception("Unhandled exception while persisting Chat entity:", e);
    }
}
项目：javase-study    文件：QueryExampleHelper.java    
/**
 * 根据主键创建查询条件
 *
 * @param pathBase Querydsl query type
 * @param pk       主键
 * @return 查询条件
 */
public static QueryExample createExampleByPk(RelationalPathBase<?> pathBase, Object pk) {
    int numOfPk = pathBase.getPrimaryKey().getLocalColumns().size();
    Validate.isTrue(numOfPk > 0, "primaryKey not exists");
    QueryExample example = QueryExample.newInstance();
    if (numOfPk == 1) {
        example.equalsTo(pathBase.getPrimaryKey().getLocalColumns()
                .get(0).getMetadata().getName(), pk);
    } else {
        SqlParameterSource source = new BeanPropertySqlParameterSource(pk);
        for (Path<?> path : pathBase.getPrimaryKey().getLocalColumns()) {
            String name = path.getMetadata().getName();
            String humpName = humpName(name);
            example.equalsTo(humpName, source.getValue(name));
        }
    }
    return example;
}
项目：spring-xd-jdbc-job    文件：JdbcTasklet.java    
private String runCommand(StepContext steoContext, String sqlCommand) throws Exception {

        String msg = "";
        if (sqlCommand.trim().toUpperCase().startsWith("SELECT")) {
            logger.debug("Executing: " + sqlCommand);
            List<Map<String, Object>> result = jdbcTemplate.queryForList(sqlCommand,
                    new BeanPropertySqlParameterSource(steoContext));
            msg = "Result: " + result;
            logger.debug(msg);
        } else {
            logger.debug("Updating : " + sqlCommand);
            int updated = jdbcTemplate.update(sqlCommand, new BeanPropertySqlParameterSource(steoContext));
            msg = "Updated: " + updated + " rows";
            logger.debug(msg);
        }

        return msg;
    }
项目：maven-framework-project    文件：PGAlertDao.java    
@Override
@Transactional
public String create(Alert alert) {
    log.debug("Inserting alert into SQL backend: " + alert);
    checkArgument(StringUtils.isBlank(alert.getId()), "alert id cannot be already set");

    String id = UUID.randomUUID().toString();
    alert.setId(id);
    String sql = "INSERT INTO Alert (id, created_by, message, priority, user_id,  acknowledged, created_date) " +
            "VALUES (:id, :createdBy, :message, :priority, :userId, :acknowledged, :createdDate)";

    BeanPropertySqlParameterSource source = new BeanPropertySqlParameterSource(alert);
    int results = this.namedJdbcTemplate.update(sql, source);
    log.debug("Got: " + results + " results");

    return id;
}
项目：maven-framework-project    文件：PGAlertDao.java    
@Override
@Transactional(readOnly = true)
public List<Alert> readPage(PagingCriteria criteria) {
    log.debug("reading page with criteria: " + criteria);
    if (criteria == null || criteria.getLimit() == null || criteria.getStart() == null) {
        log.warn("criteria invalid - reading all instead of subset");
        return readAll();
    }
    String sql = "SELECT LIMIT :start :limit * FROM Alert ORDER BY created_date ASC";
    BeanPropertySqlParameterSource source = new BeanPropertySqlParameterSource(criteria);

    List<Alert> alerts = this.namedJdbcTemplate.query(sql, source, new AlertRowMapper());
    log.debug(alerts.size() + " alerts returned using criteria: " + criteria);

    return alerts;
}
项目：maven-framework-project    文件：PGDocumentDao.java    
@Override
@Transactional
public String create(Document document) {
    log.debug("Inserting Document into SQL backend: " + document);
    checkArgument(StringUtils.isBlank(document.getId()), "Document id cannot be already set");

    String id = UUID.randomUUID().toString();
    document.setId(id);
    String sql = "INSERT INTO Document (id, author, title, content, summary, group_id, state_, created_date) " +
            "VALUES (:id, :author, :title, :content, :summary, :groupId, :state, :createdDate)";

    BeanPropertySqlParameterSource source = new BeanPropertySqlParameterSource(document);
    int results = this.namedJdbcTemplate.update(sql, source);
    log.debug("Got: " + results + " results");
    document.setId(id);
    return id;
}
项目：maven-framework-project    文件：PGDocumentDao.java    
@Override
@Transactional(readOnly = true)
public List<Document> readPage(PagingCriteria criteria) {
    log.debug("reading page with criteria: " + criteria);
    if (criteria == null || criteria.getLimit() == null || criteria.getStart() == null) {
        log.warn("criteria invalid - reading all instead of subset");
        return readAll();
    }
    String sql = "SELECT LIMIT :start :limit * FROM Document ORDER BY created_date ASC";
    BeanPropertySqlParameterSource source = new BeanPropertySqlParameterSource(criteria);

    List<Document> documents = this.namedJdbcTemplate.query(sql, source, new DocumentRowMapper());
    log.debug(documents.size() + " Documents returned using criteria: " + criteria);

    return documents;
}
项目：oblatum    文件：MappingJdbcTemplate.java    
public <T> int delete(T t) throws DataAccessException {
    StringBuilder sql = new StringBuilder();
    sql.append(DELETE).append(SPACE).append(FROM).append(SPACE).append(t.getClass().getSimpleName().toLowerCase()).append(SPACE);
    sql.append(WHERE).append(SPACE).append(IDENTICAL).append(SPACE);
    PropertyDescriptor[] pds = BeanUtils.getPropertyDescriptors(t.getClass());
    BeanWrapper beanWrapper = PropertyAccessorFactory.forBeanPropertyAccess(t);
    for (int i = 0; i < pds.length; i++) {
        PropertyDescriptor pd = pds[i];
        String name = pd.getName();
        if (!CLASS.equals(name) && beanWrapper.isReadableProperty(name) && beanWrapper.getPropertyValue(name) != null) {
            sql.append(AND).append(SPACE).append(CamelCaseUtils.underscoreName(name)).append(SPACE);
            sql.append(EQUAL).append(SPACE).append(COLON).append(name).append(SPACE);
        }
    }
    return namedJdbcTemplate.update(sql.toString(), new BeanPropertySqlParameterSource(t));
}
项目：appframework    文件：UserDaoJdbcImpl.java    
@Override
public Long insertUser(User u) {
    StringBuffer sql = new StringBuffer("");
    sql.append(" insert into user ");
    sql.append(" ( username, password ) ");
    sql.append(" values ( ");
    sql.append("   :username ");
    sql.append(" , :password ");
    sql.append(" ) ");

    SqlParameterSource paramSource = new BeanPropertySqlParameterSource(u);
    KeyHolder generatedKeyHolder = new GeneratedKeyHolder();
    int rows = getDao().update(sql.toString(), paramSource, generatedKeyHolder);

    if(rows > 0 ){
        Long userId = generatedKeyHolder.getKey().longValue();
        u.setId(userId);
    }

    return u.getId();
}
项目：appframework    文件：UserDaoJdbcImpl.java    
@Override
    public List<User> listUser(User query) {
        StringBuffer sql = new StringBuffer("");
        sql.append(" select * ").append("\n");
        sql.append(" from user ").append("\n");
        sql.append(" where 1=1 ").append("\n");

        if(null != query.getId()){
            sql.append(" and id = :id  ").append("\n");
        }
        sql.append(" order by id desc ").append("\n");

        SqlParameterSource paramSource = new BeanPropertySqlParameterSource(query);

//      RowMapper<User> rowMapper = ParameterizedBeanPropertyRowMapper.newInstance(User.class);

        BeanPropertyRowMapper<User> rowMapper = new BeanPropertyRowMapper<User>(User.class);

        return getDao().query(sql.toString(), paramSource, rowMapper);

    }
项目：DevOps-for-Web-Development    文件：JdbcOwnerRepositoryImpl.java    
@Override
public void save(Owner owner) throws DataAccessException {
    BeanPropertySqlParameterSource parameterSource = new BeanPropertySqlParameterSource(owner);
    if (owner.isNew()) {
        Number newKey = this.insertOwner.executeAndReturnKey(parameterSource);
        owner.setId(newKey.intValue());
    } else {
        this.namedParameterJdbcTemplate.update(
            "UPDATE owners SET first_name=:firstName, last_name=:lastName, address=:address, " +
                "city=:city, telephone=:telephone WHERE id=:id",
            parameterSource);
    }
}
项目：DevOps-for-Web-Development    文件：JdbcOwnerRepositoryImpl.java    
@Override
public void save(Owner owner) throws DataAccessException {
    BeanPropertySqlParameterSource parameterSource = new BeanPropertySqlParameterSource(owner);
    if (owner.isNew()) {
        Number newKey = this.insertOwner.executeAndReturnKey(parameterSource);
        owner.setId(newKey.intValue());
    } else {
        this.namedParameterJdbcTemplate.update(
            "UPDATE owners SET first_name=:firstName, last_name=:lastName, address=:address, " +
                "city=:city, telephone=:telephone WHERE id=:id",
            parameterSource);
    }
}
项目：tc    文件：TcDbExtensionLogger.java    
protected void doInsert(TcExtensionLog tcExtensionLog) {
    int affectedLine = namedParameterJdbcTemplate.update(EXTENSION_LOGGER_INSERT_SQL,
            new BeanPropertySqlParameterSource(tcExtensionLog));
    if (!Objects.equals(affectedLine, 1)) {
        log.error("extension logger log crashed [{}]", tcExtensionLog);
    }
}
项目：nbone    文件：NamedJdbcDao.java    
@Override
public int insert(Object object) {
    SqlModel<Object> sqlModel = sqlBuilder.insertSelectiveSql(object);
    checkSqlModel(sqlModel);

    SqlParameterSource paramSource =  new BeanPropertySqlParameterSource(object);
    return namedPjdbcTemplate.update(sqlModel.getSql(), paramSource);
}
项目：nbone    文件：NamedJdbcDao.java    
@Override
public Serializable save(Object object) {
    SqlModel<Object> sqlModel = sqlBuilder.insertSelectiveSql(object);
    checkSqlModel(sqlModel);

    SqlParameterSource paramSource =  new BeanPropertySqlParameterSource(object);
    KeyHolder generatedKeyHolder =  new  GeneratedKeyHolder();
    namedPjdbcTemplate.update(sqlModel.getSql(), paramSource, generatedKeyHolder);
    return generatedKeyHolder.getKey();
}
项目：nbone    文件：NamedJdbcDao.java    
@Override
public int updateSelective(Object object) {
    SqlModel<Object> sqlModel = sqlBuilder.updateSelectiveSql(object);
    checkSqlModel(sqlModel);

    SqlParameterSource paramSource =  new BeanPropertySqlParameterSource(object);

    return namedPjdbcTemplate.update(sqlModel.getSql(), paramSource);
}
项目：nbone    文件：NamedJdbcDao.java    
@Override
public int delete(Object object) {
    SqlModel<Object> sqlModel = sqlBuilder.deleteSqlByEntityParams(object, true);
    checkSqlModel(sqlModel);

    SqlParameterSource paramSource =  new BeanPropertySqlParameterSource(object);

    return namedPjdbcTemplate.update(sqlModel.getSql(), paramSource);
}
项目：nbone    文件：NamedJdbcDao.java    
@Override
public int deleteByEntityParams(Object object) {
    SqlModel<Object> sqlModel = sqlBuilder.deleteSqlByEntityParams(object, false);
    checkSqlModel(sqlModel);

    SqlParameterSource paramSource =  new BeanPropertySqlParameterSource(object);

    return namedPjdbcTemplate.update(sqlModel.getSql(), paramSource);
}
项目：nbone    文件：NamedJdbcDao.java    
public <T> T get(Object object){
    SqlModel<Object> sqlModel = sqlBuilder.selectSqlById(object);
    checkSqlModel(sqlModel);

    RowMapper<T> rowMapper =   (RowMapper<T>) sqlModel.getRowMapper();
    List<T> list = namedPjdbcTemplate.query(sqlModel.getSql(),new BeanPropertySqlParameterSource(object),rowMapper);
    int row ;
    if(list != null && (row = list.size()) > 0){
        if(row > 1){
            logger.warn("Primary Key query result return multiple lines ["+row+"].thinking");
        }
        return list.get(0);
    }
    return null;
}
项目：nbone    文件：NamedJdbcDao.java    
@Override
public long count(Object object) {
    SqlModel<Object> sqlModel = sqlBuilder.countSql(object);
    checkSqlModel(sqlModel);
    SqlParameterSource parameterSource =  new BeanPropertySqlParameterSource(object);

    Number number = namedPjdbcTemplate.queryForObject(sqlModel.getSql(),parameterSource, Long.class);
    return (number != null ? number.longValue() : 0);
}
项目：nbone    文件：NamedJdbcDao.java    
@Override
public <T> List<T> getForList(Object object, FieldLevel fieldLevel,String afterWhere) {

    SqlModel<Object> sqlModel = sqlBuilder.selectSql(object,fieldLevel,afterWhere);
    checkSqlModel(sqlModel);

    RowMapper<T> rowMapper =   (RowMapper<T>) sqlModel.getRowMapper();
    List<T> list = namedPjdbcTemplate.query(sqlModel.getSql(),new BeanPropertySqlParameterSource(object),rowMapper);
    return list;
}
项目：nbone    文件：NamedJdbcDao.java    
@Override
public <T> List<T> queryForList(Object object, FieldLevel fieldLevel,String afterWhere) {
    SqlModel<Object> sqlModel = sqlBuilder.simpleSelectSql(object,fieldLevel,afterWhere);
    checkSqlModel(sqlModel);

    RowMapper<T> rowMapper =   (RowMapper<T>) sqlModel.getRowMapper();
    List<T> list = namedPjdbcTemplate.query(sqlModel.getSql(),new BeanPropertySqlParameterSource(object),rowMapper);
    return list;
}
项目：nbone    文件：NamedJdbcDao.java    
@Override
public int[] batchUpdate(Object[] objects) {
    //XXX: thinking 共享第一实体的sql
    SqlModel<Object> sqlModel = sqlBuilder.updateSql(objects[0]);
    checkSqlModel(sqlModel);

    SqlParameterSource[] batchArgs = new BeanPropertySqlParameterSource[objects.length];
    for (int i = 0; i < objects.length; i++) {
        batchArgs[i] = new BeanPropertySqlParameterSource(objects[i]);
    }
    int[] rows = namedPjdbcTemplate.batchUpdate(sqlModel.getSql(), batchArgs);
    return rows;

}
项目：nbone    文件：NamedJdbcDao.java    
@Override
public <T> List<T> getForListWithFieldNames(Object object, String[] fieldNames,boolean dbFieldMode) {
    SqlConfig sqlConfig = new SqlConfig(-1);
    sqlConfig.setFieldNames(fieldNames);
    sqlConfig.setDbFieldMode(dbFieldMode);

    SqlModel<Object> sqlModel= sqlBuilder.selectSql(object, sqlConfig);
    checkSqlModel(sqlModel);

    RowMapper<T> rowMapper =   (RowMapper<T>) sqlModel.getRowMapper();
    List<T> list = namedPjdbcTemplate.query(sqlModel.getSql(),new BeanPropertySqlParameterSource(object),rowMapper);
    return list;
}
项目：nbone    文件：NamedJdbcDao.java    
/**
    * MathOperation is null MathOperation set +
    */
@Override
public  int updateMathOperation(Object object, MathOperation mathOperation) {
    if(mathOperation == null ){
        mathOperation = MathOperation.ADD;
    }
    SqlModel<Object> sqlModel = sqlBuilder.updateMathOperationSql(object, mathOperation);
    checkSqlModel(sqlModel);

    SqlParameterSource paramSource =  new BeanPropertySqlParameterSource(object);

    return namedPjdbcTemplate.update(sqlModel.getSql(), paramSource);
}
项目：nbone    文件：NamedJdbcTemplate.java    
@SuppressWarnings("unchecked")
private <T> Page<T>  processPage(SqlModel<Object> sqlModel,Object object,int pageNum ,int pageSize,String... afterWhere){
    if(sqlModel == null){
        throw new BuilderSQLException("sqlModel is null.");
    }
    if(pageNum <= 0 ){
        pageNum = 1;
    }
    if(pageSize <= 0 ){
        pageSize = 10;
    }

    String countSql = sqlModel.getCountSql();
    String pageSql  = sqlModel.getPageSql(pageNum, pageSize);

    RowMapper<T> rowMapper =   (RowMapper<T>) sqlModel.getRowMapper();
    SqlParameterSource paramSource = new BeanPropertySqlParameterSource(object);

    List<T> rows = jdbcTemplate.query(getPreparedStatementCreator(pageSql,paramSource), rowMapper);

    long  count  =  this.queryForLong(countSql, paramSource);

    Page<T> page  = new PageImpl<T>(rows, null,count);

    return page;

}
项目：cacheonix-core    文件：SimpleJdbcClinic.java    
@Transactional
public void storeOwner(Owner owner) throws DataAccessException {
    if (owner.isNew()) {
        Number newKey = this.insertOwner.executeAndReturnKey(
                new BeanPropertySqlParameterSource(owner));
        owner.setId(newKey.intValue());
    }
    else {
        this.simpleJdbcTemplate.update(
                "UPDATE owners SET first_name=:firstName, last_name=:lastName, address=:address, " +
                "city=:city, telephone=:telephone WHERE id=:id",
                new BeanPropertySqlParameterSource(owner));
    }
}
项目：nics-common    文件：FeatureDAOImpl.java    
public void addCollabroomFeature(CollabroomFeature collabroomFeature) throws Exception{
    try{
    List<String> fields = Arrays.asList(
            SADisplayConstants.COLLAB_ROOM_ID, SADisplayConstants.FEATURE_ID);

    QueryModel model = QueryManager.createQuery(SADisplayConstants.FEATURE_COLLABROOM).insertInto(fields);

    this.template.update(model.toString(), new BeanPropertySqlParameterSource(collabroomFeature));
    }catch(Exception e) {
        throw new Exception("Unhandled exception while persisting Collabroom Feature entity: " + e.getMessage());
    }
}
项目：nics-common    文件：FeatureDAOImpl.java    
public void addUserFeature(UserFeature userFeature) throws Exception{
    try{
    List<String> fields = Arrays.asList(
            SADisplayConstants.USER_ID, SADisplayConstants.FEATURE_ID);

    QueryModel model = QueryManager.createQuery(SADisplayConstants.FEATURE_USER).insertInto(fields);

    this.template.update(model.toString(), new BeanPropertySqlParameterSource(userFeature));
    }catch(Exception e) {
        throw new Exception("Unhandled exception while persisting User Feature entity: " + e.getMessage());
    }
}
项目：docker-workflow-plugin    文件：JdbcOwnerRepositoryImpl.java    
@Override
public void save(Owner owner) throws DataAccessException {
    BeanPropertySqlParameterSource parameterSource = new BeanPropertySqlParameterSource(owner);
    if (owner.isNew()) {
        Number newKey = this.insertOwner.executeAndReturnKey(parameterSource);
        owner.setId(newKey.intValue());
    } else {
        this.namedParameterJdbcTemplate.update(
                "UPDATE owners SET first_name=:firstName, last_name=:lastName, address=:address, " +
                        "city=:city, telephone=:telephone WHERE id=:id",
                parameterSource);
    }
}
项目：summerb    文件：PasswordDaoImpl.java    
@Override
public int updateUserPassword(String userUuid, String newPasswordHash) {
    Password pwd = new Password();
    pwd.setUserUuid(userUuid);
    pwd.setPasswordHash(newPasswordHash);
    pwd.setRestorationToken(null);

    BeanPropertySqlParameterSource params = new BeanPropertySqlParameterSource(pwd);

    return jdbc.update(sqlPutPassword, params);
}
项目：audit4j-demo    文件：JdbcOwnerRepositoryImpl.java    
@Override
public void save(Owner owner) throws DataAccessException {
    BeanPropertySqlParameterSource parameterSource = new BeanPropertySqlParameterSource(owner);
    if (owner.isNew()) {
        Number newKey = this.insertOwner.executeAndReturnKey(parameterSource);
        owner.setId(newKey.intValue());
    } else {
        this.namedParameterJdbcTemplate.update(
                "UPDATE owners SET first_name=:firstName, last_name=:lastName, address=:address, " +
                        "city=:city, telephone=:telephone WHERE id=:id",
                parameterSource);
    }
}
项目：jersey-jax-rs-examples    文件：EmployeeResource.java    
@PUT
@Path("/{employeeId}")
public Employee editEmployee(final Employee employee, @PathParam("employeeId") Integer employeeId) {

    String sql = "update EMPLOYEE set name=:name, address=:address where id=:id";

    SqlParameterSource namedParameters = new BeanPropertySqlParameterSource(employee);

    this.namedParameterJdbcTemplate.update(sql, namedParameters);

    sql = "select * from EMPLOYEE where id=:employeeId";
    SqlParameterSource namedParameters2 = new MapSqlParameterSource("employeeId", employeeId);
    return namedParameterJdbcTemplate.query(sql, namedParameters2, new EmployeeMapper()).get(0);
}
项目：gomall.la    文件：BaseJdbcDaoImpl.java    
public <T> int updateNamed(String namedSql, T bean) {
    String sql = NamedParameterUtils.parseSqlStatementIntoString(namedSql);
    ParsedSql parsedSql = NamedParameterUtils.parseSqlStatement(namedSql);
    BeanPropertySqlParameterSource source = new BeanPropertySqlParameterSource(bean);
    List<SqlParameter> params = NamedParameterUtils.buildSqlParameterList(parsedSql, source);
    Object[] args = NamedParameterUtils.buildValueArray(parsedSql, source, params);
    return jdbcTemplate.update(sql, args);

}
项目：gomall.la    文件：BaseJdbcDaoImpl.java    
public <T> int[] updateNamed(String namedSql, List<T> beans) {
    String sql = NamedParameterUtils.parseSqlStatementIntoString(namedSql);
    ParsedSql parsedSql = NamedParameterUtils.parseSqlStatement(namedSql);
    List<Object[]> batchArgs = new ArrayList<Object[]>();
    for (T bean : beans) {
        BeanPropertySqlParameterSource source = new BeanPropertySqlParameterSource(bean);
        List<SqlParameter> params = NamedParameterUtils.buildSqlParameterList(parsedSql, source);
        Object[] args = NamedParameterUtils.buildValueArray(parsedSql, source, params);
        batchArgs.add(args);
    }
    return jdbcTemplate.batchUpdate(sql, batchArgs);
}
项目：DependencyInjectionAgent    文件：JdbcOwnerRepositoryImpl.java    
@Override
public void save(Owner owner) throws DataAccessException {
    BeanPropertySqlParameterSource parameterSource = new BeanPropertySqlParameterSource(owner);
    if (owner.isNew()) {
        Number newKey = this.insertOwner.executeAndReturnKey(parameterSource);
        owner.setId(newKey.intValue());
    } else {
        this.namedParameterJdbcTemplate.update(
                "UPDATE owners SET first_name=:firstName, last_name=:lastName, address=:address, " +
                        "city=:city, telephone=:telephone WHERE id=:id",
                parameterSource);
    }
}
项目：spring-petclinic-study    文件：JdbcOwnerRepositoryImpl.java    
@Override
public void save(Owner owner) throws DataAccessException {
    BeanPropertySqlParameterSource parameterSource = new BeanPropertySqlParameterSource(owner);
    if (owner.isNew()) {
        Number newKey = this.insertOwner.executeAndReturnKey(parameterSource);
        owner.setId(newKey.intValue());
    } else {
        this.namedParameterJdbcTemplate.update(
                "UPDATE owners SET first_name=:firstName, last_name=:lastName, address=:address, " +
                        "city=:city, telephone=:telephone WHERE id=:id",
                parameterSource);
    }
}