001
014
015 package com.liferay.portal.upgrade.util;
016
017 import com.liferay.portal.kernel.upgrade.util.BaseUpgradeColumnImpl;
018 import com.liferay.portal.kernel.upgrade.util.ValueMapper;
019 import com.liferay.portal.kernel.upgrade.util.ValueMapperFactoryUtil;
020
021 import java.sql.Types;
022
023
027 public class PKUpgradeColumnImpl extends BaseUpgradeColumnImpl {
028
029 public PKUpgradeColumnImpl(String name, boolean trackValues) {
030 this(name, null, trackValues);
031 }
032
033 public PKUpgradeColumnImpl(
034 String name, Integer oldColumnType, boolean trackValues) {
035
036 super(name, oldColumnType);
037
038 _newColumnType = new Integer(Types.BIGINT);
039 _trackValues = trackValues;
040
041 if (_trackValues) {
042 _valueMapper = ValueMapperFactoryUtil.getValueMapper();
043 }
044 }
045
046 public Integer getNewColumnType(Integer defaultType) {
047 return _newColumnType;
048 }
049
050 public Object getNewValue(Object oldValue) throws Exception {
051 Long newValue = new Long(increment());
052
053 if (_trackValues) {
054 _valueMapper.mapValue(oldValue, newValue);
055 }
056
057 return newValue;
058 }
059
060 public boolean isTrackValues() {
061 return _trackValues;
062 }
063
064 public ValueMapper getValueMapper() {
065 return _valueMapper;
066 }
067
068 private Integer _newColumnType;
069 private boolean _trackValues;
070 private ValueMapper _valueMapper;
071
072 }