Windows Azure入门教学系列 (六)：使用Table Storage

2

3

using Microsoft.WindowsAzure;

using Microsoft.WindowsAzure.StorageClient;

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

class Program

{

    static void Main(string[] args)

    {

        var storageAccount = CloudStorageAccount.DevelopmentStorageAccount;

        var tableStorage = storageAccount.CreateCloudTableClient();

        // 检查名为CustomerInfo的表格是否被创建，如果没有，创建它

        tableStorage.CreateTableIfNotExist("CustomerInfo");

        // 创建表格服务上下文

        var context = new CustomerInfoContext(storageAccount.TableEndpoint.AbsoluteUri, storageAccount.Credentials);

        // 插入两条客户信息数据,客户ID分别设置为0和1

        CustomerInfo ci1 = new CustomerInfo() { CustomerAge = 25, CustomerID = "0", CustomerName = "Mike" };

        context.AddObject("CustomerInfo", ci1);

        CustomerInfo ci2 = new CustomerInfo() { CustomerAge = 32, CustomerID = "1", CustomerName = "Peter" };

        context.AddObject("CustomerInfo", ci2);

        context.SaveChanges();

        // 查找CustomerID为1的客户数据并显示

        Console.WriteLine("Retrieve information of a customer whose ID is 1");

        var query = context.CreateQuery<CustomerInfo>("CustomerInfo").Where(c => c.CustomerID == "1").ToList();

        var returnedcustomerinfo = query.FirstOrDefault();

        Console.WriteLine(string.Format("Customer info retrieved: ID:{0},Name:{1},Age:{2}",

            returnedcustomerinfo.CustomerID, returnedcustomerinfo.CustomerName, returnedcustomerinfo.CustomerAge));

        // 更新CustomerID为1的客户数据中的年龄

        returnedcustomerinfo.CustomerAge = 33;

        context.UpdateObject(returnedcustomerinfo);

        Console.WriteLine("**Customer Info updated**");

        // 重新查询,测试更新效果

        Console.WriteLine("Retrieve information of a customer whose ID is 1");

        var query2 = context.CreateQuery<CustomerInfo>("CustomerInfo").Where(c => c.CustomerID == "1").ToList();

        var returnedcustomerinfo2 = query.FirstOrDefault();

        Console.WriteLine(string.Format("Customer info retrieved: ID:{0},Name:{1},Age:{2}",

                returnedcustomerinfo2.CustomerID, returnedcustomerinfo2.CustomerName, returnedcustomerinfo2.CustomerAge));

        // 删除插入的两条客户数据

        context.DeleteObject(ci1);

        context.DeleteObject(ci2);

        context.SaveChanges();

        Console.WriteLine("The records has been deleted");

        Console.ReadLine();

    }

}

public class CustomerInfo : TableServiceEntity

{

    public string CustomerID

    {

        get { return this.RowKey; }

        set { this.RowKey = value; }

    }

    public string CustomerName { get; set; }

    public int CustomerAge { get; set; }

    public CustomerInfo()

    {

        this.PartitionKey = "mypartitionkey";

    }

}

public class CustomerInfoContext : TableServiceContext

{

    public CustomerInfoContext(string baseAddress, StorageCredentials credentials) :

        base(baseAddress, credentials)

    {

    }

}

2

3

4

5

6

7

8

9

10

11

12

13

public IQueryable<CustomerInfo> CustomerInfo

{

    get

    {

        return CreateQuery<CustomerInfo>("CustomerInfo");

    }

}