Pessoal,
boa tarde!
Eu estou tentando inserir alguns dados de um arquivo TXT em um banco de dados MYSQL. eu primeiramente obtenho os dados do TXT, seto eles em algumas variaveis de uma classe arquivo para obter somente o que preciso e depois queria inserí-los no banco, porém o que esta ocorrendo e que apenas é gravado NULL. o que estou fazendo de errado ? segue o meu código abaixo:
public void ProcessarDados(){
String leitor = null; // -> variavel utilizada para percorrer o arquivo.
try{
// CAPTURA AS LOGS DO DIRETORIO INFORMADO
File [] arquivos;
File dir = new File("C:/LOG/HG");
arquivos = dir.listFiles();
// LE TODOS OS ARQUIVOS QUE ESTAO NO DIRETORIO
for (int i = 0; i < arquivos.length; i++){
System.out.println("Lendo o arquivo:" + arquivos[i].getName());
// LEITURA DOS DADOS DOS ARQUIVOS.
FileInputStream fis = new FileInputStream(arquivos[i]);
InputStreamReader stream = new InputStreamReader(fis);
BufferedReader reader = new BufferedReader(stream);
// LOOP PARA PERCORRER OS ARQUIVOS ATÉ O ULTIMO REGISTROS
while((leitor=reader.readLine() ) != null){
// SEPARACAO DO ARQUIVO EM COLUNAS
String[] novoArq = leitor.split(" ");
//System.out.println(retornaListaNumerada(novoArq));
// CAPTURA APENAS AS INFORMACOES DOS ERROS
if(leitor.contains("ABENDED") || leitor.contains("FAILED") ||
leitor.contains("NOT CATLGD 2") || leitor.contains("UNEXPLA")){
// FILTRA APENAS JOBS COM 8 POSICOES
if(novoArq[13].length() > 8){
// CRIA UM OBJETO DA CLASSE ARQUIVO PARA INSERCAO DOS DADOS
Arquivo_Abend colunas = new Arquivo_Abend();
//*** DIVISAO DAS COLUNAS *****
//SISTEMA
colunas.setSISTEMA(novoArq[13].substring(0,2));
//DATA DE PROCESSAMENTO
colunas.setDT_PROCESSAMENTO(novoArq[2]);
//HORA
colunas.setHORA_INICIAL(novoArq[3].substring(0,4));
//ODATE
colunas.setODATE(novoArq[4]);
//JOB
colunas.setJOB(novoArq[13].substring(0,8));
//JOB_ID
colunas.setJOB_ID(novoArq[13].split("/")[1]);
//UID
colunas.setUID(novoArq[14].substring(4,9));
//OCORRENCIAS
if(leitor.contains("UNEXPLA")){
colunas.setOCORRENCIAS(novoArq[16] + " " + novoArq[18]);
} else if (leitor.contains("NOT CATLGD 2")){
colunas.setOCORRENCIAS(novoArq[15] + " " + novoArq[16] + " " + novoArq[17] + " " + novoArq[18] + " " + novoArq[19]);
} else if (leitor.contains("FAILED")){
colunas.setOCORRENCIAS(novoArq[15] + " " + novoArq[16] + " " + novoArq[17]);
} else if (leitor.contains("ABENDED")){
colunas.setOCORRENCIAS(novoArq[15] + " " + novoArq[17]);
}
} // FECHA O SEGUNDO IF
} // FECHA O PRIMEIRO IF
} // FECHA O WHILE
} //FECHA O FOR
}catch(IOException x){
x.printStackTrace();
}
}// FECHA O METODO
public void inserirBD(Arquivo_Abend dados){
conectar();
try {
comando.executeUpdate("INSERT INTO Arquivo.Abend(SISTEMA,DT_PROCESSAMENTO,HORA_INICIAL,ODATE,JOB,JOB_ID,UID,OCORRENCIAS)" +
"VALUES('" + dados.getSISTEMA() + "','" + dados.getDT_PROCESSAMENTO() + "','"+ dados.getHORA_INICIAL() + "','"
+ dados.getODATE() + "','" + dados.getJOB() + "','" + dados.getJOB_ID() + "','"
+ dados.getUID() + "','" + dados.getOCORRENCIAS() + "')");
System.out.println("Dados Inseridos!");
} catch (SQLException e) {
imprimeErro("Erro ao inserir Dados", e.getMessage());
} finally {
fechar();
}
}
Obrigado.