Package com.dp.nebula.wormhole.common

Examples of com.dp.nebula.wormhole.common.WormholeException

69
70
71
72
73
74
75
76
        DBUtils.update(conn, sql);
      }
      conn.close();
    }catch (Exception e) {
      logger.error(writerID + ": Greenplum writer prepare failed. ");
      throw new WormholeException(e,JobStatus.PRE_WRITE_FAILED.getStatus()+errorCodeAdd,writerID);
    }
  }
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
 
  @Override
  public void rollback(IParam param) {
    if(rollback.isEmpty()){
      logger.error(writerID + ": Fail to roll back because rollback sql is empty!");
      throw new WormholeException("Fail to roll back because rollback sql is empty!",JobStatus.ROLL_BACK_FAILED.getStatus()+errorCodeAdd,writerID);
    }
    try{
      conn = DBSource.getConnection(GreenplumWriter.class, ip, writerID, dbname);
      String[] sqlArray = rollback.split(";");
      for(String sql:sqlArray){
        sql = sql.trim();
        if(sql.isEmpty()) {
          continue;
        }
        DBUtils.update(conn, sql);
      }
      conn.close();
    } catch (Exception e) {
      logger.error(writerID + ": Greenplum writer roll back failed. ");
      throw new WormholeException(e,JobStatus.ROLL_BACK_FAILED.getStatus()+errorCodeAdd,writerID);
    }
  }
View Full Code Here
126
127
128
129
130
131
132
133
134
        }
        conn.close();
        conn.close();
      }catch (Exception e) {
        logger.error(writerID + ": Greenplum writer dopost failed. ");
        throw new WormholeException(e,JobStatus.POST_WRITE_FAILED.getStatus()+errorCodeAdd,writerID);
      }
    }
  }
View Full Code Here
157
158
159
160
161
162
163
164
    /* for connection session */
    Properties p = createProperties();
    try {
      DBSource.register(GreenplumWriter.class, this.ip, this.writerID, this.dbname, p);
    } catch (Exception e) {
      throw new WormholeException(e, JobStatus.WRITE_CONNECTION_FAILED.getStatus() + errorCodeAdd);
    }
  }
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
          field = line.getField(j);
          j++;
        }
        else {
          logger.error(writerID + ": fields number is less than column number");
          throw new WormholeException("MysqlWriter: Fields number is less than column number ",JobStatus.WRITE_FAILED.getStatus(),writerID);
        }
          if (null != field) {
            StringBuilder sb = new StringBuilder();
            char[] characters = field.toCharArray();
            for(int k = 0; k < characters.length; k++) {
View Full Code Here
117
118
119
120
121
122
123
124
  @Override
  public void connection() {
    try {
      conn = DBSource.getConnection(GreenplumWriter.class, ip, writerID, dbname);
    } catch (Exception e) {
      throw new WormholeException(e, JobStatus.WRITE_CONNECTION_FAILED.getStatus() + errorCodeAdd);
    }
  }
View Full Code Here
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
      }
    }
  }
 
  private WormholeException throwException(Exception e) {
    WormholeException ex = new WormholeException(e,JobStatus.WRITE_FAILED.getStatus(),writerID);
    if(e instanceof WormholeException) {
      ex = (WormholeException) e;
    }
    else if(e instanceof PSQLException) {
      ErrorCodeUtils.psqlWriterWrapper((PSQLException)e,ex);
    }
    else if(e instanceof IOException && e.getCause() != null
        && e.getCause() instanceof PSQLException) {
      ErrorCodeUtils.psqlWriterWrapper((PSQLException)(e.getCause()),ex);
    }
    ex.setStatusCode(ex.getStatusCode() + errorCodeAdd);
    return ex;
  }
View Full Code Here
233
234
235
236
237
238
239
240
241
242
243
          field = line.getField(j);
          j++;
        }
        else {
          logger.error(writerID + ": field number is less than column number.");
          throw new WormholeException("GreenplumWriter: Fields number is less than column number ",JobStatus.WRITE_FAILED.getStatus(),writerID);
        }
          if (null != field) {
            StringBuilder sb = new StringBuilder();
            char[] characters = field.toCharArray();
            for(int k = 0; k < characters.length; k++){
View Full Code Here
300
301
302
303
304
305
306
307
308
309
310
//           }
    } catch (Exception e) {
      logger.warn(writerID + ": Copy data failed for one Line.");
      if(!outputStream.isActive()) {
        logger.error(writerID + ": Copy data failed:" + line.toString('\t'),e);
        throw new WormholeException(e,JobStatus.WRITE_FAILED.getStatus(),writerID);
      }
           isSuccess = false;
    }
    if(isSuccess) {
      this.sucLineCounter ++ ;
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
        client = new HiveJdbcClient.Builder(path).username(username)
            .password(password).sql(sql).build();
        client.initialize();
        client.processInsertQuery(reduceNumber);
      } catch (Exception e) {
        throw new WormholeException(e,
            JobStatus.READ_FAILED.getStatus());
      } finally {
        if (client != null) {
          client.close();
        }
View Full Code Here
TOP

Related Classes of com.dp.nebula.wormhole.common.WormholeException

  • com.dp.nebula.wormhole.engine.core.AbstractPluginManager
  • com.dp.nebula.wormhole.engine.storage.RAMStorage
  • com.dp.nebula.wormhole.plugins.common.DBUtils
  • com.dp.nebula.wormhole.plugins.common.HBaseClient
  • com.dp.nebula.wormhole.plugins.reader.greenplumreader.GreenplumReader
  • com.dp.nebula.wormhole.plugins.reader.greenplumreader.GreenplumReaderPeriphery
  • com.dp.nebula.wormhole.plugins.reader.greenplumreader.GreenplumReaderSplitter
  • com.dp.nebula.wormhole.plugins.reader.hbasereader.HBaseReader
  • com.dp.nebula.wormhole.plugins.reader.hivereader.HiveJdbcClient
  • com.dp.nebula.wormhole.plugins.reader.hivereader.HiveReader
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.