博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
速记 - 实现sql server clr trigger
阅读量:6832 次
发布时间:2019-06-26

本文共 3230 字,大约阅读时间需要 10 分钟。

本来一直反对在sql server中使用clr的,但是无奈在我之前,网站已经被人开启clr,所以今天干脆偶也来实现一个clr的trigger,用于在文章表内建立一个insert 触发器,每次发表文章,均ping一次google的博客接口。

过程如下:

1 建立sql server 项目,选择触发器

2 写代码:

ContractedBlock.gif
ExpandedBlockStart.gif
Code
public partial class Triggers
{
    
// 为目标输入现有表或视图并取消对属性行的注释
    [Microsoft.SqlServer.Server.SqlTrigger (Name="Articletrigger", Target="cyzonearticle", Event="FOR INSERT")]
    
public static void Articletrigger()
    {
        
try
        {
            SqlTriggerContext triggContext 
= SqlContext.TriggerContext;
            
//    SqlParameter userName = new SqlParameter("@username", System.Data.SqlDbType.NVarChar);
            
if (triggContext.TriggerAction == TriggerAction.Insert)
            {
                
using (SqlConnection conn = new SqlConnection("context connection=true"))
                {
                    conn.Open();
                    SqlCommand sqlComm 
= new SqlCommand();
                    SqlPipe sqlP 
= SqlContext.Pipe;
                    sqlComm.Connection 
= conn;
                    sqlComm.CommandText 
= @"select i.articleid,i.userid,i.time,i.publishtype,u.username,u.blogname,u.createtime,dbo.GetLinkUrl(i.articleid,i.publishtype,u.username,i.time) as url from inserted i 
                inner join userbase u on(i.userid = u.userid)
";
                    DataSet ds 
= new DataSet();
                    SqlDataAdapter da 
= new SqlDataAdapter(sqlComm);
                    da.Fill(ds);
                    DataRow dr 
= ds.Tables[0].Rows[0];
                    
string articleid = dr["articleid"].ToString();
                    
string userid = dr["userid"].ToString();
                    DateTime time 
= Convert.ToDateTime(dr["time"]);
                    
string publishtype = dr["publishtype"].ToString();
                    
string username = dr["username"].ToString();
                    DateTime createtime 
= Convert.ToDateTime(dr["createtime"]);
                    
string blogname = dr["blogname"].ToString();
                    
string url = dr["url"].ToString();
                    
string rssurl = "";
                    
if (publishtype.ToLower()=="a" || publishtype.ToLower()=="b" || publishtype.ToLower()=="c" )
                    {
                        rssurl 
= "http://www.cyzone.cn/blog/" + username + "/rss.aspx";
                    }
                    
if ((time - createtime) > new TimeSpan(3000))
                    {
                        
string returns = PingGoogleBlogService(blogname, url, rssurl);
                        
string flag = "0";
                        
if (returns != "Thanks for the ping.")
                        {
                            flag 
= "1";
                        }
                        sqlComm.CommandText 
= "INSERT X_Google_Blog_Ping_Log(articleid,time,flag) VALUES('" + articleid + "','" + time + "','" + flag + "')";
                        sqlP.Send(sqlComm.CommandText);
                        sqlP.ExecuteAndSend(sqlComm);
                    }
                }
            }
        }
        
catch (Exception ee)
        { 
            System.IO.StreamWriter sw 
= new System.IO.StreamWriter(@"E:\services\GooglePingDll\xx.txt");
            sw.WriteLine(ee.Message
+ee.Source);
            sw.Close();
        }
    }
    
private static string PingGoogleBlogService(string blogname, string url, string rssurl)
    {
        WebClient w 
= new WebClient();
        Uri uri ;
        
if (string.IsNullOrEmpty(rssurl))
            uri 
= new Uri("http://blogsearch.google.com/ping?name=" + blogname + "&url=" + url, false);
        
else
            uri 
= new Uri("http://blogsearch.google.com/ping?name=" + blogname + "&url=" + url+"&changesURL="+rssurl,false);
        
return w.DownloadString(uri);
    }
}

3 编译项目,上传dll到服务器指定目录

4 开启clr(偶的服务器已经默认开启)

5 USE  cyzone

  GO  
   

  EXEC   sp_changedbowner   'sa'   (更改安全主体,有些服务器不需要)

6  ALTER DATABASE cyzone SET TRUSTWORTHY ON

 7 CREATE ASSEMBLY GooleBlogPingService

FROM 'E:"services"GooglePingDll"GoogleBlogPingServiceSqlFunction.dll'
WITH PERMISSION_SET = unSAFE;

8  Create Trigger tr_aasdasd

on cyzonearticle
For INSERT
AS
External Name GooleBlogPingService.Triggers.Articletrigger
Go

其中有几点要注意的是:

 

 如果您的触发器程序中没有访问到数据库服务器的外部资源,可以将权限设置为安全模式,并且略去第5步和第6步

最后一步也是将触发器和程序集挂钩。

 这个名称 GooleBlogPingService.Triggers.Articletrigger 是比较讲究的,他的组成是:程序集名称.类名.方法名

 

that's all.

 

 

 

 

 

 

你可能感兴趣的文章
centos/linux下的使得maven/tomcat能在普通用户是使用
查看>>
Web学习篇之---html基础知识(一)
查看>>
java多线程入门学习(一)
查看>>
多线程间的通讯之等待唤醒机制
查看>>
Shell中整数比較
查看>>
IOS应用内购(一)内购的种类
查看>>
canvas图形处理和进阶用法
查看>>
传输PDF文档的好帮手
查看>>
更新部分屏幕内容
查看>>
The server does not support version 3.0 of the J2EE Web module specification
查看>>
SQL Server内存
查看>>
MPU6050带字符驱动的i2c从设备驱动2
查看>>
深入探析c# Socket
查看>>
Python 全集变量
查看>>
1. 请问PHP里的ECHO是什么意思 ?请问PHP里的ECHO是什么意思???有什么作用???又应该怎么使用???...
查看>>
ES6,数组遍历
查看>>
如何把浏览器不信任的网址设置为可信任的网点
查看>>
脚本加密http://www.datsi.fi.upm.es/~frosal/sources/
查看>>
Cocos Studio is EOL'd
查看>>
linux shell下16进制 “\uxxxx” unicode to UTF-8中文
查看>>