Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #547 from Ginger-Automation/BugFix/6729-Couch_base…
…_DB_Configuration Bug fix/6729 couch base db configuration
- Loading branch information
Showing
11 changed files
with
265 additions
and
6 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,179 @@ | ||
| #region License | ||
| /* | ||
| Copyright © 2014-2018 European Support Limited | ||
| Licensed under the Apache License, Version 2.0 (the "License") | ||
| you may not use this file except in compliance with the License. | ||
| You may obtain a copy of the License at | ||
| http://www.apache.org/licenses/LICENSE-2.0 | ||
| Unless required by applicable law or agreed to in writing, software | ||
| distributed under the License is distributed on an "AS IS" BASIS, | ||
| WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| See the License for the specific language governing permissions and | ||
| limitations under the License. | ||
| */ | ||
| #endregion | ||
|
|
||
| using System; | ||
| using System.Collections.Generic; | ||
| using System.Linq; | ||
| using System.Reflection; | ||
| using GingerCore.Actions; | ||
| using Amdocs.Ginger.Common; | ||
| using Couchbase; | ||
| using Couchbase.Configuration.Client; | ||
| using Couchbase.Authentication; | ||
| using Couchbase.N1QL; | ||
| using Couchbase.Configuration.Server.Serialization; | ||
|
|
||
|
|
||
| namespace GingerCore.NoSqlBase | ||
| { | ||
| public class GingerCouchbase : NoSqlBase | ||
| { | ||
| Cluster clusterCB = null; | ||
| ActDBValidation Act = null; | ||
|
|
||
| public override List<eNoSqlOperations> GetSupportedActions() | ||
| { | ||
| List<eNoSqlOperations> SupportedActions = new List<eNoSqlOperations>(); | ||
|
|
||
| SupportedActions.Add(eNoSqlOperations.freesql); | ||
| return SupportedActions; | ||
| } | ||
|
|
||
| public bool Connect() | ||
| { | ||
| try | ||
| { | ||
| clusterCB = new Couchbase.Cluster(new ClientConfiguration | ||
| { | ||
| ViewRequestTimeout = 45000, | ||
| Servers = new List<Uri> { new Uri(Db.TNSCalculated.ToString()) },//http://incespr021:8091 | ||
| }); | ||
| bool res = false; | ||
| String deCryptValue = EncryptionHandler.DecryptString(Db.PassCalculated.ToString(), ref res, false); | ||
| if (res == true) | ||
| { | ||
| Db.Pass = deCryptValue; | ||
| } | ||
|
|
||
| clusterCB.Authenticate(Db.UserCalculated.ToString(), Db.PassCalculated.ToString()); | ||
| return true; | ||
| } | ||
| catch (Exception e) | ||
| { | ||
| Reporter.ToLog(eLogLevel.ERROR, "Failed to connect to Couchbase DB", e); | ||
| throw (e); | ||
| } | ||
| } | ||
|
|
||
| //TODO: need this while checking Test Connection , need to find a better way | ||
| public GingerCouchbase(Environments.Database mDB) | ||
| { | ||
| this.Db = mDB; | ||
| } | ||
|
|
||
| public GingerCouchbase(ActDBValidation.eDBValidationType DBValidationtype, Environments.Database mDB, ActDBValidation mact) | ||
| { | ||
| Action = DBValidationtype; | ||
| this.Db = mDB; | ||
| Act = mact; | ||
| } | ||
|
|
||
| public override List<string> GetKeyspaceList() | ||
| { | ||
| return null; | ||
| } | ||
|
|
||
| public override List<string> GetTableList(string keyspace) | ||
| { | ||
| return null; | ||
| } | ||
|
|
||
| public override List<string> GetColumnList(string tablename) | ||
| { | ||
| return null; | ||
| } | ||
|
|
||
| private void Disconnect() | ||
| { | ||
| clusterCB.Dispose(); | ||
| } | ||
|
|
||
| public void ConnecttoBucket(string bucketName) | ||
| { | ||
| var clusterMan = clusterCB.CreateManager(Db.UserCalculated.ToString(),Db.PassCalculated.ToString()); | ||
| IList<BucketConfig> buckets = clusterMan.ListBuckets().Value; | ||
| string bucketpassword = (from buckConfig in buckets where buckConfig.Name == bucketName select buckConfig.SaslPassword).FirstOrDefault(); | ||
| if(bucketpassword == null) | ||
| { | ||
| throw new Exception("No bucket found with name " + bucketName); | ||
| } | ||
| ClassicAuthenticator classicAuthenticator = new ClassicAuthenticator("Administrator", "Administrator"); | ||
| classicAuthenticator.AddBucketCredential(bucketName, bucketpassword); | ||
| clusterCB.Authenticate(classicAuthenticator); | ||
| } | ||
|
|
||
| public override void PerformDBAction() | ||
| { | ||
| Connect(); | ||
| string SQL = Act.SQL; | ||
| string keyspace = Act.Keyspace; | ||
| ValueExpression VE = new ValueExpression(Db.ProjEnvironment, Db.BusinessFlow, Db.DSList); | ||
| VE.Value = SQL; | ||
| string SQLCalculated = VE.ValueCalculated; | ||
| IQueryResult<dynamic> result =null; | ||
| string bucketName = ""; | ||
| try | ||
| { | ||
| switch (Action) | ||
| { | ||
| case Actions.ActDBValidation.eDBValidationType.FreeSQL: | ||
|
|
||
| if(!String.IsNullOrEmpty(SQLCalculated)) | ||
| { | ||
| bucketName = SQLCalculated.Substring(SQLCalculated.IndexOf(" from ") + 6); | ||
| bucketName = bucketName.Substring(0, bucketName.IndexOf(" ")).Replace("`",""); | ||
| } | ||
| ConnecttoBucket(bucketName); | ||
| result = clusterCB.Query<dynamic>(SQLCalculated); | ||
| for (int i=0; i< result.Rows.Count;i++) | ||
| { | ||
| Act.ParseJSONToOutputValues(result.Rows[i].ToString(), i+1); | ||
| } | ||
| break; | ||
| case Actions.ActDBValidation.eDBValidationType.RecordCount: | ||
| string SQLRecord = SQLCalculated; | ||
| ConnecttoBucket(SQLCalculated); | ||
| result = clusterCB.Query<dynamic>("Select Count(*) as RECORDCOUNT from `" + SQLCalculated + "`"); | ||
| Act.ParseJSONToOutputValues(result.Rows[0].ToString(), 1); | ||
| break; | ||
| case Actions.ActDBValidation.eDBValidationType.UpdateDB: | ||
| if (!String.IsNullOrEmpty(SQLCalculated)) | ||
| { | ||
| bucketName = SQLCalculated.Substring(SQLCalculated.IndexOf(" from ") + 6); | ||
| bucketName = bucketName.Substring(0, bucketName.IndexOf(" ")).Replace("`", ""); | ||
| } | ||
| ConnecttoBucket(bucketName); | ||
| var RS1 = clusterCB.Query<dynamic>(SQLCalculated); | ||
| break; | ||
|
|
||
| default: | ||
| throw new Exception("Action Not SUpported"); | ||
| } | ||
| } | ||
| catch (Exception e) | ||
| { | ||
| Act.Error = "Failed to execute. Error :" + e.Message; | ||
| Reporter.ToLog(eLogLevel.ERROR, $"Method - {MethodBase.GetCurrentMethod().Name}, Error - {e.Message}", e); | ||
| } | ||
| if (!Db.KeepConnectionOpen) | ||
| { | ||
| Disconnect(); | ||
| } | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.