diff --git a/Hadoop/ZKLT.Hadoop.API/Program.cs b/Hadoop/ZKLT.Hadoop.API/Program.cs index 38f3a30..3e2187e 100644 --- a/Hadoop/ZKLT.Hadoop.API/Program.cs +++ b/Hadoop/ZKLT.Hadoop.API/Program.cs @@ -40,34 +40,34 @@ namespace ZKLT.Hadoop.API app.UseCors("all"); #endregion - app.UseHadoop((c) => - { - c.Host = "127.0.0.1"; - c.Account = "root"; - c.PassWord = "root"; - c.Key = "hadoopdb"; - c.Port = 3306; - }); - - //app.UseHadoop((c) => //{ - // c.Host = "172.17.0.1"; + // c.Host = "127.0.0.1"; // c.Account = "root"; // c.PassWord = "root"; - // c.Key = "testdb"; - // c.Port = 4000; + // c.Key = "hadoopdb"; + // c.Port = 3306; //}); + //app.UseHadoop((c) => //{ - // c.Host = "118.195.165.218"; + // c.Host = "172.17.0.1"; // c.Account = "root"; // c.PassWord = "root"; // c.Key = "testdb"; // c.Port = 4000; //}); + app.UseHadoop((c) => + { + c.Host = "118.195.165.218"; + c.Account = "root"; + c.PassWord = "root"; + c.Key = "testdb"; + c.Port = 4000; + }); + // Configure the HTTP request pipeline. if (app.Environment.IsDevelopment()) { diff --git a/Hadoop/ZKLT.Hadoop/TableService.cs b/Hadoop/ZKLT.Hadoop/TableService.cs index f6d4f98..c63230d 100644 --- a/Hadoop/ZKLT.Hadoop/TableService.cs +++ b/Hadoop/ZKLT.Hadoop/TableService.cs @@ -72,6 +72,10 @@ namespace ZKLT.Hadoop { param.Add(_guid, _data[_item.Name]!); } + else if (_item.Value.ToString() == HDP_WhereType.LIKE) + { + param.Add(_guid,$@"%{((JValue)_data[_item.Name]!).Value!}%" ); + } else { param.Add(_guid, ((JValue)_data[_item.Name]!).Value!); } @@ -525,6 +529,15 @@ namespace ZKLT.Hadoop { throw new ArgumentNullException("条件无效"); } + List _where = new List(); + if (where.Type == JTokenType.Object) + { + _where.Add((JObject)where); + } + else if (where.Type == JTokenType.Array) + { + _where.AddRange(((JArray)where).ToObject()!); + } if (data == null || data.Count == 0) { throw new ArgumentNullException("数据无效"); @@ -564,7 +577,7 @@ namespace ZKLT.Hadoop for (var i = 0; i < table.Columns.Length; i++) { var _column = table.Columns[i]; - if (_row.ContainsKey(_column.Key!)) + if (_row.ContainsKey(_column.Key!) && !_where.Any(x => x.ContainsKey(_column.Key!))) { _colstr.Append($@"`{_column.Key!}`=@{_column.Key!},"); _params.Add(_column.Key!, ((JValue)_row[_column.Key!]!).Value!);