unit2.pas

数据导入导出

unit Unit2;

interface

uses
  activex,Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
  Dialogs, bsSkinCtrls, StdCtrls, DB, ADODB, DBTables;


type
  MyDBThread = class(TThread)
  private

     procedure DBexport_filmtype;
    // procedure DBexport_atorcharge;

  protected


    procedure Execute; override;


  public





  end;

implementation
 uses unit1;

procedure MyDBThread.Execute;

begin

     CoInitialize( nil );

     dbexport_filmtype;
    // DBexport_atorcharge;


     CoUnInitialize;


end;




procedure mydbthread.DBexport_filmtype;
var i:integer;

begin

    dbtrans.table1.tablename:='atorcharge';
    dbtrans.table1.EmptyTable;

    dbtrans.table1.tablename:='atorinfo';
    dbtrans.table1.EmptyTable;

    dbtrans.table1.tablename:='chargestd';
    dbtrans.table1.EmptyTable;

    dbtrans.table1.tablename:='doctor';
    dbtrans.table1.EmptyTable;

    dbtrans.table1.tablename:='filmtype';
    dbtrans.table1.EmptyTable;

    dbtrans.table1.tablename:='player';
    dbtrans.table1.EmptyTable;

    dbtrans.table1.tablename:='provider';
    dbtrans.table1.EmptyTable;

    dbtrans.table1.tablename:='atorrating';
    dbtrans.table1.EmptyTable;

    dbtrans.table1.tablename:='rent_cd';
    dbtrans.table1.EmptyTable;

    dbtrans.table1.tablename:='rttransaction';
    dbtrans.table1.EmptyTable;

//--------------ACCESS_TBCATEGORY--->>SQLSERVER_FILETYPE-------------------//



    with dbtrans.fromaccessquery_1 do
      begin
        close;
        sql.Clear;
        sql.add('select * from TbCdCategory');
        open;
        first;
        dbtrans.bsskingauge1.ProgressText:='正在导入到影片类型表';
          for i:=1 to dbtrans.fromaccessquery_1.RecordCount do
            begin
               dbtrans.bsskingauge1.maxvalue:=dbtrans.fromaccessquery_1.RecordCount;//进度条1
               dbtrans.bsskingauge1.value:=i;//进度条1
               if i=dbtrans.fromaccessquery_1.RecordCount then break;
               with dbtrans.tosqlserver do
                  begin
                    close;
                    sql.Clear;
                    sql.Add('insert filmtype values(:a,:b)');
                    dbtrans.tosqlserver.ParamByName('a').asstring:=dbtrans.fromaccessquery_1.FieldValues['name'];     //关键字
                    dbtrans.tosqlserver.ParamByName('b').asstring:=dbtrans.fromaccessquery_1.FieldValues['memo'];     //ACCESS中字段类型为"备注"
                    execsql;
                    dbtrans.fromaccessquery_1.next;

                  end;                             //FreeOnTerminate:=True;

            end;
      end;







  //----------------------------------------------------------------------------//




  with dbtrans.fromaccessquery_1 do // 从ACCESS_bFtransaction+TbAssociator---->>SQLSERVER_ATORCHARGE(会员信息)
      begin
        close;
        sql.Clear;
        sql.add('select TbFtransaction.*,TbAssociator.* from TbFtransaction,TbAssociator where TbFtransaction.AID3=TbAssociator.ID');
        open;
        first;
      end;


  with dbtrans.fromaccessquery_2 do //ACCESS_TbOperator+TbFtransaction----->>SQLSERVER_ATORCHARGE(会员信息)
      begin
        close;
        sql.Clear;
        sql.add('select TbOperator.*,TbFtransaction.* from TbOperator,TbFtransaction where TbOperator.ID=TbFtransaction.CID3 and TbFtransaction.AID3<>0');
        open;
        first;
      end;


  with dbtrans.fromaccessquery_3 do //ACCESS_TbCategory+TbFtransaction-------->>SQLSERVER_ATORCHARGE(会员信息)
      begin
        close;
        sql.Clear;
        sql.add('select TbCategory.*,TbFtransaction.* from Tbcategory,TbFtransaction where TbFtransaction.CID1=Tbcategory.ID and TbFtransaction.AID3<>0');
        open;
        first;
      end;
   dbtrans.bsskingauge1.ProgressText:='正在导入到会员表';
  for i:=1 to dbtrans.fromaccessquery_1.RecordCount do
      begin
        dbtrans.bsskingauge1.maxvalue:=dbtrans.fromaccessquery_1.RecordCount;//进度条1
        dbtrans.bsskingauge1.value:=i;//进度条1
        if i=dbtrans.fromaccessquery_1.RecordCount then break;
             with dbtrans.tosqlserver do
                  begin
                    close;
                    sql.Clear;
                    sql.Add('insert into atorcharge(会员编号,金额,对应帐户,说明,操作日期,经手人,收支分类) values(:a,:b,:c,:d,:e,:f,:g)');

                    dbtrans.tosqlserver.ParamByName('a').asstring:=dbtrans.fromaccessquery_1.FieldValues['code'];  //关键字
                    dbtrans.tosqlserver.ParamByName('b').asinteger:=dbtrans.fromaccessquery_1.FieldValues['sum2'];
                    dbtrans.tosqlserver.ParamByName('c').asstring:=dbtrans.fromaccessquery_1.FieldValues['aid2'];
                    dbtrans.tosqlserver.ParamByName('d').asstring:=dbtrans.fromaccessquery_1.FieldValues['memo'];
                    dbtrans.tosqlserver.ParamByName('e').AsDatetime:=dbtrans.fromaccessquery_1.FieldValues['day'];
                    dbtrans.tosqlserver.ParamByName('f').asstring:=dbtrans.fromaccessquery_2.FieldValues['name'];
                    dbtrans.tosqlserver.ParamByName('g').asstring:=dbtrans.fromaccessquery_3.FieldValues['name'];
                    execsql;
                    dbtrans.fromaccessquery_1.next;
                    dbtrans.fromaccessquery_2.next;
                    dbtrans.fromaccessquery_3.next;
                  end;

       end;


 //-------------------------------------------------------------------------//


    with dbtrans.fromaccessquery_1 do
      begin
        close;
        sql.Clear;
        sql.add('select * from TbPlayer');
        open;
        first;
        dbtrans.bsskingauge1.ProgressText:='正在导入到演员表';
     end;
          for i:=1 to dbtrans.fromaccessquery_1.RecordCount do
            begin
               dbtrans.bsskingauge1.maxvalue:=dbtrans.fromaccessquery_1.RecordCount;//进度条1
               dbtrans.bsskingauge1.value:=i;//进度条1
               if i=dbtrans.fromaccessquery_1.RecordCount then break;
               with dbtrans.tosqlserver do
                  begin
                    close;
                    sql.Clear;
                    sql.Add('insert into doctor(导演,首拼,说明) values(:a,:b,:c)');
                    dbtrans.tosqlserver.ParamByName('a').asstring:=dbtrans.fromaccessquery_1.FieldValues['name'];   //关键字
                    dbtrans.tosqlserver.ParamByName('b').asstring:=dbtrans.fromaccessquery_1.FieldValues['spell'];  //不可能为空
                    dbtrans.tosqlserver.ParamByName('c').asstring:=dbtrans.fromaccessquery_1.FieldValues['memo'];   //备注类型
                    execsql;
                    dbtrans.fromaccessquery_1.next;

                  end;                             //FreeOnTerminate:=True;


             end;




        with dbtrans.fromaccessquery_1 do
      begin
        close;
        sql.Clear;
        sql.add('select * from TbPlayer');
        open;
        first;
        dbtrans.bsskingauge1.ProgressText:='正在导入到导演表';
     end;
          for i:=1 to dbtrans.fromaccessquery_1.RecordCount do
            begin
               dbtrans.bsskingauge1.maxvalue:=dbtrans.fromaccessquery_1.RecordCount;//进度条1
               dbtrans.bsskingauge1.value:=i;//进度条1
               if i=dbtrans.fromaccessquery_1.RecordCount then break;
               with dbtrans.tosqlserver do
                  begin
                    close;
                    sql.Clear;
                    sql.Add('insert into player(演员,首拼,说明) values(:a,:b,:c)');
                    dbtrans.tosqlserver.ParamByName('a').asstring:=dbtrans.fromaccessquery_1.FieldValues['name'];
                    dbtrans.tosqlserver.ParamByName('b').asstring:=dbtrans.fromaccessquery_1.FieldValues['spell'];
                    dbtrans.tosqlserver.ParamByName('c').asstring:=dbtrans.fromaccessquery_1.FieldValues['memo'];
                    execsql;
                    dbtrans.fromaccessquery_1.next;

                  end;                             //FreeOnTerminate:=True;


             end;





   with dbtrans.fromaccessquery_1 do
      begin
        close;
        sql.Clear;
        sql.add('select * from Tbcompany');
        open;
        first;
        dbtrans.bsskingauge1.ProgressText:='正在导入到进货表';
     end;
          for i:=1 to dbtrans.fromaccessquery_1.RecordCount do
            begin
               dbtrans.bsskingauge1.maxvalue:=dbtrans.fromaccessquery_1.RecordCount;//进度条1
               dbtrans.bsskingauge1.value:=i;//进度条1
               if i=dbtrans.fromaccessquery_1.RecordCount then break;
               with dbtrans.tosqlserver do
                  begin
                    close;
                    sql.Clear;
                    sql.Add('insert into provider(供应商,电话号码,首拼,地址,说明) values(:a,:b,:c,:d,:e)');

                        dbtrans.tosqlserver.ParamByName('a').asstring:=dbtrans.fromaccessquery_1.FieldValues['name'];

                        if dbtrans.fromaccessquery_1.FieldValues['telephone']=null then
                           dbtrans.tosqlserver.ParamByName('b').asstring:='/'
                        else
                        dbtrans.tosqlserver.ParamByName('b').asstring:=dbtrans.fromaccessquery_1.FieldValues['telephone'];


                        dbtrans.tosqlserver.ParamByName('c').asstring:='/';

                        if  dbtrans.fromaccessquery_1.FieldValues['address']=null then
                            dbtrans.tosqlserver.ParamByName('c').asstring:='/'
                        else
                            dbtrans.tosqlserver.ParamByName('d').asstring:=dbtrans.fromaccessquery_1.FieldValues['address'];
                        
                        dbtrans.tosqlserver.ParamByName('e').asstring:=dbtrans.fromaccessquery_1.FieldValues['memo'];
                        execsql;
                        dbtrans.fromaccessquery_1.next;

                           end;                             //FreeOnTerminate:=True;


             end;
















          




   
  with dbtrans.fromaccessquery_1 do // 从ACCESS_tbassociator+batortype---->>SQLSERVER_atorinfo(会员信息)
      begin
        close;
        sql.Clear;
        sql.add('select tbassociator.*,tbatortype.* from tbassociator,tbatortype where tbassociator.aid=tbatortype.id');
        open;
        first;
      end;


  with dbtrans.fromaccessquery_2 do //ACCESS_tbassociator.AID+tbatortype.name----->>SQLSERVER_atorinfo(会员信息)
      begin
        close;
        sql.Clear;
        sql.add('select tbassociator.AID,tbatortype.name from tbassociator,tbatortype where tbassociator.aid=tbatortype.id');
        open;
        first;
      end;

    dbtrans.bsskingauge1.ProgressText:='正在导入到会员信息表';


   for i:=1 to dbtrans.fromaccessquery_1.RecordCount do
      begin
        dbtrans.bsskingauge1.maxvalue:=dbtrans.fromaccessquery_1.RecordCount;//进度条1
        dbtrans.bsskingauge1.value:=i;//进度条1
        if i=dbtrans.fromaccessquery_1.RecordCount then break;
             with dbtrans.tosqlserver do
                  begin
                    close;