基于xml配置插入数据库数据例子(三)

浏览数：49 / 时间：2015年06月12日

16.Util
package net.atpco.dds.offline.filing.common.datamapper.binder;

public class Util {
private static String userId;
public static String getUserId() {
return userId;
}

public static void setUserId(String userId) {
Util.userId = userId;
}
}

17.SpringDataLoadConfiguration.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:c="http://www.springframework.org/schema/c"
xmlns:util="http://www.springframework.org/schema/util"
xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
           http://www.springframework.org/schema/util
           http://www.springframework.org/schema/util/spring-util-3.2.xsd">

package net.atpco.dds.offline.filing.common.datamapper.parser;
18.ClassConfig
package net.atpco.dds.offline.filing.common.datamapper.parser;

import java.util.ArrayList;
import java.util.List;

import javax.xml.bind.annotation.XmlAttribute;
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement(name = "classConfig")
public class ClassConfig implements Cloneable {
private String id;
private String schemaName;
private String schemaPropName;
private String tableName;
private String className;

private List<PropertyConfig> propertyConfigs = new ArrayList<PropertyConfig>();

public String getId() {
return id;
}

@XmlAttribute(name = "id")
public void setId(final String id) {
this.id = id;
}

public String getSchemaName() {
return schemaName;
}

/**
* Used to hold the schema name fetched from the property schema property name
* @param schemaName
*/
public void setSchemaName(final String schemaName) {
this.schemaName = schemaName;
}

public String getSchemaPropName() {
return schemaPropName;
}

@XmlAttribute(name = "schemaPropName")
public void setSchemaPropName(final String schemaPropName) {
this.schemaPropName = schemaPropName;
}

public String getTableName() {
return tableName;
}

@XmlAttribute(name = "tableName")
public void setTableName(final String tableName) {
this.tableName = tableName.trim().toUpperCase();
}

public String getClassName() {
return className;
}

@XmlAttribute(name = "className")
public void setClassName(final String className) {
this.className = className;
}

public List<PropertyConfig> getPropertyConfigs() {
return propertyConfigs;
}

@XmlElement(name = "propertyConfig", type = PropertyConfig.class)
public void setPropertyConfigs(final List<PropertyConfig> propertyConfigs) {
this.propertyConfigs = propertyConfigs;
}

@Override
public String toString() {
  final StringBuilder obj = new StringBuilder(512);
  obj.append(" \n\n Id : ");
  obj.append(getId());
  obj.append(" schemaName: ");
  obj.append(getSchemaName());
  obj.append(" tableName: " );
  obj.append(getTableName());
  obj.append(" className: " );
  obj.append(getClassName());
  obj.append(" \n Property Configurations : \n [");
  for (final PropertyConfig config : getPropertyConfigs()) {
   obj.append("\n \tProperty Name: ").append(config.getName());
   obj.append(" \tColumn Name: ").append(config.getColumnName());
   obj.append(" \tJava Type: ").append(config.getJavaType());
   obj.append(" \tInclude Clause: ").append(config.getIncludeClause());
  }
  obj.append(" \n] ");
  return obj.toString();
}
}

19.PropertyConfig
package net.atpco.dds.offline.filing.common.datamapper.parser;

import javax.xml.bind.annotation.XmlAttribute;
import javax.xml.bind.annotation.XmlRootElement;

/**
* Holds the property information like method name, sql type and java type
*
* @author atp1axi
* @version 1.0
*
*/

@XmlRootElement(name = "propertyConfig")
public class PropertyConfig {
private String name;
private String columnName;
private String javaType;
private String sqlType;
private String includeClause = "false";

public String getName() {
return name;
}

@XmlAttribute(name = "name")
public void setName(final String propertyName) {
this.name = propertyName;
}

public String getColumnName() {
return columnName;
}

@XmlAttribute(name = "columnName")
public void setColumnName(final String columnName) {
this.columnName = columnName.trim().toUpperCase();
}

public String getJavaType() {
return javaType;
}

@XmlAttribute(name = "javaType")
public void setJavaType(final String javaType) {
this.javaType = javaType;
}

public String getSqlType() {
return sqlType;
}

@XmlAttribute(name = "sqlType")
public void setSqlType(final String sqlType) {
this.sqlType = sqlType.trim().toUpperCase();
}

public String getIncludeClause() {
return includeClause;
}

@XmlAttribute(name = "includeClause")
public void setIncludeClause(final String includeClause) {
this.includeClause = includeClause;
}

@Override
public String toString() {
  final StringBuilder stringBuilder = new StringBuilder(256);
  stringBuilder.append(" propertyName - ").append(getName());
  stringBuilder.append(" columnName - ").append(getColumnName());
  stringBuilder.append(" javaType - ").append(getJavaType());
  stringBuilder.append(" sqlType - ").append(getSqlType());
  stringBuilder.append(" includeClause - ").append(getIncludeClause());
  return stringBuilder.toString();
}
}

package net.atpco.dds.offline.filing.common.model;
20.FilingFCSegmentCorrection
package net.atpco.dds.offline.filing.common.model;

public class FilingFCSegmentCorrection {

/**inEffYr*/
private Integer inEffYr;
/**carrierCode*/
private String carrierCode;
/**ruleTariffCode*/
private String ruleTariffCode;
/**ruleCode*/
private String ruleCode;
private Integer seqNo;
private Integer zoneNO;
public Integer getSeqNo() {
  return seqNo;
}
public void setSeqNo(Integer seqNo) {
  this.seqNo = seqNo;
}
public Integer getZoneNO() {
  return zoneNO;
}
public void setZoneNO(Integer zoneNO) {
  this.zoneNO = zoneNO;
}
public Integer getInEffYr() {
  return inEffYr;
}
public void setInEffYr(Integer inEffYr) {
  this.inEffYr = inEffYr;
}
public String getCarrierCode() {
  return carrierCode;
}
public void setCarrierCode(String carrierCode) {
  this.carrierCode = carrierCode;
}
public String getRuleTariffCode() {
  return ruleTariffCode;
}
public void setRuleTariffCode(String ruleTariffCode) {
  this.ruleTariffCode = ruleTariffCode;
}
public String getRuleCode() {
  return ruleCode;
}
public void setRuleCode(String ruleCode) {
  this.ruleCode = ruleCode;
}

@Override
public String toString() {
  StringBuffer sb=new StringBuffer();
  sb.append("inEffYr="+inEffYr+",carrierCode="+carrierCode+
    ",ruleTariffCode="+ruleTariffCode+",ruleCode="+ruleCode
    +",seqNo="+seqNo+",zoneNO="+zoneNO);
  return sb.toString();
}

}

<util:list id="configPaths">
  <value>classpath:/spring/fc_segment_crrn.xml</value>
  <value>classpath:/spring/cat_segment_crrn.xml</value>
  <value>classpath:/spring/cat_govt_filing_crrn.xml</value>
</util:list>

</beans>

22.fc_segment_crrn.xml
<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<classConfig id="fcSegmentCRRN" schemaPropName="gfsSchema"
tableName="FC_SEG_CRRN" className="net.atpco.dds.offline.filing.common.model.FilingFCSegmentCorrection">

<propertyConfig name="inEffYr" columnName="IN_EFF_YR" javaType="java.lang.Integer" sqlType="SMALLINT" includeClause="true"/>
<propertyConfig name="carrierCode" columnName="CXR_CD" javaType="java.lang.String" sqlType="CHAR" includeClause="true"/>
<propertyConfig name="ruleTariffCode" columnName="RULE_TAR_CD" javaType="java.lang.String" sqlType="CHAR" includeClause="true"/>
<propertyConfig name="ruleCode" columnName="RULE_CD" javaType="java.lang.String" sqlType="CHAR" includeClause="true"/>
<propertyConfig name="CREATE_SYSTEM" columnName="CREATE_ID" javaType="java.lang.String" sqlType="CHAR" />
</classConfig>

23.DataLoadSchema.xsd
<?xml version="1.0"?>
<xs:schema xmlns:xs="http://www.w3.org/2001/XMLSchema" attributeFormDefault="unqualified" elementFormDefault="qualified">
<xs:element name="classConfig">
    <xs:complexType>
      <xs:sequence>
        <xs:element name="propertyConfig" maxOccurs="unbounded" minOccurs="0">
          <xs:complexType>
            <xs:simpleContent>
              <xs:extension base="xs:string">
                <xs:attribute type="xs:string" name="name" use="required"/>
                <xs:attribute type="xs:string" name="columnName" use="required"/>
                <xs:attribute type="xs:string" name="javaType" use="required"/>
                <xs:attribute type="xs:string" name="sqlType" use="required"/>
                <xs:attribute type="xs:string" name="includeClause" use="optional"/>
              </xs:extension>
            </xs:simpleContent>
          </xs:complexType>
        </xs:element>
      </xs:sequence>
      <xs:attribute type="xs:string" name="id" use="required"/>
      <xs:attribute type="xs:string" name="schemaPropName" use="required"/>
      <xs:attribute type="xs:string" name="tableName" use="required"/>
      <xs:attribute type="xs:string" name="className" use="required"/>
    </xs:complexType>
</xs:element>
</xs:schema>

23.filingConfig.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:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="
       http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
       http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.2.xsd
       http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd">

<context:component-scan base-package="net.atpco.dds" >
</context:component-scan>

<import resource="classpath:/spring/filingDataQueries.xml" />
<import resource="classpath:/spring/object-data-mappings.xml" />

<bean id="properties" class="org.springframework.beans.factory.config.PropertiesFactoryBean">
  <property name="locations">
   <list>
    <value>classpath:/gfs0.properties</value>
   </list>
  </property>
</bean>

<bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
  <property name="locations">
   <list>
    <value>classpath:/gfs0.properties</value>
   </list>
  </property>
</bean>

</beans>

</beans>

////////////////////////////Test Project/////////////////////////////////////////////////
25.TestFilingTextDataLoadService
/*
* Created on Jul 31, 2014
*
* Copyright 2014 ATPCO Confidential and Proprietary. All Rights Reserved.
*/
package net.atpco.dds.offline.filing.textload.service;

import java.util.List;

import junit.framework.Assert;
import net.atpco.dds.offline.filing.common.AbstractJUnitFilingIntegration;
import net.atpco.dds.offline.filing.common.datamapper.binder.DataLoadRequest;
import net.atpco.dds.offline.filing.common.datamapper.binder.DataLoadService;
import net.atpco.dds.offline.filing.common.datamapper.binder.Mode;
import net.atpco.dds.offline.filing.common.model.FilingFCSegmentCorrection;

import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.test.context.ContextConfiguration;
@ContextConfiguration(locations = {"classpath:/net/atpco/dds/offline/filing/textload/service/TestFilingTextDataLoadService.xml" })
@SuppressWarnings("unchecked")
public class TestFilingTextDataLoadService extends
AbstractJUnitFilingIntegration {

/** dataLoadService */
@Autowired
@Qualifier("dataLoadService")
private transient DataLoadService dataLoadService;

@Test
public void test() throws Exception {
  final List<FilingFCSegmentCorrection> filingDataList = (List<FilingFCSegmentCorrection>) applicationContext
    .getBean("fcSegCorrectionList");
  DataLoadRequest dataLoadRequest = new DataLoadRequest(Mode.INSERT,
    "fcSegmentCRRN", filingDataList);
  boolean result = dataLoadService.update(dataLoadRequest);
  Assert.assertTrue(result);
}
}

26.TestFilingTextDataLoadService.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:c="http://www.springframework.org/schema/c"
xmlns:util="http://www.springframework.org/schema/util"
xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
           http://www.springframework.org/schema/util
           http://www.springframework.org/schema/util/spring-util-3.2.xsd">

<util:list id="fcSegCorrectionList">
<ref bean="fcSegCorrection1"></ref>
<ref bean="fcSegCorrection2"></ref>
</util:list>

</beans>

27.AbstractJUnitFilingIntegration
package net.atpco.dds.offline.filing.common;

import net.atpco.dds.offline.filing.common.datamapper.binder.Util;

import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = { "classpath:/spring/filingConfig.xml"
})
public class AbstractJUnitFilingIntegration extends GFSJunit {

static{
Util.setUserId(System.getProperty("user.name"));
}

}
28.GFSJunit
package net.atpco.dds.offline.filing.common;

import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.AbstractTransactionalJUnit4SpringContextTests;
import org.springframework.test.context.transaction.TransactionConfiguration;

@ContextConfiguration(locations = {
"classpath:/spring/net/atpco/dds/offline/common/gfs-jdbc-config.xml" })
@TransactionConfiguration(transactionManager = "txManager", defaultRollback = false)
public abstract class GFSJunit extends
AbstractTransactionalJUnit4SpringContextTests {
}

<bean id="dataSource1111111"
        class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
     <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
     <property name="url" value="${Url}"/>
     <property name="username" value="${username}"/>
     <property name="password" ref="ddns_password" />
</bean>

    
    <bean id="dataSource"
        class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
     <property name="driverClassName" value="net.sf.log4jdbc.DriverSpy"/>
     <property name="url" value="jdbc:log4jdbc:mysql://localhost:3306/atpco"/>
     <property name="username" value="${username}"/>
     <property name="password" ref="ddns_password" />
</bean>

<bean id="dataSource2222222"
        class="com.p6spy.engine.spy.P6DataSource" >
        <constructor-arg>
            <bean
                class="org.springframework.jdbc.datasource.DriverManagerDataSource">
                <property name="driverClassName"
                    value="com.mysql.jdbc.Driver" />
                <property name="url" value="${Url}" />
                <property name="username" value="${username}" />
                <property name="password" ref="ddns_password" />
            </bean>
        </constructor-arg>
</bean>

<bean id="ddns_password" factory-bean="app_textEncrypter"
  factory-method="decrypt">
  
  <constructor-arg index="0" value="${pass}" />
</bean>