Admin: 1 версия

2010-06-01T06:17:00Z

1 версия

в 18:01, 31 мая 2010

2010-05-31T18:01:44Z

Новая страница

== extends StoredProcedure ==



<source lang="java">
File: context.xml
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"
"http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<bean id="dataSource" class="org.apache.rumons.dbcp.BasicDataSource"
destroy-method="close">
<property name="driverClassName" value="org.hsqldb.jdbcDriver"/>
<property name="url" value="jdbc:hsqldb:mem:."/>
<property name="username" value="sa"/>
<property name="password" value=""/>
</bean>
<bean id="employeeDao" class="EmployeeDaoImpl">
<property name="dataSource" ref="dataSource"/>
</bean>
</beans>

File: EmployeeDaoImpl.java
import java.sql.Types;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.sql.DataSource;
import org.springframework.jdbc.core.SqlOutParameter;
import org.springframework.jdbc.core.SqlParameter;
import org.springframework.jdbc.core.support.JdbcDaoSupport;
import org.springframework.jdbc.object.StoredProcedure;
import org.springframework.jdbc.support.nativejdbc.SimpleNativeJdbcExtractor;
public class EmployeeDaoImpl extends JdbcDaoSupport {

protected void initDao() throws Exception {
super.initDao();
getJdbcTemplate().setNativeJdbcExtractor(new SimpleNativeJdbcExtractor());
CallAggregateEmployees procedure = new CallAggregateEmployees(getDataSource());

int numberOfAffectedRecords = procedure.aggregate(1, 2);
}
}
class CallAggregateEmployees extends StoredProcedure {
private static final String STORED_PROCEDURE_NAME = "aggregate_employees";
public CallAggregateEmployees(DataSource dataSource) {
super(dataSource, STORED_PROCEDURE_NAME);
declareParameter(new SqlParameter("start_age", Types.INTEGER));
declareParameter(new SqlParameter("end_age", Types.INTEGER));
declareParameter(new SqlOutParameter("number_aggregated", Types.INTEGER));
compile();
}
public int aggregate(Integer start, Integer end) {
Map<String, Integer> inParameters = new HashMap<String, Integer>(2);
inParameters.put("start_age", start);
inParameters.put("end_age", end);
Map outParameters = execute(inParameters);
if (outParameters.size() > 0) {
return (Integer) outParameters.get("number_aggregated");
} else {
return 0;
}
}
}

class Employee {
private Integer id;
private Name name = new Name();
private Integer age;
private Sex sex;
private Address address = new Address();
private List<PhoneNumber> phoneNumbers = new ArrayList<PhoneNumber>();
public Employee() {
}
public Employee(String firstName, String lastName) {
this.getName().setFirst(firstName);
this.getName().setLast(lastName);
}
void setId(Integer id) {
this.id = id;
}
public Integer getId() {
return id;
}
public Address getAddress() {
return address;
}
public Integer getAge() {
return age;
}
public void setAge(Integer age) {
this.age = age;
}
public Name getName() {
return name;
}
public List<PhoneNumber> getPhoneNumbers() {
return Collections.unmodifiableList(phoneNumbers);
}
public void addPhoneNumber(PhoneNumber phoneNumber) {
this.phoneNumbers.add(phoneNumber);
}
public void removePhoneNumber(PhoneNumber phoneNumber) {
this.phoneNumbers.remove(phoneNumber);
}
public void removePhoneNumber(int index) {
this.phoneNumbers.remove(index);
}
public Sex getSex() {
return sex;
}
public void setSex(Sex sex) {
this.sex = sex;
}
}
abstract class Sex {
public static final Sex MALE = new Male();
public static final Sex FEMALE = new Female();
public boolean equals(Object o) {
if (o == null) {
return false;
}
return getClass().equals(o.getClass());
}
}
class PhoneNumber {
}
class Address {
private String line1;
private String line2;
private String city;
private String state;
private String zip;
public void setLine1(String line1) {
this.line1 = line1;
}
public String getLine1() {
return this.line1;
}
public void setLine2(String line2) {
this.line2 = line2;
}
public String getLine2() {
return this.line2;
}
public void setCity(String city) {
this.city = city;
}
public String getCity() {
return this.city;
}
public void setState(String state) {
this.state = state;
}
public String getState() {
return this.state;
}
public void setZip(String zip) {
this.zip = zip;
}
public String getZip() {
return this.zip;
}
}
final class Male extends Sex {
protected Male() {
}
}
final class Female extends Sex {
protected Female() {
}
}
class Name {
private String first;
private String middle;
private String last;
public void setFirst(String first) {
this.first = first;
}
public String getFirst() {
return this.first;
}
public void setMiddle(String middle) {
this.middle = middle;
}
public String getMiddle() {
return this.middle;
}
public void setLast(String last) {
this.last = last;
}
public String getLast() {
return this.last;
}
}

File: Main.java
import java.util.Date;
import java.util.GregorianCalendar;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
class Main {
public static void main(String args[]) throws Exception {
ApplicationContext ctx = new ClassPathXmlApplicationContext(
"context.xml");
EmployeeDaoImpl ws = (EmployeeDaoImpl) ctx.getBean("employeeDao");
}
}

</source>



== StoredProcedure and SqlOutParameter ==



<source lang="java">

File: context.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:util="http://www.springframework.org/schema/util"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:lang="http://www.springframework.org/schema/lang"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-2.0.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.0.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.0.xsd
http://www.springframework.org/schema/lang http://www.springframework.org/schema/lang/spring-lang-2.0.xsd">

<bean id="dataSource" class="org.apache.rumons.dbcp.BasicDataSource" destroy-method="close">
<property name="driverClassName" value="org.hsqldb.jdbcDriver"/>
<property name="url" value="jdbc:hsqldb:mem:."/>
<property name="username" value="sa"/>
<property name="password" value=""/>
</bean>

<bean id="lobHandler" class="org.springframework.jdbc.support.lob.OracleLobHandler">
<property name="nativeJdbcExtractor" ref="nativeJdbcExtractor"/>
</bean>
<bean id="nativeJdbcExtractor" class="org.springframework.jdbc.support.nativejdbc.rumonsDbcpNativeJdbcExtractor"/>
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource"/>
</bean>

</beans>

File: Main.java
import java.sql.Types;
import java.util.Collections;
import java.util.Map;
import javax.sql.DataSource;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.core.SqlOutParameter;
import org.springframework.jdbc.object.StoredProcedure;
class Main {
public static void main(String args[]) throws Exception {
ApplicationContext ac = new ClassPathXmlApplicationContext("context.xml", Main.class);
DataSource dataSource = (DataSource) ac.getBean("dataSource");
//DataSource mysqlDataSource = (DataSource) ac.getBean("mysqlDataSource");
MeaningOfLife meaningOfLife = new MeaningOfLife(dataSource);

Map result = meaningOfLife.execute(Collections.emptyMap());
System.out.println(result.values().iterator().next());
}
}
class MeaningOfLife extends StoredProcedure {
private static final String SQL = "f_calculate";
MeaningOfLife(DataSource dataSource) {
super(dataSource, SQL);
setFunction(true);
declareParameter(new SqlOutParameter("n", Types.INTEGER));
}
int executeAndGet() {
return (Integer)execute(Collections.emptyMap()).values().iterator().next();
}
}

</source>



== StoredProcedure With Parameter ==



<source lang="java">

File: context.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:util="http://www.springframework.org/schema/util"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:lang="http://www.springframework.org/schema/lang"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-2.0.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.0.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.0.xsd
http://www.springframework.org/schema/lang http://www.springframework.org/schema/lang/spring-lang-2.0.xsd">

<bean id="dataSource" class="org.apache.rumons.dbcp.BasicDataSource" destroy-method="close">
<property name="driverClassName" value="org.hsqldb.jdbcDriver"/>
<property name="url" value="jdbc:hsqldb:mem:."/>
<property name="username" value="sa"/>
<property name="password" value=""/>
</bean>

<bean id="lobHandler" class="org.springframework.jdbc.support.lob.OracleLobHandler">
<property name="nativeJdbcExtractor" ref="nativeJdbcExtractor"/>
</bean>
<bean id="nativeJdbcExtractor" class="org.springframework.jdbc.support.nativejdbc.rumonsDbcpNativeJdbcExtractor"/>
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource"/>
</bean>

</beans>

File: Main.java
import java.sql.Types;
import java.util.HashMap;
import java.util.Map;
import javax.sql.DataSource;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.core.SqlParameter;
import org.springframework.jdbc.object.StoredProcedure;
class Main {
public static void main(String args[]) throws Exception {
ApplicationContext ac = new ClassPathXmlApplicationContext("context.xml", Main.class);
DataSource dataSource = (DataSource) ac.getBean("dataSource");
//DataSource mysqlDataSource = (DataSource) ac.getBean("mysqlDataSource");

ActStartled actStartled = new ActStartled(dataSource);

actStartled.execute(1);
}
}
class ActStartled extends StoredProcedure {
private static final String SQL = "p_proc";
ActStartled(DataSource dataSource) {
super(dataSource, SQL);
declareParameter(new SqlParameter("n", Types.INTEGER));
}
void execute(int value) {
Map<String, Object> parameters = new HashMap<String, Object>(1);
parameters.put("n", value);
execute(parameters);
}
}

</source>

← Предыдущая	Версия 06:17, 1 июня 2010
(нет различий)

Java/Spring/StoredProcedure - История изменений

Admin: 1 версия

в 18:01, 31 мая 2010