Project

General

Profile

Download (4.96 KB) Statistics
| Branch: | Tag: | Revision:
1 02390953 Andreas Müller
/**
2
* Copyright (C) 2016 EDIT
3
* European Distributed Institute of Taxonomy
4
* http://www.e-taxonomy.eu
5
*
6
* The contents of this file are subject to the Mozilla Public License Version 1.1
7
* See LICENSE.TXT at the top of this package for the full license terms.
8
*/
9 af612856 Andreas Müller
package eu.etaxonomy.cdm.database.update.v40_50;
10 02390953 Andreas Müller
11
import java.sql.ResultSet;
12
import java.sql.SQLException;
13 99e01f35 Andreas Müller
import java.util.List;
14 02390953 Andreas Müller
15 5c3f30b9 Andreas Müller
import org.apache.commons.lang3.StringUtils;
16 23de68fc Andreas Müller
import org.apache.logging.log4j.LogManager;import org.apache.logging.log4j.Logger;
17 02390953 Andreas Müller
18
import eu.etaxonomy.cdm.common.CdmUtils;
19
import eu.etaxonomy.cdm.common.monitor.IProgressMonitor;
20
import eu.etaxonomy.cdm.database.ICdmDataSource;
21
import eu.etaxonomy.cdm.database.update.CaseType;
22 99e01f35 Andreas Müller
import eu.etaxonomy.cdm.database.update.ISchemaUpdaterStep;
23 ba35e2f8 Andreas Müller
import eu.etaxonomy.cdm.database.update.SchemaUpdateResult;
24 02390953 Andreas Müller
import eu.etaxonomy.cdm.database.update.SchemaUpdaterStepBase;
25
import eu.etaxonomy.cdm.strategy.cache.agent.PersonDefaultCacheStrategy;
26
27
/**
28
 * Updates the field Person.initials from Person.firstname.
29
 * @author a.mueller
30 53db84af Andreas Müller
 * @since 21.05.2017
31 02390953 Andreas Müller
 *
32
 */
33 65fbcddb Andreas Müller
public class InitialsUpdater extends SchemaUpdaterStepBase{
34 02390953 Andreas Müller
    @SuppressWarnings("unused")
35 23de68fc Andreas Müller
    private static final Logger logger = LogManager.getLogger(InitialsUpdater.class);
36 02390953 Andreas Müller
37
    /**
38
     * @return
39
     */
40 99e01f35 Andreas Müller
    public static InitialsUpdater NewInstance(List<ISchemaUpdaterStep> stepList) {
41
        return new InitialsUpdater(stepList);
42 02390953 Andreas Müller
    }
43
44
    private static final String stepName = "Make Person initials from firstname";
45
46
    /**
47
     * @param stepName
48
     */
49 99e01f35 Andreas Müller
    protected InitialsUpdater(List<ISchemaUpdaterStep> stepList) {
50
        super(stepList, stepName);
51 02390953 Andreas Müller
    }
52
53
54
55
    @Override
56 ba35e2f8 Andreas Müller
    public void invoke(ICdmDataSource datasource, IProgressMonitor monitor,
57
            CaseType caseType, SchemaUpdateResult result) throws SQLException {
58
59
        try {
60
            PersonDefaultCacheStrategy formatter = PersonDefaultCacheStrategy.NewInstance();
61
62
            String sqlCopyFirstname = "UPDATE AgentBase SET initials = firstname WHERE DTYPE='Person'"
63 5c3f30b9 Andreas Müller
                    + " AND firstname IS NOT NULL AND initials IS NULL ";
64 02390953 Andreas Müller
65 5c3f30b9 Andreas Müller
            String sqlRemoveFirstname = "UPDATE AgentBase SET firstname = %s, initials = %s WHERE id = %d";
66 02390953 Andreas Müller
67 ba35e2f8 Andreas Müller
            String sqlSelectInitials = "SELECT id, firstname FROM AgentBase WHERE DTYPE='Person'"
68 5c3f30b9 Andreas Müller
                    + " AND firstname IS NOT NULL AND initials = firstname ";
69 02390953 Andreas Müller
70 986f6827 Andreas Müller
            datasource.executeUpdate(sqlCopyFirstname);
71 ba35e2f8 Andreas Müller
72
            ResultSet rs = datasource.executeQuery(sqlSelectInitials);
73
            while (rs.next()){
74 3989c417 Andreas Müller
                handleSingle(datasource, formatter, sqlRemoveFirstname, rs, monitor, result);
75 ba35e2f8 Andreas Müller
            }
76
        } catch (Exception e) {
77
            String message = e.getMessage();
78
            monitor.warning(message, e);
79
            result.addException(e, message, this, "invoke");
80
        }
81 02390953 Andreas Müller
82 ba35e2f8 Andreas Müller
        return;
83
    }
84 02390953 Andreas Müller
85
86
87 ba35e2f8 Andreas Müller
    /**
88
     * @param datasource
89
     * @param formatter
90
     * @param sqlRemoveFirstname
91
     * @param rs
92
     * @param monitor
93
     * @throws SQLException
94
     */
95 3989c417 Andreas Müller
    private void handleSingle(ICdmDataSource datasource, PersonDefaultCacheStrategy formatter,
96 ba35e2f8 Andreas Müller
            String sqlRemoveFirstname, ResultSet rs, IProgressMonitor monitor, SchemaUpdateResult result) throws SQLException {
97
        try {
98 02390953 Andreas Müller
            Integer id = rs.getInt("id");
99
            String firstname = rs.getString("firstname");
100
101 986f6827 Andreas Müller
            String initialsAllow = formatter.getInitialsFromGivenName(firstname, false);
102
            String initialsForced = formatter.getInitialsFromGivenName(firstname, true);
103 02390953 Andreas Müller
104
            String firstnameSql;
105
            String initialsSql;
106
            if (CdmUtils.equalsIgnoreWS(firstname, initialsForced)){
107
                //firstname was initials
108
                firstnameSql = " null ";
109
                initialsSql = initialsForced;
110
            }else if (CdmUtils.equalsIgnoreWS(firstname, initialsAllow)){
111 5c3f30b9 Andreas Müller
                //first name has only abbreviations, but not all of them being 1-letter, keep everything
112 02390953 Andreas Müller
                firstnameSql = " firstname ";
113
                initialsSql = initialsAllow;
114
            }else {
115 5c3f30b9 Andreas Müller
                //first name has non abbreviated parts, keep it as it is and use initials forced as initials
116 02390953 Andreas Müller
                firstnameSql = " firstname ";
117
                initialsSql = initialsForced;
118
            }
119 3989c417 Andreas Müller
            if (initialsSql!= null){
120
                initialsSql = initialsSql.replace("'", "\\'");
121
            }
122 5c3f30b9 Andreas Müller
            //handle blank
123
            if (StringUtils.isBlank(firstname)){
124
                firstnameSql = " null ";
125
                initialsSql = " null ";
126
            }else {
127
                initialsSql = "'" + initialsSql + "'";
128
            }
129 02390953 Andreas Müller
130
            String sql = String.format(sqlRemoveFirstname, firstnameSql, initialsSql, id);
131
            //remove old relationship
132
            datasource.executeUpdate(sql);
133 ba35e2f8 Andreas Müller
        } catch (Exception e) {
134
            String message = e.getMessage();
135
            monitor.warning(message, e);
136 3989c417 Andreas Müller
            result.addException(e, message, this, "handleSingle");
137 02390953 Andreas Müller
        }
138
    }
139
140
}