// ORM class for TT // WARNING: This class is AUTO-GENERATED. Modify at your own risk. import org.apache.hadoop.io.BytesWritable; import org.apache.hadoop.io.Text; import org.apache.hadoop.io.Writable; import org.apache.hadoop.mapred.lib.db.DBWritable; import com.cloudera.sqoop.lib.JdbcWritableBridge; import com.cloudera.sqoop.lib.DelimiterSet; import com.cloudera.sqoop.lib.FieldFormatter; import com.cloudera.sqoop.lib.RecordParser; import com.cloudera.sqoop.lib.BooleanParser; import com.cloudera.sqoop.lib.BlobRef; import com.cloudera.sqoop.lib.ClobRef; import com.cloudera.sqoop.lib.LargeObjectLoader; import com.cloudera.sqoop.lib.SqoopRecord; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; import java.nio.ByteBuffer; import java.nio.CharBuffer; import java.sql.Date; import java.sql.Time; import java.sql.Timestamp; import java.util.Arrays; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.TreeMap; public class TT extends SqoopRecord implements DBWritable, Writable { private final int PROTOCOL_VERSION = 3; public int getClassFormatVersion() { return PROTOCOL_VERSION; } protected ResultSet __cur_result_set; private Integer I; public Integer get_I() { return I; } public void set_I(Integer I) { this.I = I; } public TT with_I(Integer I) { this.I = I; return this; } private String S; public String get_S() { return S; } public void set_S(String S) { this.S = S; } public TT with_S(String S) { this.S = S; return this; } public boolean equals(Object o) { if (this == o) { return true; } if (!(o instanceof TT)) { return false; } TT that = (TT) o; boolean equal = true; equal = equal && (this.I == null ? that.I == null : this.I.equals(that.I)); equal = equal && (this.S == null ? that.S == null : this.S.equals(that.S)); return equal; } public void readFields(ResultSet __dbResults) throws SQLException { this.__cur_result_set = __dbResults; this.I = JdbcWritableBridge.readInteger(1, __dbResults); this.S = JdbcWritableBridge.readString(2, __dbResults); } public void loadLargeObjects(LargeObjectLoader __loader) throws SQLException, IOException, InterruptedException { } public void write(PreparedStatement __dbStmt) throws SQLException { write(__dbStmt, 0); } public int write(PreparedStatement __dbStmt, int __off) throws SQLException { JdbcWritableBridge.writeInteger(I, 1 + __off, 4, __dbStmt); JdbcWritableBridge.writeString(S, 2 + __off, 12, __dbStmt); return 2; } public void readFields(DataInput __dataIn) throws IOException { if (__dataIn.readBoolean()) { this.I = null; } else { this.I = Integer.valueOf(__dataIn.readInt()); } if (__dataIn.readBoolean()) { this.S = null; } else { this.S = Text.readString(__dataIn); } } public void write(DataOutput __dataOut) throws IOException { if (null == this.I) { __dataOut.writeBoolean(true); } else { __dataOut.writeBoolean(false); __dataOut.writeInt(this.I); } if (null == this.S) { __dataOut.writeBoolean(true); } else { __dataOut.writeBoolean(false); Text.writeString(__dataOut, S); } } private final DelimiterSet __outputDelimiters = new DelimiterSet((char) 44, (char) 10, (char) 0, (char) 0, false); public String toString() { return toString(__outputDelimiters, true); } public String toString(DelimiterSet delimiters) { return toString(delimiters, true); } public String toString(boolean useRecordDelim) { return toString(__outputDelimiters, useRecordDelim); } public String toString(DelimiterSet delimiters, boolean useRecordDelim) { StringBuilder __sb = new StringBuilder(); char fieldDelim = delimiters.getFieldsTerminatedBy(); __sb.append(FieldFormatter.escapeAndEnclose(I==null?"null":"" + I, delimiters)); __sb.append(fieldDelim); __sb.append(FieldFormatter.escapeAndEnclose(S==null?"null":S, delimiters)); if (useRecordDelim) { __sb.append(delimiters.getLinesTerminatedBy()); } return __sb.toString(); } private final DelimiterSet __inputDelimiters = new DelimiterSet((char) 44, (char) 10, (char) 0, (char) 0, false); private RecordParser __parser; public void parse(Text __record) throws RecordParser.ParseError { if (null == this.__parser) { this.__parser = new RecordParser(__inputDelimiters); } List __fields = this.__parser.parseRecord(__record); __loadFromFields(__fields); } public void parse(CharSequence __record) throws RecordParser.ParseError { if (null == this.__parser) { this.__parser = new RecordParser(__inputDelimiters); } List __fields = this.__parser.parseRecord(__record); __loadFromFields(__fields); } public void parse(byte [] __record) throws RecordParser.ParseError { if (null == this.__parser) { this.__parser = new RecordParser(__inputDelimiters); } List __fields = this.__parser.parseRecord(__record); __loadFromFields(__fields); } public void parse(char [] __record) throws RecordParser.ParseError { if (null == this.__parser) { this.__parser = new RecordParser(__inputDelimiters); } List __fields = this.__parser.parseRecord(__record); __loadFromFields(__fields); } public void parse(ByteBuffer __record) throws RecordParser.ParseError { if (null == this.__parser) { this.__parser = new RecordParser(__inputDelimiters); } List __fields = this.__parser.parseRecord(__record); __loadFromFields(__fields); } public void parse(CharBuffer __record) throws RecordParser.ParseError { if (null == this.__parser) { this.__parser = new RecordParser(__inputDelimiters); } List __fields = this.__parser.parseRecord(__record); __loadFromFields(__fields); } private void __loadFromFields(List fields) { Iterator __it = fields.listIterator(); String __cur_str; __cur_str = __it.next(); if (__cur_str.equals("null") || __cur_str.length() == 0) { this.I = null; } else { this.I = Integer.valueOf(__cur_str); } __cur_str = __it.next(); if (__cur_str.equals("null")) { this.S = null; } else { this.S = __cur_str; } } public Object clone() throws CloneNotSupportedException { TT o = (TT) super.clone(); return o; } public Map getFieldMap() { Map __sqoop$field_map = new TreeMap(); __sqoop$field_map.put("I", this.I); __sqoop$field_map.put("S", this.S); return __sqoop$field_map; } public void setField(String __fieldName, Object __fieldVal) { if ("I".equals(__fieldName)) { this.I = (Integer) __fieldVal; } else if ("S".equals(__fieldName)) { this.S = (String) __fieldVal; } else { throw new RuntimeException("No such field: " + __fieldName); } } }