zoukankan      html  css  js  c++  java

  • 初学Service Broker

    在软件开发领域，新的开发工具经常引入新的、可靠的成熟平台。SQL Server Service Broker就是这种技术，Service Broker带来了SQL Server 数据库平台的异步消息技术。

    Enterprise Integration Patterns（由Gregor Hohpe和Bobby Wolf编著）是一本关于异步消息机制的最好的书之一。通过解释异步消息，该书将不同的消息设计想法分为不同的软件设计模式。根据这本书，异步消息认为是 application-to-application之间的通信机制，允许有不同的交易量和处理能力的应用程序（application）之间可靠地交 换数据。

    通过使用Service Broker、一些新的T-SQL脚本、一些新的概念、和现有的SQL Server知识，一个T-SQL开发人员可以充分利用SQL Server 2005的异步消息功能。使用Service Broker开发设计模式，你可以选择合适的方案实现SQL Server 2005异步消息的需要。

    这篇文章展示如何使用Service Broker来实现Enterprise Integration Patterns书中的通用软件模式。因为详细的enterprise integration patterns和异步消息的描述超出了本篇文章的范围，这里重点介绍了Pub/Sub异步消息模式的想法。

    ms官方系统教程:http://technet.microsoft.com/zh-cn/sysinternals/ms166104.aspx

    EntLib.com Forum:http://www.cnblogs.com/entlibforum/category/135628.html

    SSB 初探: http://www.cnblogs.com/sherrys/archive/2006/12/28/605991.html

    源文档 <http://www.cnblogs.com/mxy1028/archive/2009/03/22/1419275.html>

    1.Server Broker 开发

     1

    /*********************************************************/
/*                    Server Broker 开发Demo              */
/*                     2012-07-24                                   */
/*                        Leo                                            */
/*********************************************************/

--1.创建要使用的数据库
Create database HelloWorldDB
Go
Use HelloWorldDB
--2.创建要使用的两种消息类型是字符串而不是XML,因此无需进行验证
Create Message Type [HelloWorldRequest] Validation = NONe
Create Message Type [HelloWorldResponse] Validation = NONe
/*(如果消息类型是XML,而不是字符串,需要验证,如下:
    Create Message Type [HelloWorldRequest] Validation = WELL_FORMED_XML
    Create Message Type [HelloWorldResponse] Validation = WELL_FORMED_XML
)*/
--3.创建消息规范--约定
Create Contract [HelloWorldContract](
    [HelloWorldRequest] Sent By initiator,
    [HelloWorldResponse] Sent By target
)
--4.创建对话在期间通信的两个队列.
Create Queue [HelloWorldRequestTragetQueue]
Create Queue [HelloWorldResponseInitiatorQueue]

--5.创建命名对话端点的服务,服务会将会话端点连接到队列
Create Service [HelloWorldRequestService] ON  Queue [HelloWorldRequestTragetQueue](
    [HelloWorldContract]
)
Create Service [HelloWorldResponseService] ON Queue [HelloWorldResponseInitiatorQueue](
    [HelloWorldContract]
)

/*6.现在已经设置了元数据,可以发送消息了.
请注意,由于初始化程序和目标服务位于同一SQL Server 实例中,
因此消息将直接转到目标队列而不会通过传送队列传送,
由于SQL Borker 内置在数据库,因此可以进行此项性能优化.
*/


--7.  消息发送
Use HelloWorldDB
Go
Set NoCount On
Declare @conversationHandle uniqueidentifier
Begin Transaction
--开始Hello World 服务的对话
Begin Dialog @conversationHandle
From Service [HelloWorldResponseService]
To Service 'HelloWorldRequestService'
On Contract [HelloWorldContract]
With ENCRYPTION = OFF, LIFETIME = 600; 
--发送消息
SEND On Conversation @conversationHandle
MESSAGE TYPE [HelloWorldRequest](N'HelloWorld Server Broker.')
Commit

--8.让我们查看目标队列以确保成功发送了信息.
Use HelloWorldDB
Go
--检查目标队列以确认消息已送达
Select * from [HelloWorldRequestTragetQueue]
Go
--将消息主体转换为字符串，以便我们查看其中包含的内容
Select cast(message_body as nvarchar(max)) from [HelloWorldRequestTragetQueue]
Go

--9.现在可以从目标队列中接收消息并将响应发送回初始化程序。
--使用Receive命令可从队列接收消息
--声明变量以存储接收到的数据
SET NOCOUNT ON
DECLARE @conversationHandle uniqueidentifier
Declare @message_body nvarchar(Max)
Declare @message_type_name sysname;
--Service Broker 命令总是位于事务中
Begin transaction;
--Receive 命令的格式类似于一个选择列表。首先列出要获取的列，、
--然后指定要从中获取消息的队列
Receive top(1) --只接收一条消息，因此我们可以直接保存到变量中。
@message_type_name = message_type_name,
--接收的消息类型
@conversationHandle = conversation_handle,
--对话的标识符
--我们通过下列语句接收该消息
@message_body = message_body
--作为varbinary(Max)blob的消息内容
From [HelloWorldRequestTragetQueue]
Print @message_body
--如果这是一条hello world 消息，则用相应的问候回答
If @message_type_name = N'HelloWorldRequest'
Begin
Send on Conversation @conversationHandle
--使用下列消息接收语句的相同会话
MESSAGE TYPE [HelloWorldResponse] (N'Hello From ' @@servername)
--这是我们希望从初始化程序接收的唯一消息，因此现在可以安全地结束对话
End CONVERSATION @conversationHandle
End
--提交事务
--如果此时我们回滚，所有内容将退回到我们开始时的状态-消息会返回到队列，并且没有发送响应
Commit
Go
-- 确认我们从队列中删除了消息
select cast(message_body as nvarchar(MAX)) from [HelloWorldRequestTragetQueue]
go

--响应已在对话中发送回初始化程序队列，现在检查响应是否成功到达：
Use HelloWorldDB
go
select cast(message_body as nvarchar(MAX)) from [HelloWorldResponseInitiatorQueue]
go

--... 最后接收并显示响应消息：

RECEIVE
cast(message_body as nvarchar(MAX))
FROM [HelloWorldResponseInitiatorQueue]

    2.SSB 表结构

    IntefaceType int
    Pkid1 int
    Pkid2 varchar
    Pkid3 varchar
    Companyid int
    daytime datetime
    IntfaceFlag int
    1.InterfaceData : 接口待发送数据

    1) IntefaceType : 接口类型--数据字典 (数据字典的对应值)

    2)Pkid1,与Pkid2,Pkid3为程序发送消息时传递过来的参数值,(Pkid2,Pkid3与数据字典的关系,它是数据字典主建,还是读取组织数据的主键)

    3)Pkid2,Pkid3数据类型

    4)消息发送存储过程接收参数 : IntefaceType , Pkid1 , Pkid2 , Pkid3 , Companyid

    5)执行消息发送成功时,更改IntfaceFlag 状态值(由0改为1)

    2.InterfaceMonitor : 接口监控

    1) 统计当日消息的发送和接收,记录消息的正常发送\接收记录,和异常接收的处理记录

    Daytime datetime
    InterfaceType int
    ReceiveCount int
    SendCount int
    ErrorCount int
    Remark varchar

    3.InterfaceReceiveXml : 接收临时表

    1) 接收消息存储执行时,解析消息数据xml类型,将xml消息数据解析成单条数据插入到消息接收临时表中

    2)没有接收消息需要用XML类型字段

    XMLID int
    InterfaceType int
    Daytime datetime
    Companyid int
    DealFlag int
    Remark varchar

    4.InterfaceError : 接口错误信息

    1) 程序从消息接收临时表里读取,并验证消息的数据,判断是否正确,如果出现异常,则把异常信息记录到InterfaceError 表中.

    Logid int
    daytime datetime
    InterfaceType int
    ErrorType int
    Info varchar

    SQL Server中的Transaction、error check、Lock、Isolation level和save point

    SQL Server中的Transaction、error check、Lock、Isolation level和save point

    2010-10-23 23:50

    一.Transaction及错误检查

    1.SQL Server 中最重要的知识点莫过于事务，比如很多OLTP（联机事务处理）应用程序。什么是事务?事务就是一系列SQL语句的集合。事务包括隐性事务（例如 Insert，Update等语句）和显性事务（用Begin Tran语句显式指明的事务）。事务中通常需要进行错误检查，用@@error来进行检查，比如：

    Begin Tran

       Update A set id =5 where id=1

       If @@error<>0

       rollback Tran

       Update A set id =5 where id=2

       If @@error<>0

    rollback Tran

    Commit Tran

    二.Lock (锁)

    1.按锁的粒度分，锁可以分成如下几类：

    Key Lock(键锁)--->Row Lock(行级锁)--->Page Lock(页级锁)--->Extent Lock(扩展盘曲锁)--->Table Lock(表锁)--->Database Lock(数据库锁)

    2.按锁的模式分，锁可以分为如下几类：

    holdlock(共享锁)，xlock(排它锁)，Updlock(更新锁)，Schlock(架构锁)，Intent lock(意向锁)等等。如果要查看锁的类型，使用系统存储过程sys_lock来查看。

    三.Isolation level (隔离级别)

    1.事务有4中隔离级别，分别为：

    1.read uncommitted(未提交读) --- 读未提交，可以读取到内存中已经修改但是没有保存到硬盘上的信息，即允许数据脏读。

    2.read committed(提交读) --- 读提交，只能读取到已经提交到硬盘的信息，如果信息在内存中修改了，但是还没有提交到硬盘，即没有commit tran，则另一个事务什么也读取不到，被另一事物阻塞在此。当修改数据的事务一旦commit tran，则读取数据的事务立即运行，修改后的数据被读取到。

    3.repeatable read(重复读) --- 当事务A设置隔离级别为repeatable read在对数据进行读取，此时，事务B来修改数据，由于repeatable read隔离级别对操作的实体(行或者表)设置了更新锁，所以此时事务B不能对数据进行更新，但是事务B可以insert新数据，因为 repeatable read隔离级别对操作的实体(行或者表)没有设置排它锁，所以事务A可以读取到幻象。

    4.serializable(串行读) --- 串行化，即事务一个接一个地进行操作，包括对操作实体的update，insert，select等等。

    2.实际上隔离级别和锁的关系是密不可分的，隔离级别的实现本质上是对锁来进行操作，由于我们在操作一个实体对象的时候不能准确地判断到底应该上什么具体的锁 ，所以鉴于此，SQL server数据库为我们开辟了一个简单的途径，即使用隔离级别。实体的隔离级别越高，说明实体上锁的数量越多，种类越复杂；实体的隔离级别越高，并行化的几率越低，串行化的几率越高。

    四.Save Point(保存点)

    1.保存点的出现，是为了在事务恢复时更加地迅速和容易，因为不用把所有的操作都恢复，而是只用恢复到保存点即可，关于如何恢复以及更具体的知识，会在事务的恢复博客中详述。举个简单的例子：

    Begin Tran

       Update A set id =4 where id=1

       Save tran t1

       Update A set id =3 where id=2

       If @@error<>0

       rollback t1

       Update A set id=5 where id =3

    Commit Tran

    源文档 <http://hi.baidu.com/programmerl/blog/item/7807daedc9e3bade2f2e217b.html>

    SQL语句大全

    创建数据库

    创建之前判断该数据库是否存在

    if exists (select * from sysdatabases where name='databaseName')

    drop database databaseName

    go

    Create DATABASE database-name

    删除数据库

    drop database dbname

    备份sql server

    --- 创建备份数据的 device

    USE master

    EXEC sp_addumpdevice 'disk', 'testBack', 'c:\mssql7backup\MyNwind_1.dat'

    --- 开始备份

    BACKUP DATABASE pubs TO testBack

    创建新表

    create table tabname(col1 type1 [not null] [primary key],col2 type2 [not null],..)

    根据已有的表创建新表：

    A：go

    use 原数据库名

    go

    select * into 目的数据库名.dbo.目的表名 from 原表名(使用旧表创建新表)

    B：create table tab_new as select col1,col2… from tab_old definition only

    创建序列

    create sequence SIMON_SEQUENCE

    minvalue 1 -- 最小值

    maxvalue 999999999999999999999999999最大值

    start with 1开始值

    increment by 1 每次加几

    cache 20;

    删除新表

    drop table tabname

    增加一个列

    Alter table tabname add column col type

    注：列增加后将不能删除。DB2中列加上后数据类型也不能改变，唯一能改变的是增加varchar类型的长度。

    添加主键

    Alter table tabname add primary key(col)

    说明：删除主键：Alter table tabname drop primary key(col)

    创建索引

    create [unique] index idxname on tabname(col…。)

    删除索引：drop index idxname on tabname

    注：索引是不可更改的，想更改必须删除重新建。

    创建视图

    create view viewname as select statement

    删除视图：drop view viewname

    几个简单的基本的sql语句

    选择：select * from table1 where 范围

    插入：insert into table1(field1,field2) values(value1,value2)

    删除：delete from table1 where 范围

    更新：update table1 set field1=value1 where 范围

    查找：select * from table1 where field1 like ’%value1%’（所有包含‘value1’这个模式的字符串）---like的语法很精妙，查资料！

    排序：select * from table1 order by field1,field2 [desc]

    分组：select * from table1 group by field1ORDER BY count(ShopId) LIMIT 20(兼并排序分页)

    总数：select count(*) as totalcount from table1

    求和：select sum(field1) as sumvalue from table1

    平均：select avg(field1) as avgvalue from table1

    最大：select max(field1) as maxvalue from table1

    最小：select min(field1) as minvalue from table1[separator]

    查询去除重复值：select distinct * from table1

    几个高级查询运算词

    A：UNION 运算符

    UNION 运算符通过组合其他两个结果表（例如TABLE1 和TABLE2）并消去表中任何重复行而派生出一个结果表。当 ALL 随UNION 一起使用时（即UNION ALL），不消除重复行。两种情况下，派生表的每一行不是来自TABLE1 就是来自TABLE2。

    B： EXCEPT 运算符

    EXCEPT 运算符通过包括所有在TABLE1 中但不在TABLE2 中的行并消除所有重复行而派生出一个结果表。当ALL 随EXCEPT 一起使用时(EXCEPT ALL)，不消除重复行。

    C：INTERSECT 运算符

    INTERSECT 运算符通过只包括TABLE1 和TABLE2 中都有的行并消除所有重复行而派生出一个结果表。当ALL 随INTERSECT 一起使用时(INTERSECT ALL)，不消除重复行。

    注：使用运算词的几个查询结果行必须是一致的。

    使用外连接

    A、left outer join：

    左外连接（左连接）：结果集既包括连接表的匹配行，也包括左连接表的所有行。

    SQL: select a.a, a.b, a.c, b.c, b.d, b.f from a LEFT OUT JOIN b ON a.a = b.c

    B：right outer join:

    右外连接(右连接)：结果集既包括连接表的匹配连接行，也包括右连接表的所有行。

    C：full outer join：

    全外连接：不仅包括符号连接表的匹配行，还包括两个连接表中的所有记录。

    编辑本段判断对象是否存在

    判断数据库是否存在

    if exists (select * from sys.databases where name = '数据库名')

    drop database [数据库名]

    判断表是否存在

    if not exists (select * from sysobjects where [name] = '表名' and xtype='U')

    begin

    --这里创建表

    end

    判断存储过程是否存在

    if exists (select * from sysobjects where id = object_id(N'[存储过程名]') and OBJECTPROPERTY(id, N'IsProcedure') = 1)

    drop procedure [存储过程名]

    判断临时表是否存在

    if object_id('tempdb..#临时表名') is not null

    drop table #临时表名

    判断视图是否存在

    --SQL Server 2000

    IF EXISTS (SELECT * FROM sysviews WHERE object_id = '[dbo].[视图名]'

    --SQL Server 2005

    IF EXISTS (SELECT * FROM sys.views WHERE object_id = '[dbo].[视图名]'

    判断函数是否存在

    if exists (select * from dbo.sysobjects where id = object_id(N'[dbo].[函数名]') and xtype in (N'FN', N'IF', N'TF'))

    drop function [dbo].[函数名]

    获取用户创建的对象信息

    SELECT [name],[id],crdate FROM sysobjects where xtype='U'

    /*

    xtype 的表示参数类型，通常包括如下这些 C = CHECK 约束 D = 默认值或DEFAULT 约束 F = FOREIGN KEY 约束 L = 日志 FN = 标量函数 IF = 内嵌表函数 P = 存储过程 PK = PRIMARY KEY 约束（类型是K） RF = 复制筛选存储过程 S = 系统表 TF = 表函数 TR = 触发器 U = 用户表 UQ = UNIQUE 约束（类型是K） V = 视图 X = 扩展存储过程 */

    判断列是否存在

    if exists(select * from syscolumns where id=object_id('表名') and name='列名')

    alter table 表名drop column 列名

    判断列是否自增列

    if columnproperty(object_id('table'),'col','IsIdentity')=1

    print '自增列'

    else

    print '不是自增列'

    SELECT * FROM sys.columns WHERE object_id=OBJECT_ID('表名')

    AND is_identity=1

    判断表中是否存在索引

    if exists(select * from sysindexes where id=object_id('表名') and name='索引名')

    print '存在'

    else

    print '不存在

    查看数据库中对象

    SELECT * FROM sys.sysobjects WHERE name='对象名'

    编辑本段提升

    复制表

    (只复制结构，源表名：a 新表名：b) (Access可用)

    法一：select * into b from a where 1<>1

    法二：select top 0 * into b from a

    拷贝表

    (拷贝数据,源表名：a 目标表名：b) (Access可用)

    insert into b(a, b, c) select d,e,f from a;

    跨数据库之间表的拷贝

    (具体数据使用绝对路径) (Access可用)

    insert into b(a, b, c) select d,e,f from a in ‘具体数据库’ where 条件

    例子：。.from b in '"&Server.MapPath("."&"\data.mdb" &"' where..

    子查询

    (表名1：a 表名2：b)

    select a,b,c from a where a IN (select d from b 或者： select a,b,c from a where a IN (1,2,3)

    显示文章、提交人和最后回复时间

    select a.title,a.username,b.adddate from table a,(select max(adddate) adddate from table where table.title=a.title) b

    外连接查询

    (表名1：a 表名2：b)

    select a.a, a.b, a.c, b.c, b.d, b.f from a LEFT OUT JOIN b ON a.a = b.c

    在线视图查询

    (表名1：a

    select * from (Select a,b,c FROM a) T where t.a > 1;

    between的用法

    between限制查询数据范围时包括了边界值，not between不包括

    select * from table1 where time between time1 and time2

    select a,b,c, from table1 where a not between 数值1 and 数值2

    in 的使用方法

    select * from table1 where a [not] in (‘值1’，’值2’,’值4’，’值6’)

    删除主表中已经在副表中没有的信息

    两张关联表delete from table1 where not exists ( select * from table2 where table1.field1=table2.field1

    四表联查问题

    select * from a left inner join b on a.a=b.b right inner join c on a.a=c.c inner join d on a.a=d.d where .....

    日程安排提前五分钟提醒

    SQL: select * from 日程安排 where datediff('minute',f开始时间，getdate())>5

    一条sql 语句搞定数据库分页

    select top 10 b.* from (select top 20 主键字段,排序字段 from 表名 order by 排序字段 desc) a,表名 b where b.主键字段= a.主键字段 order by a.排序字段

    前10条记录

    select top 10 * from table1 where 范围

    选择排名

    选择在每一组b值相同的数据中对应的a最大的记录的所有信息(类似这样的用法可以用于论坛每月排行榜，每月热销产品分析,按科目成绩排名，等等。)

    select a,b,c from tablename ta where a=(select max(a) from tablename tb where tb.b=ta.b)

    派生结果表

    包括所有在TableA 中但不在TableB和TableC 中的行并消除所有重复行而派生出一个结果表

    (select a from tableA except (select a from tableB) except (select a from tableC)

    随机取出10条数据

    select top 10 * from tablename order by newid()

    随机选择记录

    select newid()

    删除重复记录

    Delete from tablename where id not in (select max(id) from tablename group by col1,col2,...)

    列出数据库里所有的表名

    select name from sysobjects where type='U'

    列出表里的所有的

    select name from syscolumns where id=object_id('TableName')

    列示排列

    列示type、vender、pcs字段，以type字段排列，case可以方便地实现多重选择，类似select 中的case。

    select type,sum(case vender when 'A' then pcs else 0 end),sum(case vender when 'C' then pcs else 0 end),sum(case vender when 'B' then pcs else 0 end) FROM tablename group by type

    显示结果：

    type vender pcs

    电脑A 1

    电脑A 1

    光盘 B 2

    光盘A 2

    手机B 3

    手机C 3

    初始化表table1

    TRUNCATE TABLE table1

    选择从10到15的记录

    select top 5 * from (select top 5 * from (select top 15 * from table order by id asc) table_别名 order by id desc) table_2 order by id

    数据类型转换

    declare @numid int

    declare @id varchar(50)

    set @numid=2005

    set @id=convert(varchar,@numid)

    通过上述语句完成数据类型Int转换成varchar，其他转换类似，可参看convert函数

    编辑本段技巧

    1=1，1=2的使用

    在SQL语句组合时用的较多

    “where 1=1”是表示选择全部 “where 1=2”全部不选，

    如：

    if @strWhere !='

    begin

    set @strSQL = 'select count(*) as Total from [' + @tblName + '] where ' + @strWhere

    end

    else

    begin

    set @strSQL = 'select count(*) as Total from [' + @tblName + ']'

    end

    我们可以直接写成

    set @strSQL = 'select count(*) as Total from [' + @tblName + '] where 1=1 and '+ @strWhere

    收缩数据库

    --重建索引

    DBCC REINDEX

    DBCC INDEXDEFRAG

    --收缩数据和日志

    DBCC SHRINKDB

    DBCC SHRINKFILE

    压缩数据库

    dbcc shrinkdatabase(dbname)

    转移数据库给新用户以已存在用户权限

    exec sp_change_users_login 'update_one','newname','oldname'

    go

    检查备份集

    RESTORE VERIFYONLY from disk='E:\dvbbs.bak'

    修复数据库

    Alter DATABASE [dvbbs] SET SINGLE_USER

    GO

    DBCC CHECKDB('dvbbs',repair_allow_data_loss) WITH TABLOCK

    GO

    Alter DATABASE [dvbbs] SET MULTI_USER

    GO

    日志清除

    SET NOCOUNT ON

    DECLARE @LogicalFileName sysname,

    @MaxMinutes INT,

    @NewSize INT

    USE tablename -- 要操作的数据库名

    Select @LogicalFileName = 'tablename_log', -- 日志文件名

    @MaxMinutes = 10, -- Limit on time allowed to wrap log.

    @NewSize = 1 -- 你想设定的日志文件的大小(M)

    -- Setup / initialize

    DECLARE @OriginalSize int

    Select @OriginalSize = size

    FROM sysfiles

    Where name = @LogicalFileName

    Select 'Original Size of ' + db_name() + ' LOG is ' +

    CONVERT(VARCHAR(30),@OriginalSize) + ' 8K pages or ' +

    CONVERT(VARCHAR(30),(@OriginalSize*8/1024)) + 'MB'

    FROM sysfiles

    Where name = @LogicalFileName

    Create TABLE DummyTrans

    (DummyColumn char (8000) not null)

    DECLARE @Counter INT,

    @StartTime DATETIME,

    @TruncLog VARCHAR(255)

    Select @StartTime = GETDATE(),

    @TruncLog = 'BACKUP LOG ' + db_name() + ' WITH TRUNCATE_ONLY'

    DBCC SHRINKFILE (@LogicalFileName, @NewSize)

    EXEC (@TruncLog)

    -- Wrap the log if necessary.

    WHILE @MaxMinutes > DATEDIFF (mi, @StartTime, GETDATE()) -- time has not expired

    AND @OriginalSize = (Select size FROM sysfiles Where name = @LogicalFileName)

    AND (@OriginalSize * 8 /1024) > @NewSize

    BEGIN -- Outer loop.

    Select @Counter = 0

    WHILE ((@Counter < @OriginalSize / 16) AND (@Counter < 50000))

    BEGIN -- update

    Insert DummyTrans VALUES ('Fill Log')

    Delete DummyTrans

    Select @Counter = @Counter + 1

    END

    EXEC (@TruncLog)

    END

    Select 'Final Size of ' + db_name() + ' LOG is ' +

    CONVERT(VARCHAR(30),size) + ' 8K pages or ' +

    CONVERT(VARCHAR(30),(size*8/1024)) + 'MB'

    FROM sysfiles

    Where name = @LogicalFileName

    Drop TABLE DummyTrans

    SET NOCOUNT OFF

    更改某个表

    exec sp_changeobjectowner 'tablename','dbo'

    存储更改全部表

    Create PROCEDURE dbo.User_ChangeObjectOwnerBatch

    @OldOwner as NVARCHAR(128),

    @NewOwner as NVARCHAR(128)

    AS

    DECLARE @Name as NVARCHAR(128)

    DECLARE @Owner as NVARCHAR(128)

    DECLARE @OwnerName as NVARCHAR(128)

    DECLARE curObject CURSOR FOR

    select 'Name' = name,

    'Owner' = user_name(uid)

    from sysobjects

    where user_name(uid)=@OldOwner

    order by name

    OPEN curObject

    FETCH NEXT FROM curObject INTO @Name, @Owner

    WHILE(@@FETCH_STATUS=0)

    BEGIN

    if @Owner=@OldOwner

    begin

    set @OwnerName = @OldOwner + '.' + rtrim(@Name)

    exec sp_changeobjectowner @OwnerName, @NewOwner

    end

    -- select @name,@NewOwner,@OldOwner

    FETCH NEXT FROM curObject INTO @Name, @Owner

    END

    close curObject

    deallocate curObject

    GO

    SQL SERVER中直接循环写入数据

    declare @i int

    set @i=1

    while @i<30

    begin

    insert into test (userid) values(@i)

    set @i=@i+1

    end

    源文档 <http://baike.baidu.com/view/3146511.html?fromTaglist>

  • 相关阅读:
    Android入门：Button
    Android入门：部署时的常见错误
    to be
    Android入门：单元测试
    忘记 MySQL 的 root 帐号密码该怎么办
    Eclipse开发build path中jar包部署到应用中
    报告两个bug
    本站导引
    一个用Word做报表设计的报表系统windwardreports
    智能互联网
  • 原文地址：https://www.cnblogs.com/Hacker2012/p/2606615.html
Copyright © 2011-2022 走看看