Changeset 7271


Ignore:
Timestamp:
04/08/10 12:29:22 (9 years ago)
Author:
mnagni
Message:

Major commit. Activated services: doHarvest (still without no mail service), getList, getListName

Location:
RevitalizationWS/ws/DPWS/trunk
Files:
44 added
3 deleted
4 edited
5 moved

Legend:

Unmodified
Added
Removed
  • RevitalizationWS/ws/DPWS/trunk/.classpath

    r7233 r7271  
    33        <classpathentry kind="src" output="target/classes" path="src/main/java"/> 
    44        <classpathentry excluding="**" kind="src" output="target/classes" path="src/main/resources"/> 
    5         <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/> 
     5        <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.6"/> 
    66        <classpathentry kind="con" path="org.maven.ide.eclipse.MAVEN2_CLASSPATH_CONTAINER"> 
    77                <attributes> 
  • RevitalizationWS/ws/DPWS/trunk/pom.xml

    r7233 r7271  
    6464                <dependency> 
    6565                        <groupId>org.hibernate</groupId> 
    66                         <artifactId>hibernate-annotations</artifactId> 
    67                         <version>3.4.0.GA</version> 
     66                        <artifactId>ejb3-persistence</artifactId> 
     67                        <version>1.0.2.GA</version> 
    6868                        <scope>provided</scope> 
     69                </dependency> 
     70 
     71                <dependency> 
     72                        <groupId>javax</groupId> 
     73                        <artifactId>javaee-api</artifactId> 
     74                        <version>6.0</version> 
     75                        <scope>provided</scope>                  
    6976                </dependency> 
    7077 
     
    7380                        <artifactId>jboss-ejb3x</artifactId> 
    7481                        <version>4.2.2.GA</version> 
     82                        <scope>provided</scope> 
     83                </dependency> 
     84 
     85                <dependency> 
     86                        <groupId>javax.mail</groupId> 
     87                        <artifactId>mail</artifactId> 
     88                        <version>1.4.1</version> 
    7589                        <scope>provided</scope> 
    7690                </dependency> 
     
    8599                        <groupId>ndg.services</groupId> 
    86100                        <artifactId>common</artifactId> 
    87                         <version>1.0.0</version> 
     101                        <version>1.1.0</version> 
    88102                        <scope>provided</scope> 
    89103                </dependency> 
  • RevitalizationWS/ws/DPWS/trunk/src/main/java/ndg/services/revitalization/ejb/DPWS.java

    r7220 r7271  
    1 package ndg.services.revitalization; 
     1package ndg.services.revitalization.ejb; 
    22 
    33import javax.ejb.Stateless; 
    4  
    54import javax.jws.WebMethod; 
    65import javax.jws.WebParam; 
    76import javax.jws.WebService; 
    87 
     8import ndg.services.revitalization.ejb.interfaces.DPWSLocal; 
     9import ndg.services.revitalization.ejb.interfaces.DPWSRemote; 
     10import ndg.services.revitalization.executor.ExecuteGetList; 
     11import ndg.services.revitalization.executor.ExecuteGetListNames; 
     12import ndg.services.revitalization.executor.ExecuteHarvest; 
     13import ndg.services.revitalization.executor.ServiceExecutor; 
    914import ndg.services.schemas.revitalization.DoConfigureProviderDetails; 
    1015import ndg.services.schemas.revitalization.DoConfigureProviderDetailsReturn; 
    1116import ndg.services.schemas.revitalization.DoHarvestRequest; 
    12 import ndg.services.schemas.revitalization.DoHarvestReturn; 
     17import ndg.services.schemas.revitalization.DoHarvestResponse; 
    1318import ndg.services.schemas.revitalization.DoIngestRequest; 
    1419import ndg.services.schemas.revitalization.DoIngestReturn; 
     
    1722import ndg.services.schemas.revitalization.GetIngestHistoryRequest; 
    1823import ndg.services.schemas.revitalization.GetIngestHistoryReturn; 
    19 import ndg.services.schemas.revitalization.GetListNamesReturnType; 
    20 import ndg.services.schemas.revitalization.GetListReturnType; 
     24import ndg.services.schemas.revitalization.GetListNamesResponse; 
     25import ndg.services.schemas.revitalization.GetListResponse; 
    2126import ndg.services.schemas.revitalization.GetListType; 
     27import ndg.services.schemas.revitalization.GetProcessStatusRequest; 
     28import ndg.services.schemas.revitalization.GetProcessStatusReturn; 
    2229import ndg.services.schemas.revitalization.GetProviderDetailsRequest; 
    2330import ndg.services.schemas.revitalization.GetProviderDetailsReturn; 
     
    3845         
    3946        @WebMethod(operationName="doHarvest") 
    40         public DoHarvestReturn doHarvest(@WebParam(name="request") DoHarvestRequest request) { 
    41                 return of.createDoHarvestReturn(); 
     47        public DoHarvestResponse doHarvest(@WebParam(name="request") DoHarvestRequest request) { 
     48                ServiceExecutor<DoHarvestRequest, DoHarvestResponse> executor = new ExecuteHarvest(); 
     49                return executor.doService(request); 
    4250        } 
    4351         
     
    6270        } 
    6371         
    64         @WebMethod(operationName="getListType") 
    65         public GetListReturnType getListType(@WebParam(name="request") GetListType request) { 
    66                 return of.createGetListReturnType(); 
     72        @WebMethod(operationName="getList") 
     73        public GetListResponse getListType(@WebParam(name="request") GetListType request) { 
     74                ServiceExecutor<GetListType, GetListResponse> executor = new ExecuteGetList(); 
     75                return executor.doService(request); 
    6776        } 
    6877         
    6978        @WebMethod(operationName="getListNames") 
    70         public GetListNamesReturnType getListNames() { 
    71                 return of.createGetListNamesReturnType(); 
     79        public GetListNamesResponse getListNames() { 
     80                ServiceExecutor<Object, GetListNamesResponse> executor = new ExecuteGetListNames(); 
     81                return executor.doService(null); 
    7282        } 
    7383         
     
    8696                return of.createGetUsageStatsReturn(); 
    8797        } 
     98         
     99        @WebMethod(operationName="getStatusProcess") 
     100        public GetProcessStatusReturn getUsageStats(@WebParam(name="request") GetProcessStatusRequest request) { 
     101                return of.createGetProcessStatusReturn(); 
     102        } 
    88103} 
  • RevitalizationWS/ws/DPWS/trunk/src/main/java/ndg/services/revitalization/ejb/interfaces/DPWSLocal.java

    r7220 r7271  
    1 package ndg.services.revitalization; 
     1package ndg.services.revitalization.ejb.interfaces; 
    22import javax.ejb.Local; 
    33 
  • RevitalizationWS/ws/DPWS/trunk/src/main/java/ndg/services/revitalization/ejb/interfaces/DPWSRemote.java

    r7220 r7271  
    1 package ndg.services.revitalization; 
     1package ndg.services.revitalization.ejb.interfaces; 
    22import javax.ejb.Remote; 
    33 
  • RevitalizationWS/ws/DPWS/trunk/src/main/java/ndg/services/revitalization/harvest/oai/OAIHarvestRequest.java

    r7233 r7271  
    1 package ndg.services.revitalization.oai; 
     1package ndg.services.revitalization.harvest.oai; 
    22 
    33import java.util.Date; 
     4 
     5import ndg.services.revitalization.harvest.HarvestRequest; 
     6import ndg.services.revitalization.jpa.OaiProvider; 
     7import ndg.services.schemas.revitalization.DoHarvestRequest; 
    48 
    59/** 
    610 * Represents an Harvest request 
    711 **/ 
    8 public class HarvestRequest { 
     12public class OAIHarvestRequest extends HarvestRequest { 
    913 
    10         /** The baseURL of the data provider */ 
    11         private String baseURL; 
     14        public OAIHarvestRequest(OaiProvider provider, DoHarvestRequest doRequest) { 
     15                super(provider.getId(), provider.getFormat().getValue(), provider.getBaseUrl());         
     16                this.setSet(provider.getSet()); 
     17                if (!provider.getFormat().getValue().equals("ANY")) 
     18                        this.setMetadataPrefix(provider.getFormat().getValue()); 
     19        } 
     20         
     21        /* 
     22        public HarvestRequest(CSWProvider provider) { 
     23                this.setBaseURL(provider.get_baseURL_()); 
     24                this.setSet(provider.getSet()); 
     25                this.setMetadataPrefix(provider.getFormat().getName()); 
     26        } 
     27        */ 
    1228         
    1329        /** MetadataPrefix. e.g., "oai_dc", or null to harvest all formats */ 
     
    3551         
    3652         
    37         private boolean harvestAll; 
     53        private boolean harvestAll = true; 
    3854        private boolean harvestAllIfNoDeletedRecord; 
    39         public String getBaseURL() { 
    40                 return baseURL; 
    41         } 
    42         public void setBaseURL(String baseURL) { 
    43                 this.baseURL = baseURL; 
    44         } 
     55 
    4556        public String getMetadataPrefix() { 
    4657                return metadataPrefix; 
  • RevitalizationWS/ws/DPWS/trunk/src/main/java/ndg/services/revitalization/jpa/HarvestLog.java

    r7233 r7271  
    77 
    88/** 
    9  * The persistent class for the HarvestLog database table. 
     9 * The persistent class for the harvest_log database table. 
    1010 *  
    1111 */ 
    1212@Entity 
    13 @Table(name="HarvestLog") 
    14 @SequenceGenerator(name = "req_sequence", sequenceName = "req_id_seq") 
     13@Table(name="harvest_log") 
    1514public class HarvestLog implements Serializable { 
    1615        private static final long serialVersionUID = 1L; 
    17  
    18         @Id 
    19         @Column(name="reqID") 
    20         @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "req_sequence") 
    21         private String reqID; 
    22          
    23         @Column(name="delRecs") 
    24         private Integer delRecs; 
    25  
    26         @Column(name="newRecs") 
    27         private Integer newRecs; 
    28  
    29         @Column(name="updateRecs") 
    30         private Integer updateRecs;      
    31          
    32         @Column(name="totRecs") 
     16        private Integer reqId; 
     17        private Integer providerId; 
     18        private String providerIdType; 
     19        private Timestamp startHarvest; 
     20        private Timestamp stopHarvest; 
    3321        private Integer totRecs; 
    34          
    35         @Column(name="providerID") 
    36         private String providerID; 
    37  
    38         @Column(name="startHarvest") 
    39         private Timestamp startHarvest; 
    40  
    41         @Column(name="stopHarvest") 
    42         private Timestamp stopHarvest; 
    4322 
    4423    public HarvestLog() { 
    4524    } 
    46      
     25 
     26 
     27/* 
     28        @TableGenerator(name="HARV_KEY_GENERATOR",  
     29                        table="GENERATOR_TABLE", 
     30                pkColumnName="PRIMARY_KEY_COLUMN", 
     31                valueColumnName="VALUE_COLUMN", 
     32                pkColumnValue="HARVEST_LOG_ID", 
     33                allocationSize=10)       
     34        @GeneratedValue(strategy=GenerationType.TABLE, generator="HARV_KEY_GENERATOR") 
     35*/       
     36        @Id 
     37        @Column(name="req_id") 
     38        public Integer getReqId() { 
     39                return this.reqId; 
     40        } 
     41 
     42        public void setReqId(Integer reqId) { 
     43                this.reqId = reqId; 
     44        } 
     45 
     46 
     47        @Column(name="provider_id") 
     48        public Integer getProviderId() { 
     49                return this.providerId; 
     50        } 
     51 
     52        public void setProviderId(Integer providerId) { 
     53                this.providerId = providerId; 
     54        } 
     55 
     56 
     57        @Column(name="provider_id_type") 
     58        public String getProviderIdType() { 
     59                return this.providerIdType; 
     60        } 
     61 
     62        public void setProviderIdType(String providerIdType) { 
     63                this.providerIdType = providerIdType; 
     64        } 
     65 
     66 
     67        @Column(name="start_harvest") 
     68        public Timestamp getStartHarvest() { 
     69                return this.startHarvest; 
     70        } 
     71 
     72        public void setStartHarvest(Timestamp startHarvest) { 
     73                this.startHarvest = startHarvest; 
     74        } 
     75 
     76 
     77        @Column(name="stop_harvest") 
     78        public Timestamp getStopHarvest() { 
     79                return this.stopHarvest; 
     80        } 
     81 
     82        public void setStopHarvest(Timestamp stopHarvest) { 
     83                this.stopHarvest = stopHarvest; 
     84        } 
     85 
     86 
     87        @Column(name="tot_recs") 
    4788        public Integer getTotRecs() { 
    48                 return totRecs; 
     89                return this.totRecs; 
    4990        } 
    5091 
     
    5394        } 
    5495 
    55         public Integer getDelRecs() { 
    56                 return delRecs; 
    57         } 
    58  
    59         public void setDelRecs(Integer delRecs) { 
    60                 this.delRecs = delRecs; 
    61         } 
    62  
    63         public Integer getNewRecs() { 
    64                 return newRecs; 
    65         } 
    66  
    67         public void setNewRecs(Integer newRecs) { 
    68                 this.newRecs = newRecs; 
    69         } 
    70  
    71         public String getProviderID() { 
    72                 return providerID; 
    73         } 
    74  
    75         public void setProviderID(String providerID) { 
    76                 this.providerID = providerID; 
    77         } 
    78  
    79         public String getReqID() { 
    80                 return reqID; 
    81         } 
    82  
    83         public void setReqID(String reqID) { 
    84                 this.reqID = reqID; 
    85         } 
    86  
    87         public Timestamp getStartHarvest() { 
    88                 return startHarvest; 
    89         } 
    90  
    91         public void setStartHarvest(Timestamp startHarvest) { 
    92                 this.startHarvest = startHarvest; 
    93         } 
    94  
    95         public Timestamp getStopHarvest() { 
    96                 return stopHarvest; 
    97         } 
    98  
    99         public void setStopHarvest(Timestamp stopHarvest) { 
    100                 this.stopHarvest = stopHarvest; 
    101         } 
    102  
    103         public Integer getUpdateRecs() { 
    104                 return updateRecs; 
    105         } 
    106  
    107         public void setUpdateRecs(Integer updateRecs) { 
    108                 this.updateRecs = updateRecs; 
    109         } 
    110  
    111         public static long getSerialversionuid() { 
    112                 return serialVersionUID; 
    113         } 
    11496} 
  • RevitalizationWS/ws/DPWS/trunk/src/main/resources/META-INF/persistence.xml

    r7233 r7271  
    33        xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    44        xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd"> 
    5         <persistence-unit name="dpws_jpa" transaction-type="JTA"> 
    6                 <jta-data-source>java:/DPWS_JPA</jta-data-source> 
     5        <persistence-unit name="discoveryDPWS" transaction-type="JTA"> 
     6                <jta-data-source>jdbc/discoveryDPWS</jta-data-source> 
    77                <properties> 
    88                        <property name="hibernate.dialect" value="org.hibernate.dialect.HSQLDialect" /> 
    9                         <property name="hibernate.hbm2ddl.auto" value="create-drop" /> 
    10                 </properties> 
     9                        <property name="hibernate.hbm2ddl.auto" value="validate" /> 
     10                </properties>            
    1111        </persistence-unit> 
    1212</persistence> 
Note: See TracChangeset for help on using the changeset viewer.