importação txt para firebird

Welder · Abril 30, 2009

Estou importando um txt para fdb usando dbexpress e clientdataset, uso o código

procedure TfrmPrincipal.BitBtn1Click(Sender: TObject);

var

Txt: Textfile;

Terceiro, Ano, Mes, Dia: string;

begin

BitBtn1.Enabled:= false;

if OpenDialog1.Execute then

begin

dmImportar.cdsTerceiros.Open;

AssignFile(Txt,(OpenDialog1.FileName));//{ NOME do arquivo texto}

Animate1.Visible:= true;

Animate1.Active:= true;

Reset(Txt);

While not Eoln(Txt) do

begin

Readln(Txt,Terceiro);

dmImportar.cdsTerceiros.Insert;

dmImportar.cdsTerceiros.FieldByName('TIPO').Value:= Copy(Terceiro,1,3);

dmImportar.cdsTerceiros.FieldByName('ORDEM').Value:= Copy(Terceiro,4,5);

dmImportar.cdsTerceiros.FieldByName('FILLER1').Value:= Copy(Terceiro,09,2);

dmImportar.cdsTerceiros.FieldByName('PERSONALIDADE').Value:= StrToInt(Copy(Terceiro,11,1));

dmImportar.cdsTerceiros.FieldByName('CNPJCPF').Value:= Copy(Terceiro,12,14);

dmImportar.cdsTerceiros.FieldByName('RAZAOSOCIAL').Value:= Copy(Terceiro,26,60);

dmImportar.cdsTerceiros.FieldByName('APELIDO').Value:= Copy(Terceiro,86,20);

dmImportar.cdsTerceiros.FieldByName('ENDERECO_TIPO').Value:= Copy(Terceiro,106,10);

dmImportar.cdsTerceiros.FieldByName('ENDERECO_LOGRADOURO').Value:= Copy(Terceiro,116,60);

dmImportar.cdsTerceiros.FieldByName('NUMERO').Value:= Copy(Terceiro,176,10);

dmImportar.cdsTerceiros.FieldByName('CEP').Value:= Copy(Terceiro,206,09);

dmImportar.cdsTerceiros.FieldByName('BAIRRO').Value:= Copy(Terceiro,215,30);

dmImportar.cdsTerceiros.FieldByName('MUNICIPIO').Value:= Copy(Terceiro,245,30);

dmImportar.cdsTerceiros.FieldByName('UF').Value:= Copy(Terceiro,275,2);

Ano := Copy(Terceiro,277,4);

Mes := Copy(Terceiro,281,2);

Dia := Copy(Terceiro,283,2);

dmImportar.cdsTerceiros.FieldByName('DATAINICIOATIVIDADES').Value:= dia+'/'+mes+'/'+ano;

dmImportar.cdsTerceiros.FieldByName('TELEFONE_DDD').Value:= Copy(Terceiro,285,5);

dmImportar.cdsTerceiros.FieldByName('TELEFONE_NUMERO').Value:= Copy(Terceiro,290,10);

dmImportar.cdsTerceiros.FieldByName('TELEFAX_DDD').Value:= Copy(Terceiro,300,5);

dmImportar.cdsTerceiros.FieldByName('TELEFAX_NUMERO').Value:= Copy(Terceiro,305,10);

dmImportar.cdsTerceiros.FieldByName('EMAIL').Value:= Copy(Terceiro,315,50);

dmImportar.cdsTerceiros.FieldByName('HOMEPAGE').Value:= Copy(Terceiro,365,60);

dmImportar.cdsTerceiros.FieldByName('INSCEST').Value:= Copy(Terceiro,425,20);

dmImportar.cdsTerceiros.FieldByName('INSCMUN').Value:= Copy(Terceiro,445,20);

dmImportar.cdsTerceiros.FieldByName('CNAE').Value:= Copy(Terceiro,465,10);

dmImportar.cdsTerceiros.FieldByName('RG_NUMERO').Value:= Copy(Terceiro,475,18);

dmImportar.cdsTerceiros.FieldByName('RG_ORGAO').Value:= Copy(Terceiro,493,5);

dmImportar.cdsTerceiros.FieldByName('RG_ESTADO').Value:= Copy(Terceiro,498,2);

Ano := Copy(Terceiro,500,4);

Mes := Copy(Terceiro,504,2);

Dia := Copy(Terceiro,506,2);

dmImportar.cdsTerceiros.FieldByName('RG_DT_EMISSAO').Value:= dia+'/'+mes+'/'+ano;

dmImportar.cdsTerceiros.FieldByName('SEXO').Value:= StrToInt(Copy(Terceiro,508,1));

dmImportar.cdsTerceiros.FieldByName('CODIGO_PAIS').Value:= Copy(Terceiro,509,4);

dmImportar.cdsTerceiros.FieldByName('CODIGO_IBGE').Value:= Copy(Terceiro,513,5);

dmImportar.cdsTerceiros.FieldByName('FILLER2').Value:= Copy(Terceiro,518,86);

dmImportar.cdsTerceiros.FieldByName('CODIGO_MUN_EST').Value:= Copy(Terceiro,604,10);

dmImportar.cdsTerceiros.Post;

lblProcessando.Caption:= 'Importando, aguarde... '+ IntToStr(dmImportar.cdsTerceiros.RecordCount);

if dmImportar.cdsTerceiros.ApplyUpdates(0) <> 0 then

dmImportar.cdsTerceiros.CancelUpdates;

end;

CloseFile(Txt);

lblProcessando.Caption:= 'Importação realizado com sucesso...';

BitBtn1.Enabled:= true;

BitBtn2.Visible := True;

BitBtn2.Kind:= bkClose;

Animate1.Visible:= true;

Animate1.Active:= False;

lblProcessando.Caption := 'Foi Importado um total de '+ IntToStr(dmImportar.cdsTerceiros.RecordCount)+' registros com sucesso';

end;

Como criar e usar algo que faça uma verificação na tabela e se no arquivo de importação constar CPF/CNPF que já exista na tabela o sistema informar que já existe e não fazer a importação desta linha, mas continua com o processo. outra coisa é verificar no arquivo texto se tem mais de um CPF/CNPJ e importar só o primeiro encontrado, ignorando e informando ao ususário os repetidos.

Lembrando que o CPF/CNPJ seria a chave primária.

Obrigado.

Chrnos · Abril 30, 2009

Quando se importa registros em massa como está tentando fazer, o ideal é que antes de dar um insert ou update você monte uma rotina que verifique se o dado já existe ou não no banco... o modo mais simples de testar é dar um select na base pelos campos chaves e ver se retorna valor... ser não retornar, põe os comandos que farão o insert... se retornar, os que fazem update, se for o caso.

Pelo que eu vejo no seu caso, talvez o melhor fosse jogar os dados do txt em variáveis, testar e depois gravar/atualizar os valores que estão nestas variáveis dentro do seu while.

[]'s

Welder · Abril 30, 2009

Quando se importa registros em massa como está tentando fazer, o ideal é que antes de dar um insert ou update você monte uma rotina que verifique se o dado já existe ou não no banco... o modo mais simples de testar é dar um select na base pelos campos chaves e ver se retorna valor... ser não retornar, põe os comandos que farão o insert... se retornar, os que fazem update, se for o caso.

Pelo que eu vejo no seu caso, talvez o melhor fosse jogar os dados do txt em variáveis, testar e depois gravar/atualizar os valores que estão nestas variáveis dentro do seu while.

[]'s

entendi a lógica. mas não sei se vou conseguir colocar na prática.

Exemplo: Faço um select na tabela pelo CNPJFPF se existir algum que já exista no arquivo eu faço um update ou ignoro, se não eu faço um insert. na prática complicou minha vida.rsrs.

Chrnos · Abril 30, 2009

É só bolar uma function que pegue o retorno de um count por exemplo... algo do tipo:

function Tform1.TestaExistenciaRegistro(cpf : string) : boolean;
begin
	Query.Close;
	Query.Sql.Clear;
	Query.Sql.Add('Select count(*) as total from tabela where cpf = ' + QuotedStr(cpf));
	Query.Open;
	if not Query.IsEmpty then
		if Query.FieldByName('total').AsInteger > 0 then
			result := true
		else
			result := false
   else result := false;
end;

E ai é só chamar isso num teste no código....

If not TestaExistenciaRegistro(cpf) then
begin
	insert...
end
else
begin
	update...
end;

[]'s

Welder · Abril 30, 2009

É só bolar uma function que pegue o retorno de um count por exemplo... algo do tipo:

function Tform1.TestaExistenciaRegistro(cpf : string) : boolean;
begin
	Query.Close;
	Query.Sql.Clear;
	Query.Sql.Add('Select count(*) as total from tabela where cpf = ' + QuotedStr(cpf));
	Query.Open;
	if not Query.IsEmpty then
		if Query.FieldByName('total').AsInteger > 0 then
			result := true
		else
			result := false
   else result := false;
end;

E ai é só chamar isso num teste no código....

If not TestaExistenciaRegistro(cpf) then
begin
	insert...
end
else
begin
	update...
end;

[]'s

Não consegui fazer o teste. Estou tentando.

unit ufrmPrincipal;

interface

uses

Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,

Dialogs, StdCtrls, Buttons, ComCtrls, FileCtrl, FMTBcd, DB, SqlExpr;

type

TfrmPrincipal = class(TForm)

btnProcessar: TBitBtn;

OpenDialog1: TOpenDialog;

Animate1: TAnimate;

BitBtn2: TBitBtn;

lblProcessando: TLabel;

Label5: TLabel;

procedure Label5Click(Sender: TObject);

procedure btnProcessarClick(Sender: TObject);

private

{ Private declarations }

public

{ Public declarations }

procedure ExtraiValoresTxt();

function TestaExistenciaRegistro(CnpjCpf : string) : boolean;

end;

var

frmPrincipal: TfrmPrincipal;

implementation

uses udmImportar, DiretoImpressora;

{$R *.dfm}

procedure TfrmPrincipal.ExtraiValoresTxt();

var

Txt: Textfile;

Terceiro: string;

Tipo, Ordem, Filler1,

Personalidade, CnpjCpf, RazaoSocial, Apelido, EnderecoTipo,

EnderecoLogradouro, Numero, Cep, Bairro, Municipio, Uf,

DataInicioAtividades, TelefoneDDD, TelefoneNumero, TelefaxDDD,

TelefaxNumero, Email, HomePage, InscMun, InscEst, Cnae, RgNumero,

RgOrgao, RgUf, RgDataEmissao, Sexo, CodigoPais, CodigoIbge, Filler2,

CodigoMunEst: string;

begin

if OpenDialog1.Execute then

begin

AssignFile(Txt,(OpenDialog1.FileName));//{ NOME do arquivo texto}

Animate1.Visible:= true;

Animate1.Active:= true;

Reset(Txt);

While not Eoln(Txt) do

begin

Readln(Txt,Terceiro);

Tipo := Copy(Terceiro,1,3);

Ordem := Copy(Terceiro,4,5);

Filler1 := Copy(Terceiro,09,2);

Personalidade := Copy(Terceiro,11,1);

CnpjCpf := Copy(Terceiro,12,14);

RazaoSocial := Copy(Terceiro,26,60);

Apelido := Copy(Terceiro,86,20);

EnderecoTipo := Copy(Terceiro,106,10);

EnderecoLogradouro := Copy(Terceiro,116,60);

Numero := Copy(Terceiro,176,10);

Cep := Copy(Terceiro,206,09);

Bairro := Copy(Terceiro,215,30);

Municipio := Copy(Terceiro,245,30);

Uf := Copy(Terceiro,275,2);

DataInicioAtividades := Copy(Terceiro,277,8);

TelefoneDDD := Copy(Terceiro,285,5);

TelefoneNumero := Copy(Terceiro,290,10);

TelefaxDDD := Copy(Terceiro,300,5);

TelefaxNumero := Copy(Terceiro,305,10);

Email := Copy(Terceiro,315,50);

HomePage := Copy(Terceiro,365,60);

InscEst := Copy(Terceiro,425,20);

InscMun := Copy(Terceiro,445,20);

Cnae := Copy(Terceiro,465,10);

RgNumero := Copy(Terceiro,475,18);

RgOrgao := Copy(Terceiro,493,5);

RgUf := Copy(Terceiro,498,2);

RgDataEmissao := Copy(Terceiro,500,8);

Sexo := Copy(Terceiro,508,1);

CodigoPais := Copy(Terceiro,509,4);

CodigoIbge := Copy(Terceiro,513,5);

Filler2 := Copy(Terceiro,518,86);

CodigoMunEst := Copy(Terceiro,604,10);

end;

CloseFile(Txt);

end;

procedure TfrmPrincipal.Label5Click(Sender: TObject);

begin

frmDiretoImpressora.Showmodal;

end;

function TfrmPrincipal.TestaExistenciaRegistro(CnpjCpf: string): boolean;

begin

dmImportar.qryTestaExiste.Close;

dmImportar.qryTestaExiste.Sql.Clear;

dmImportar.qryTestaExiste.Sql.Add('Select count(*) as total from CLIFOR where CNPJCPF = ' + QuotedStr(CnpjCpf));

dmImportar.qryTestaExiste.Open;

if not dmImportar.qryTestaExiste.IsEmpty then

if dmImportar.qryTestaExiste.FieldByName('total').AsInteger > 0 then

result := true

else

result := false

else result := false;

end;

procedure TfrmPrincipal.btnProcessarClick(Sender: TObject);

begin

ExtraiValoresTxt();

If not TestaExistenciaRegistro(CnpjCpf) then

begin

dmImportar.cdsTerceiros.Insert;

dmImportar.cdsTerceiros.FieldByName('TIPO').Value := Tipo;

dmImportar.cdsTerceiros.FieldByName('ORDEM').Value := Ordem;

dmImportar.cdsTerceiros.FieldByName('FILLER1').Value := Filler1;

dmImportar.cdsTerceiros.FieldByName('PERSONALIDADE').Value := StrToInt(Personalidade);

dmImportar.cdsTerceiros.FieldByName('CNPJCPF').Value := CnpjCpf;

dmImportar.cdsTerceiros.FieldByName('RAZAOSOCIAL').Value := RazaoSocial;