1
22
23 package com.liferay.portal.upgrade.util;
24
25 import com.liferay.portal.kernel.upgrade.util.BaseUpgradeColumnImpl;
26 import com.liferay.portal.kernel.upgrade.util.ValueMapper;
27 import com.liferay.portal.kernel.upgrade.util.ValueMapperFactoryUtil;
28
29 import java.sql.Types;
30
31
37 public class PKUpgradeColumnImpl extends BaseUpgradeColumnImpl {
38
39 public PKUpgradeColumnImpl(String name, boolean trackValues) {
40 this(name, null, trackValues);
41 }
42
43 public PKUpgradeColumnImpl(
44 String name, Integer oldColumnType, boolean trackValues) {
45
46 super(name, oldColumnType);
47
48 _newColumnType = new Integer(Types.BIGINT);
49 _trackValues = trackValues;
50
51 if (_trackValues) {
52 _valueMapper = ValueMapperFactoryUtil.getValueMapper();
53 }
54 }
55
56 public Integer getNewColumnType(Integer defaultType) {
57 return _newColumnType;
58 }
59
60 public Object getNewValue(Object oldValue) throws Exception {
61 Long newValue = new Long(increment());
62
63 if (_trackValues) {
64 _valueMapper.mapValue(oldValue, newValue);
65 }
66
67 return newValue;
68 }
69
70 public boolean isTrackValues() {
71 return _trackValues;
72 }
73
74 public ValueMapper getValueMapper() {
75 return _valueMapper;
76 }
77
78 private Integer _newColumnType;
79 private boolean _trackValues;
80 private ValueMapper _valueMapper;
81
82 }