敬业的IT人 互联网 佚名 2008-5-16 21:57:04

package com.highcom.seqgen.dao.jdbc;

import java.sql.*;
import javax.sql.*;

import org.apache.commons.logging.*;
import org.springframework.beans.factory.*;
import org.springframework.context.*;
import org.springframework.jdbc.core.*;
import org.springframework.jdbc.object.*;
import com.highcom.seqgen.dao.*;
import com.highcom.seqgen.domain.*;

public class SequenceDaoJdbcImpl
implements SequenceDao, InitializingBean {

private DataSource dataSource;
private static Log logger = LogFactory.getLog(SequenceDaoJdbcImpl.class);

//
SequenceQuery sequenceQuery;
SequenceUpdate sequenceUpdate;
SequenceInsert sequenceInsert;
//
protected static final String INSERT_SQL =
"insert into sequence(seq_name,seq_value) values( ? , ? )";
protected static final String UPDATE_SQL =
"update sequence set seq_value = ? where seq_name = ?";
protected static final String SELECT_SQL =
"select seq_name,seq_value from sequence where seq_name =?";

public SequenceDaoJdbcImpl() {

}

public int getSequence(String seq_name) {
int result;
Object obj = sequenceQuery.findObject(new Object[] {seq_name});
if (obj == null) {
sequenceInsert.insert(seq_name, 0);
}

Sequence seq = (Sequence) sequenceQuery.findObject(new Object[] {seq_name});
sequenceUpdate.update(seq.getName(), seq.getValue() 1);
result = seq.getValue() 1;
return result;
}

public void afterPropertiesSet() throws Exception {
if (dataSource == null) {
logger.error("Must set dataSource bean property on " getClass());
throw new ApplicationContextException(
"Must set dataSource bean property on " getClass());
}
//
sequenceQuery = new SequenceQuery(this.dataSource);
sequenceUpdate = new SequenceUpdate(this.dataSource);
sequenceInsert = new SequenceInsert(this.dataSource);
}

public void setDataSource(DataSource dataSource) {
this.dataSource = dataSource;
}

///////////////////////jdbc内部类
class SequenceInsert
extends SqlUpdate {
public SequenceInsert(DataSource dataSource) {
super(dataSource, INSERT_SQL);
declareParameter(new SqlParameter(Types.VARCHAR));
declareParameter(new SqlParameter(Types.INTEGER));
compile();
}

public void insert(String seqName, int segValue) {
Object[] objs = new Object[] {
seqName, new Integer(segValue)};
super.update(objs);
}
}

class SequenceUpdate
extends SqlUpdate {
public SequenceUpdate(DataSource dataSource) {
super(dataSource, UPDATE_SQL);
declareParameter(new SqlParameter(Types.INTEGER));
declareParameter(new SqlParameter(Types.VARCHAR));

compile();

}

public void update(String seqName, int segValue) {
Object[] objs = new Object[] {
new Integer(segValue), seqName};
super.update(objs);
}
}

class SequenceQuery
extends MappingSqlQuery {
public SequenceQuery(DataSource dataSource) {
super(dataSource, SELECT_SQL);
declareParameter(new SqlParameter(Types.VARCHAR));
compile();
}

protected Object mapRow(ResultSet resultSet, int _int) throws SQLException {
Sequence seq = new Sequence();
seq.setName(resultSet.getString("seq_name"));
seq.setValue(resultSet.getInt("seq_value"));
return seq;
}
}

}

最新文章

处理系统中的各类附件，上传下载[05-16]

Hibernate配置文件在单元测试中的应用[05-16]

java设计模式---prototype(原型)模式[05-16]

我的J2ME编程联系（2）——DateField[05-16]

《Java 手机/PDA 程序设计入门》读书笔记11-- M..[05-16]

Effective Java -->（一）创建和销毁对..[05-16]

相关文章

[java技术] Java常用术语解释[05-16]

应该如何使用标签技术？使用EL，logic和hanva标签库..[05-16]

Java 编程技术中汉字问题的分析及解决,文件操作[05-16]

沉重的翅膀——软件开发，业务？技术？[05-16]

html与jsp开发分离技术[05-15]

J2EE的13种核心技术(一)[05-14]