| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224 |
- // 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<String> __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<String> __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<String> __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<String> __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<String> __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<String> __fields = this.__parser.parseRecord(__record);
- __loadFromFields(__fields);
- }
- private void __loadFromFields(List<String> fields) {
- Iterator<String> __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<String, Object> getFieldMap() {
- Map<String, Object> __sqoop$field_map = new TreeMap<String, Object>();
- __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);
- }
- }
- }
|