1
2
3 package com.pnpconsult.zeiterfassung.dump;
4
5 import java.sql.Connection;
6 import java.sql.ResultSet;
7 import java.sql.Statement;
8
9 import net.sf.hibernate.Session;
10
11 import com.pnpconsult.zeiterfassung.helper.SessionLocator;
12
13 /***
14 * @author <a href="mailto:powerpete@users.sf.net">Moritz Petersen</a>
15 * @version $Id: UpdateProjectIdMain.java,v 1.2 2004/06/24 20:54:20 powerpete Exp $
16 */
17 public class UpdateProjectIdMain
18 {
19 private static final String TABLE = "userproject";
20
21 public static void main(String[] args) throws Exception
22 {
23 Session session = SessionLocator.getSession();
24 Connection con = session.connection();
25 Statement selectAll = con.createStatement();
26 ResultSet all = selectAll.executeQuery("SELECT id, projectNumber FROM " + TABLE);
27 while (all.next())
28 {
29 int id = all.getInt(1);
30
31 String projectNumber = all.getString(2);
32
33 Statement selectProject = con.createStatement();
34 ResultSet project = selectProject.executeQuery("SELECT id FROM project WHERE number = '" + projectNumber + "'");
35 if (project.next())
36 {
37 int projectId = project.getInt(1);
38
39 Statement update = con.createStatement();
40 String updateSql = "UPDATE " + TABLE + " SET projectId = " + projectId + " WHERE id = " + id;
41 System.out.println(updateSql);
42 update.executeUpdate(updateSql);
43 update.close();
44 }
45 project.close();
46 selectProject.close();
47 }
48 all.close();
49 selectAll.close();
50 session.close();
51 }
52 }