通过Dapr实现一个简单的基于.net的微服务电商系统(十)——一步一步教你如何撸Dapr之绑定

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: accountpostgres
  namespace: dapreshop
spec:
  type: bindings.postgres
  version: v1
  metadata:
  - name: url
    value: user=postgres password=Mytestpwd#123 host=postgres.infrastructure port=5432 dbname=AccountDb sslmode=disable

    public class HttpHelper
    {
        private static async Task<string> GetResultAsync(string componentName, string sql)
        {
            var req = new HttpRequestMessage(HttpMethod.Post, $"http://localhost:3500/v1.0/bindings/{componentName}");
            req.Content = new StringContent(JsonSerializer.Serialize(new { operation = "query", metadata = new { sql = sql } }));
            var resp = await new HttpClient().SendAsync(req);
            if (resp.IsSuccessStatusCode)
            {
                var result = await resp.Content.ReadAsStringAsync();
                return result;
            }
            else
                throw new NotSupportedException($"component无效或不支持的sql查询语句");
        }
        public static async Task<List<T>> GetResultAsync<T>(string componentName, string sql) where T:class
        {
            var str = await GetResultAsync(componentName, sql);
            var obj = JsonSerializer.Deserialize<List<object>>(str);
            var result = new List<T>();
            foreach (JsonElement item in obj)
            {
                result.Add(AccountConvetor(item) as T);
            }
            return result;
        }

        static Infrastructure.PersistenceObject.Account AccountConvetor(JsonElement item)
        {
            var t = new Infrastructure.PersistenceObject.Account();
            t.Id = Guid.Empty;//由于不知名的原因uuid的键读取出来的值并不是uuid而是一个数组
            t.LoginName = item[1].GetString();
            t.Password = item[2].GetString();
            t.NickName = item[3].GetString();
            t.State = (Domain.Enums.AccountState)item[4].GetInt32();
            return t;
        }
    }

        [AuthenticationFilter(false)]
        public async Task<ApiResult> GetAccountListByDapr()
        {
            var result = await HttpHelper.GetResultAsync<Infrastructure.PersistenceObject.Account>("accountpostgres", "select * from public."Account"");
            return ApiResult.Ok(result);
        }