KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > tdsecurities > itracker > converter > VersionConverter


1 /**
2  * Copyright (c) 2003 TD Securities
3  * Created on Dec 31, 2003
4  */

5 package com.tdsecurities.itracker.converter;
6
7 import java.sql.PreparedStatement JavaDoc;
8 import java.sql.ResultSet JavaDoc;
9 import java.sql.Timestamp JavaDoc;
10 import java.util.Date JavaDoc;
11
12 import org.apache.log4j.Logger;
13
14 import com.tdsecurities.itracker.common.DataSourceManager;
15
16 /**
17  * @author pardec2
18  * @version $Id$
19  */

20 public class VersionConverter extends BasicConverter
21 {
22     private static final String JavaDoc SOURCE_SQL = "select distinct group_id from groups order by group_id";
23     private static final String JavaDoc TARGET_SQL = "INSERT INTO versionbean (id,major,minor,version_number,description,status,create_date,last_modified,project_id) values (?, 1, 0, '1.0', '1.0', 1, ?, ?, ?)";
24     private static final String JavaDoc LAST_ID_SQL = "select max(id) from versionbean";
25     
26     private Logger log = Logger.getLogger(VersionConverter.class);
27     
28     protected String JavaDoc getSourceQuery()
29     {
30         return SOURCE_SQL;
31     }
32     
33     protected String JavaDoc getTargetQuery()
34     {
35         return TARGET_SQL;
36     }
37
38     protected String JavaDoc getIdStoreName()
39     {
40         return "version";
41     }
42
43     protected String JavaDoc getLastIdQuery()
44     {
45         return LAST_ID_SQL;
46     }
47
48     protected int prepareTargetStatement(PreparedStatement JavaDoc targetStmt, ResultSet JavaDoc rs) throws Exception JavaDoc
49     {
50         long now = (new Date JavaDoc()).getTime();
51         int col = 1;
52         targetStmt.setInt(col++, rs.getInt("group_id"));
53         targetStmt.setTimestamp(col++, new Timestamp JavaDoc(now));
54         targetStmt.setTimestamp(col++, new Timestamp JavaDoc(now));
55         targetStmt.setInt(col++, rs.getInt("group_id"));
56         return BasicConverter.OK;
57     }
58
59     protected void preConversionProcessing()
60     {
61         log.info("Creating versions");
62         executeUpdate(DataSourceManager.ITRACKER, "delete from versionbean");
63     }
64
65     protected void postConversionProcessing()
66     {
67         log.info("Created versions");
68     }
69 }
70
Popular Tags