【Azure Services Platform Step by Step-第4篇】SQL Data Services 编程基础

简介:

这一篇,我们会详细讲解如何使用程序员的方法来操作SDS。

SDS提供SOAP和REST两种接口,这里我们是用REST+C#的方法来讲解。SOAP与之殊途同归,请有兴趣的同学自己查阅MSDN。

闲话少说,下面我们以创建Authority为例,给出REST操作SDS的“万能框架”:

public   string  CreateAuthority()
       {
           //步骤一(蓝色部分):通过某种方式,构造要发送到服务的XML数据。显然,这一部分只有在POST方法和PUT方法时才会有,对于GET方法和DELETE方法则不需要。下面示例的是一个创建Authority的XML
        
   const string AuthorityTemplate =
                     @"<s:Authority xmlns:s='http://schemas.microsoft.com/sitka/2008/03/'>
                       <s:Id>{0}</s:Id>
                     </s:Authority>";

           if (String.IsNullOrEmpty(ServiceUri))
           {
               throw new ArgumentOutOfRangeException("ServiceUri");
           }

           string authorityUri = null;
           try
           {

               string requestPayload = string.Format(AuthorityTemplate, authorityId); 
              //步骤二:建立用以传送数据的HttpWebRequest对象
              HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(ServiceUri);
              //步骤三:将用户名和密码放置在HttpWebRequest对象的Credentials中
               request.Credentials = new NetworkCredential(userName, password);

              //步骤四(:设置Http方法。HTTP方法与数据操作方法的对照: POST=create; PUT=update; DELETE=delete; GET=retrieve 。在这个例子中,我们需要create,所以选择POST方法。
               request.Method = "POST";

             //步骤五(蓝色部分):传送数据到服务器。显然,这一部分只有在POST方法和PUT方法时才会有,对于GET方法和DELETE方法则不需要。

               UTF8Encoding encoding = new UTF8Encoding();
               request.ContentLength = encoding.GetByteCount(requestPayload);
               request.ContentType = XmlContentType;

               // 传送数据
               using (Stream reqStm = request.GetRequestStream())
               {
                   reqStm.Write(encoding.GetBytes(requestPayload), 0, encoding.GetByteCount(requestPayload));
               } 
             
          //步骤六 :获取服务器响应,根据服务器的相应获取操作结果    
       HttpWebResponse response = (HttpWebResponse)request.GetResponse();
               if (response.StatusCode != HttpStatusCode.Created)
               {
                   Console.WriteLine("Failed to create authority");
               }
               authorityUri = "
https://" + authorityId + ".data.database.windows.net/v1/";
           }
           catch (WebException ex)
           {
               Console.Error.WriteLine(ex);
               HttpWebResponse response = ex.Response as HttpWebResponse;
               if (response != null)
               {
                   string errorMsg = ReadResponse(response);
                   Console.WriteLine(string.Format("Error: {0}", errorMsg));
                   Console.WriteLine("Unexpected status code returned: {0} ", response.StatusCode);
               }
           }

           return authorityUri;
       }

很简单吧? 所有的操作与这个“万能框架”相似。例如,我们稍微做一些改动,就可以得到下面这样一个删除Entity的函数:

public   string  DeleteEntity(string entityId)
       {
//由于删除是HTTP中的Delete操作,所以无步骤一和步骤五

string EntityUri = string.Format("https://{0}.data.database.windows.net/v1/{1}/{2}", 
                                                    authorityId, containerId, entityId);
         try
         {
//步骤二: WebRequest request = HttpWebRequest.Create(EntityUri);
//步骤三: request.Credentials = new NetworkCredential(userName, password);
//步骤四: request.Method = "DELETE";             
//步骤六:using (HttpWebResponse response = (HttpWebResponse)request.GetResponse())
             {
                 if (response.StatusCode != HttpStatusCode.OK)
                 {
                     Console.WriteLine("Failed to delete the entity resource.");
                 }
             }
         }
         catch (WebException ex)
         {
             string errorMsg = ex.Message;
             Console.WriteLine("Deletion failed: {0}", errorMsg);

             if (ex.Response != null)
             {
                 using (HttpWebResponse response = ex.Response as HttpWebResponse)
                 {
                         Console.WriteLine("Unexpected status code returned: {0}", response.StatusCode);
                 }
             }
         }
}

UPDATE的操作和"万能框架"中Create的方法基本雷同,唯一区别是在步骤4的地方,将"POST"改为"PUT"。比如以下这个函数:

读取数据就不用说了吧?呵呵。。那太容易了,就连把URI直接输入浏览器都可以。不过作为编程来说,其实就是在上面给出的DeleteEntity()函数的代码中,步骤四的HTTP方法由DELETE改为GET,再大到HttpWebResponse 中去获取你想要获取的内容。

至此,数据库的四种操作(CRUD,Create,Read,Update,Delete)我们都已经讲过了。对,就是这么容易。



本文转自 流牛木马 博客园博客,原文链接:http://www.cnblogs.com/azure/archive/2008/12/21/1359174.html,如需转载请自行联系原作者

相关文章
|
7月前
|
SQL Oracle 关系型数据库
【Oracle】玩转Oracle数据库(五):PL/SQL编程
【Oracle】玩转Oracle数据库(五):PL/SQL编程
152 8
|
1月前
|
SQL 数据挖掘 Python
数据分析编程:SQL,Python or SPL?
数据分析编程用什么,SQL、python or SPL?话不多说,直接上代码,对比明显,明眼人一看就明了:本案例涵盖五个数据分析任务:1) 计算用户会话次数;2) 球员连续得分分析;3) 连续三天活跃用户数统计;4) 新用户次日留存率计算;5) 股价涨跌幅分析。每个任务基于相应数据表进行处理和计算。
|
2月前
|
SQL 存储 机器学习/深度学习
将 AWS Data Lake 和 S3 与 SQL Server 结合使用
将 AWS Data Lake 和 S3 与 SQL Server 结合使用
74 0
|
4月前
|
Java 测试技术 容器
从零到英雄:Struts 2 最佳实践——你的Web应用开发超级变身指南!
【8月更文挑战第31天】《Struts 2 最佳实践:从设计到部署的全流程指南》深入介绍如何利用 Struts 2 框架从项目设计到部署的全流程。从初始化配置到采用 MVC 设计模式,再到性能优化与测试,本书详细讲解了如何构建高效、稳定的 Web 应用。通过最佳实践和代码示例,帮助读者掌握 Struts 2 的核心功能,并确保应用的安全性和可维护性。无论是在项目初期还是后期运维,本书都是不可或缺的参考指南。
55 0
|
4月前
|
SQL 数据库 索引
SQL 编程最佳实践简直太牛啦!带你编写高效又可维护的 SQL 代码,轻松应对数据库挑战!
【8月更文挑战第31天】在SQL编程中,高效与可维护的代码至关重要,不仅能提升数据库性能,还降低维护成本。本文通过案例分析探讨SQL最佳实践:避免全表扫描,利用索引加速查询;合理使用JOIN,避免性能问题;避免使用`SELECT *`,减少不必要的数据传输;使用`COMMIT`和`ROLLBACK`确保事务一致性;添加注释提高代码可读性。遵循这些实践,不仅提升性能,还便于后期维护和扩展。应根据具体情况选择合适方法并持续优化SQL代码。
67 0
|
4月前
|
SQL JavaScript 前端开发
【Azure 应用服务】Azure JS Function 异步方法中执行SQL查询后,Callback函数中日志无法输出问题
【Azure 应用服务】Azure JS Function 异步方法中执行SQL查询后,Callback函数中日志无法输出问题
|
4月前
|
SQL Java 数据库连接
【Azure 应用服务】Java ODBC代码中,启用 Managed Identity 登录 SQL Server 报错 Managed Identity authentication is not available
【Azure 应用服务】Java ODBC代码中,启用 Managed Identity 登录 SQL Server 报错 Managed Identity authentication is not available
|
4月前
|
SQL Java 数据库连接
【Azure Spring Cloud】Azure Spring Cloud connect to SQL using MSI
【Azure Spring Cloud】Azure Spring Cloud connect to SQL using MSI
|
4月前
|
网络协议 NoSQL 网络安全
【Azure 应用服务】由Web App“无法连接数据库”而逐步分析到解析内网地址的办法(SQL和Redis开启private endpoint,只能通过内网访问,无法从公网访问的情况下)
【Azure 应用服务】由Web App“无法连接数据库”而逐步分析到解析内网地址的办法(SQL和Redis开启private endpoint,只能通过内网访问,无法从公网访问的情况下)
|
4月前
|
SQL 存储 JSON
【Azure 存储服务】Blob中数据通过Stream Analytics导出到SQL/Cosmos DB
【Azure 存储服务】Blob中数据通过Stream Analytics导出到SQL/Cosmos DB