wowza支持RESTful web服务示例代码

package com.defonds.wms.module.common.dao; import java.sql.SQLException; import java.util.List; import java.util.Map; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.springframework.dao.DataAccessException; import org.springframework.jdbc.JdbcUpdateAffectedIncorrectNumberOfRowsException; import org.springframework.orm.ibatis.SqlMapClientCallback; import org.springframework.orm.ibatis.support.SqlMapClientDaoSupport; import com.ibatis.sqlmap.client.SqlMapExecutor; import com.ibatis.sqlmap.client.event.RowHandler; import com.ibatis.sqlmap.engine.execution.BatchException; import com.ibatis.sqlmap.engine.execution.BatchResult; public class BaseDaoImpl extends SqlMapClientDaoSupport implements BaseDao { public void test(){ //SqlMapClientTemplate ddd = super.getSqlMapClientTemplate(); } private static final Log LOG = LogFactory.getLog(BaseDaoImpl.class); @SuppressWarnings("unchecked") public <T> T execute(SqlMapClientCallback action) throws DataAccessException { return (T) getSqlMapClientTemplate().execute(action); } @SuppressWarnings("unchecked") public <T> T queryForObject(String statementName) throws DataAccessException { return (T) getSqlMapClientTemplate().queryForObject(statementName); } @SuppressWarnings("unchecked") public <T> T queryForObject(final String statementName, final Object parameterObject) throws DataAccessException { return (T) getSqlMapClientTemplate().queryForObject(statementName, parameterObject); } @SuppressWarnings("unchecked") public <T> T queryForObject(final String statementName, final Object parameterObject, final Object resultObject) throws DataAccessException { return (T) getSqlMapClientTemplate().queryForObject(statementName, parameterObject, resultObject); } public List<?> queryForList(String statementName) throws DataAccessException { return queryForList(statementName, null); } public List<?> queryForList(final String statementName, final Object parameterObject) throws DataAccessException { return getSqlMapClientTemplate().queryForList(statementName, parameterObject); } public List<?> queryForList(String statementName, int skipResults, int maxResults)throws DataAccessException { return queryForList(statementName, null, skipResults, maxResults); } public List<?> queryForList(final String statementName, final Object parameterObject, final int skipResults, final int maxResults) throws DataAccessException { return getSqlMapClientTemplate().queryForList(statementName, parameterObject, skipResults, maxResults); } public void queryWithRowHandler(String statementName, RowHandler rowHandler)throws DataAccessException { queryWithRowHandler(statementName, null, rowHandler); } public void queryWithRowHandler( final String statementName, final Object parameterObject, final RowHandler rowHandler) throws DataAccessException { getSqlMapClientTemplate().queryWithRowHandler(statementName, parameterObject, rowHandler); } public Map<?,?> queryForMap( final String statementName, final Object parameterObject, final String keyProperty) throws DataAccessException { return getSqlMapClientTemplate().queryForMap(statementName, parameterObject, keyProperty); } public Map<?,?> queryForMap( final String statementName, final Object parameterObject, final String keyProperty, final String valueProperty) throws DataAccessException { return getSqlMapClientTemplate().queryForMap(statementName, parameterObject, keyProperty, valueProperty); } public <T> T insert(String statementName) throws DataAccessException { return (T) getSqlMapClientTemplate().insert(statementName, null); } @SuppressWarnings("unchecked") public <T> T insert(final String statementName, final Object parameterObject) throws DataAccessException { return (T) getSqlMapClientTemplate().insert(statementName, parameterObject); } public int update(String statementName) throws DataAccessException { return update(statementName, null); } public int update(final String statementName, final Object parameterObject) throws DataAccessException { Integer result = (Integer) execute(new SqlMapClientCallback() { public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException { return new Integer(executor.update(statementName, parameterObject)); } }); return result.intValue(); } public void update(String statementName, Object parameterObject, int requiredRowsAffected) throws DataAccessException { int actualRowsAffected = update(statementName, parameterObject); if (actualRowsAffected != requiredRowsAffected) { throw new JdbcUpdateAffectedIncorrectNumberOfRowsException( statementName, requiredRowsAffected, actualRowsAffected); } } public int delete(String statementName) throws DataAccessException { return delete(statementName, null); } public int delete(final String statementName, final Object parameterObject) throws DataAccessException { Integer result = (Integer) execute(new SqlMapClientCallback() { public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException { return new Integer(executor.delete(statementName, parameterObject)); } }); return result.intValue(); } public void delete(String statementName, Object parameterObject, int requiredRowsAffected) throws DataAccessException { int actualRowsAffected = delete(statementName, parameterObject); if (actualRowsAffected != requiredRowsAffected) { throw new JdbcUpdateAffectedIncorrectNumberOfRowsException( statementName, requiredRowsAffected, actualRowsAffected); } } public <T> int updateBatch(final String statementName, final List<T> list) { if(list == null || list.isEmpty()){ return 0; } SqlMapClientCallback callback = new SqlMapClientCallback() { public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException { executor.startBatch(); for (Object obj : list) { executor.update(statementName, obj); } try { return executor.executeBatchDetailed(); } catch (BatchException e) { LOG.error(e.getMessage(), e); throw new SQLException("Batch update failed!"); } } }; List<BatchResult> retList = (List<BatchResult>) getSqlMapClientTemplate().execute(callback); return batchResult(retList); } /** * 从批处理结果返回处理成功的记录数 * @param batchResultList * @return count */ private int batchResult(List<BatchResult> batchResultList) { int count = 0; if (batchResultList != null && !batchResultList.isEmpty()) { BatchResult result = batchResultList.get(0); if (result != null) { for (int i : result.getUpdateCounts()) { if (i == java.sql.Statement.SUCCESS_NO_INFO) { count++; } else { count += i; } } } } return count; } public <T> void insertBatch(final String statementName, final List<T> list) { getSqlMapClientTemplate().execute( new SqlMapClientCallback() { public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException { executor.startBatch(); for (int i = 0; i < list.size(); i++) { T t = (T)list.get(i); executor.insert(statementName, t); if (i%50 == 0) { executor.executeBatch(); } } executor.executeBatch();