关闭 x
IT技术网
    技 采 号
    ITJS.cn - 技术改变世界
    • 实用工具
    • 菜鸟教程
    IT采购网 中国存储网 科技号 CIO智库

    IT技术网

    IT采购网
    • 首页
    • 行业资讯
    • 系统运维
      • 操作系统
        • Windows
        • Linux
        • Mac OS
      • 数据库
        • MySQL
        • Oracle
        • SQL Server
      • 网站建设
    • 人工智能
    • 半导体芯片
    • 笔记本电脑
    • 智能手机
    • 智能汽车
    • 编程语言
    IT技术网 - ITJS.CN
    首页 » SQL语言 »批量执行SQL语句的示例

    批量执行SQL语句的示例

    2010-09-25 14:59:00 出处:ITJS
    分享

    在项目中,经常会遇到需要批量执行SQL语句的情况,下面将为您示例说明批量执行SQL语句的方法,希望对教您学习SQL语句有所帮助。

    当然,我们更想在程序中去执行这些语句,而不是再去打开查询分析器。

    当大家要在程序中批量执行SQL语句时,需要明白AdoConnection,或AdoQuery(假设我们使用ADO组件)可以执行的语句有什么要求。

    1、在查询分析器里,一条SQL语句,我们可以直接写成

    Select * from aTable where ID=123

    或者

    Select * from aTable where ID=123;

    这两条语句结果相同。不同的地方只是第二条多了一个“;”,用来表示一条语句结束。

    2、在查询分析器里,多条SQL语句的写法

    insert into aTable(Field1,Field2) values( '值一','值二')

    go

    这里的 go 表示一个批处理

    根据以上两点,我们可以看出,大家要在程序中批量执行SQL语句,需要判断一个完整的操作包含几条语句,这些语句是不是可以单独执行等。

    下面是一个示例程序(程序中不涉及到Select操作)

    unit BatchSQL;   {      批量执行SQL脚本      E-main: goldli@163.com   }   interface   uses     SysUtils,ADODB,Classes;    type      TOnException = procedure(const E: Exception) of object;      TOnSQLExecute = procedure(const strSQL: string;const RowsAffected:Integer) of object;    type     {完整的SQL语句}     TSQLString = class     private       FBuffer:string;       FSQL:TStrings;       FChanged:Boolean;       function GetSQL:string;     public       constructor Create;       destructor  Destroy;override;       procedure   Append(const StrSQL:string);       property    SQL:string read GetSQL;     end;      TBatchSQL = class     private       FConnection:TADOConnection;       FSQLList:TList;       FOnException:TOnException;       FOnSQLExecute:TOnSQLExecute;     public       constructor Create(const AConnection:TADOConnection);       destructor  Destroy;override;       property  Connection:TADOConnection write FConnection;       procedure LoadFromFile(const FileName:string);       procedure Execute;       property  OnException:TOnException write FOnException;       property  OnSQLExecute:TOnSQLExecute write FOnSQLExecute;     end;    implementation    { TSQLString }    procedure TSQLString.Append(const StrSQL: string);   begin     FSQL.Append(StrSQL);     FChanged:=True;   end;    constructor TSQLString.Create;   begin     FSQL:=TStringList.Create;   end;    destructor TSQLString.Destroy;   begin     FSQL.Free;     inherited;   end;    function TSQLString.GetSQL: string;   begin     if FChanged then     begin       FBuffer:=FSQL.Text;       FChanged:=False;     end;     Result:=FBuffer;   end;    { TBatchSQL }    constructor TBatchSQL.Create(const AConnection: TADOConnection);   begin     if Assigned(AConnection) then       FConnection:=AConnection;     FSQLList:=TList.Create;   end;    destructor TBatchSQL.Destroy;   var     i:Integer;   begin     FConnection:=nil;     for i:= FSQLList.Count -1 downto 0 do       TSQLString(FSQLList.Items[i]).Free;     FSQLList.Free;     inherited;   end;    procedure TBatchSQL.Execute;   var     i:Integer;     Qry:TADOQuery;     SQLString:TSQLString;   begin     Assert(Assigned(FConnection),'数据库连接不能为nil.');     Assert(FSQLList.count > 0,'请先加载SQL文件.');     FConnection.LoginPrompt:=False;     FConnection.Connected:=True;     Qry:=TADOQuery.Create(nil);     with Qry do     begin       Connection:=FConnection;       Prepared:=True;       for i:=0 to FSQLList.Count -1 do       begin         SQLString:=TSQLString(FSQLList.Items[i]);         SQL.Clear;         SQL.Add(SQLString.SQL);         try           ExecSQL;           if Assigned(FOnSQLExecute) then             FOnSQLExecute(SQLString.SQL,RowsAffected);         except           on E:Exception do             if Assigned(FOnException) then               FOnException(E)             else               raise Exception.Create('SQL语句出错:' + sLineBreak + SQLString.SQL);         end;       end;       Free;     end;    end;    procedure TBatchSQL.LoadFromFile(const FileName: string);   var     SqlStr,Tmp:string;     F:TextFile;     SQLString:TSQLString;   begin     Assert(FileExists(FileName),'SQL文件不存在,不能加载.');      AssignFile(F,FileName);     Reset(f);     Repeat       Readln(F,Tmp);       if Tmp='GO' then       begin         SQLString:=TSQLString.Create;         SQLString.Append(SqlStr);         FSQLList.Add(SQLString);         SqlStr:='';         Tmp:='';       end;       SqlStrSqlStr:=SqlStr + Tmp;     Until eof(F);     Closefile(F);   end;    end. 

    上一篇返回首页 下一篇

    声明: 此文观点不代表本站立场;转载务必保留本文链接;版权疑问请联系我们。

    别人在看

    正版 Windows 11产品密钥怎么查找/查看?

    还有3个月,微软将停止 Windows 10 的更新

    Windows 10 终止支持后,企业为何要立即升级?

    Windows 10 将于 2025年10 月终止技术支持,建议迁移到 Windows 11

    Windows 12 发布推迟,微软正全力筹备Windows 11 25H2更新

    Linux 退出 mail的命令是什么

    Linux 提醒 No space left on device,但我的空间看起来还有不少空余呢

    hiberfil.sys文件可以删除吗?了解该文件并手把手教你删除C盘的hiberfil.sys文件

    Window 10和 Windows 11哪个好?答案是:看你自己的需求

    盗版软件成公司里的“隐形炸弹”?老板们的“法务噩梦” 有救了!

    IT头条

    公安部:我国在售汽车搭载的“智驾”系统都不具备“自动驾驶”功能

    02:03

    液冷服务器概念股走强,博汇、润泽等液冷概念股票大涨

    01:17

    亚太地区的 AI 驱动型医疗保健:2025 年及以后的下一步是什么?

    16:30

    智能手机市场风云:iPhone领跑销量榜,华为缺席引争议

    15:43

    大数据算法和“老师傅”经验叠加 智慧化收储粮食尽显“科技范”

    15:17

    技术热点

    商业智能成CIO优先关注点 技术落地方显成效(1)

    用linux安装MySQL时产生问题破解

    JAVA中关于Map的九大问题

    windows 7旗舰版无法使用远程登录如何开启telnet服务

    Android View 事件分发机制详解

    MySQL用户变量的用法

      友情链接:
    • IT采购网
    • 科技号
    • 中国存储网
    • 存储网
    • 半导体联盟
    • 医疗软件网
    • 软件中国
    • ITbrand
    • 采购中国
    • CIO智库
    • 考研题库
    • 法务网
    • AI工具网
    • 电子芯片网
    • 安全库
    • 隐私保护
    • 版权申明
    • 联系我们
    IT技术网 版权所有 © 2020-2025,京ICP备14047533号-20,Power by OK设计网

    在上方输入关键词后,回车键 开始搜索。Esc键 取消该搜索窗口。