How to use ExecutionEngineFactory class of NBi.Core.Query.Execution package

Best NBi code snippet using NBi.Core.Query.Execution.ExecutionEngineFactory

QuerySequenceResolverTest.cs

Source:QuerySequenceResolverTest.cs

...27                    , new TimeSpan(0, 0, 30)28            );29            var args = new QuerySequenceResolverArgs(queryArgs);30            var executionEngine = Mock.Of<IExecutionEngine>(x => x.ExecuteList<string>() == new List<string>() { "foo", "bar" });31            var executionEngineFactory = Mock.Of<ExecutionEngineFactory>(x => x.Instantiate(It.IsAny<IQuery>()) == executionEngine);32            var queryResolverFactory = new ServiceLocator().GetQueryResolverFactory();33            var serviceLocator = Mock.Of<ServiceLocator>(34                x => x.GetExecutionEngineFactory() == executionEngineFactory35                && x.GetQueryResolverFactory() == queryResolverFactory36            );37            var resolver = new QuerySequenceResolver<string>(args, serviceLocator);38            var elements = resolver.Execute();39            Assert.That(elements.Count(), Is.EqualTo(2));40            Assert.That(elements, Has.Member("foo"));41            Assert.That(elements, Has.Member("bar"));42        }43        [Test]44        public void Execute_QueryEmbedded_CorrectCallsToServiceLocatorMethods()45        {46            var queryArgs = new EmbeddedQueryResolverArgs(47                    "select * from table"48                    , "server=.;initiatl catalog=db;integrated security=true"49                    , null50                    , null51                    , new TimeSpan(0, 0, 30)52            );53            var args = new QuerySequenceResolverArgs(queryArgs);54            var executionEngine = Mock.Of<IExecutionEngine>(x => x.ExecuteList<string>() == new List<string>() { "foo", "bar" });55            var executionEngineFactory = Mock.Of<ExecutionEngineFactory>(x => x.Instantiate(It.IsAny<IQuery>()) == executionEngine);56            var queryResolverFactory = new ServiceLocator().GetQueryResolverFactory();57            var serviceLocator = Mock.Of<ServiceLocator>(58                x => x.GetExecutionEngineFactory() == executionEngineFactory59                && x.GetQueryResolverFactory() == queryResolverFactory60            );61            var resolver = new QuerySequenceResolver<string>(args, serviceLocator);62            var elements = resolver.Execute();63            Mock.Get(executionEngine).Verify(x => x.ExecuteList<string>(), Times.Once);64            Mock.Get(executionEngineFactory).Verify(x => x.Instantiate(It.IsAny<IQuery>()), Times.Once);65        }66    }67}...

ExecutionEngineFactoryTest.cs

Source:ExecutionEngineFactoryTest.cs

...14using System.Threading.Tasks;15using NBi.Extensibility.Query;16namespace NBi.Testing.Core.Elasticsearch.Unit.Query.Execution17{18    public class ExecutionEngineFactoryTest19    {20        private string base64AuthKey = Convert.ToBase64String(Encoding.UTF8.GetBytes("@uthK3y"));21        private class ElasticsearchConfig : IExtensionsConfiguration22        {23            public IReadOnlyCollection<Type> Extensions => new List<Type>()24            {25                typeof(ElasticsearchClientFactory),26                typeof(ElasticsearchCommandFactory),27                typeof(ElasticsearchExecutionEngine),28            };29        }30        [Test]31        public void Instantiate_ElasticsearchConnectionString_ElasticsearchExecutionEngine()32        {33            var config = new ElasticsearchConfig();34            var clientProvider = new ClientProvider(config);35            var commandProvider = new CommandProvider(config);36            var factory = new ExecutionEngineFactory(clientProvider, commandProvider, config);37            var query = Mock.Of<IQuery>38                (39                    x => x.ConnectionString == $@"Hostname=localhost;port=9200;Username=admin;password=p@ssw0rd;api=Elasticsearch"40                    && x.Statement == @"GET index/type/_search { ""query"": {""match_all"": { }} }"41            42                );43            var engine = factory.Instantiate(query);44            Assert.That(engine, Is.Not.Null);45            Assert.That(engine, Is.TypeOf<ElasticsearchExecutionEngine>());46        }47    }48}...

ExecutionEngineFactory.cs

Source:ExecutionEngineFactory.cs

...9{10    /// <summary>11    /// Class to retrieve an adequate query engine on base of the connectionString12    /// </summary>13    public class ExecutionEngineFactory: EngineFactory<IExecutionEngine>14    {15        private Type[] classics = new[] 16        {17            typeof(AdomdExecutionEngine),18            typeof(OdbcExecutionEngine),19            typeof(OleDbExecutionEngine),20            typeof(SqlExecutionEngine)21        };22        public ExecutionEngineFactory() 23            : base()24        {25            RegisterEngines(classics);26        }27        public ExecutionEngineFactory(ClientProvider clientProvider, CommandProvider commandProvider)28            : base(clientProvider, commandProvider)29        {30            RegisterEngines(classics);31        }32        public ExecutionEngineFactory(ClientProvider clientProvider, CommandProvider commandProvider, IExtensionsConfiguration config)33            : base(clientProvider, commandProvider)34        {35            var extensions = config?.Extensions?.Where(x => typeof(IExecutionEngine).IsAssignableFrom(x.Key))?.Select(x => x.Key) ?? new Type[0];36            RegisterEngines(classics.Union(extensions).ToArray());37        }38        internal int ExtensionCount { get => engines.Count() - classics.Count(); }39    }40}

ExecutionEngineFactory

Using AI Code Generation

1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using System.Threading.Tasks;6using NBi.Core.Query.Execution;7using NBi.Core;8{9    {10        static void Main(string[] args)11        {12            var factory = new ExecutionEngineFactory();13            var engine = factory.Instantiate(new NBi.Core.Query.CommandText("SELECT * FROM [AdventureWorks2012].[Person].[BusinessEntity]"));14            var result = engine.Execute();15            var service = new ResultSetService();16            var resultSet = service.GetResultSet(result);17            foreach (var row in resultSet.Rows)18            {19                foreach (var cell in row.Cells)20                {21                    Console.WriteLine(cell.Value);22                }23            }24        }25    }26}

ExecutionEngineFactory

Using AI Code Generation

1var factory = new ExecutionEngineFactory();2var engine = factory.Instantiate(new ExecutionEngineFactoryArgs { ConnectionString = "..." });3var factory = new ExecutionEngineFactory();4var engine = factory.Instantiate(new ExecutionEngineFactoryArgs { ConnectionString = "..." });5var factory = new ExecutionEngineFactory();6var engine = factory.Instantiate(new ExecutionEngineFactoryArgs { ConnectionString = "..." });7var factory = new ExecutionEngineFactory();8var engine = factory.Instantiate(new ExecutionEngineFactoryArgs { ConnectionString = "..." });9var factory = new ExecutionEngineFactory();10var engine = factory.Instantiate(new ExecutionEngineFactoryArgs { ConnectionString = "..." });11var factory = new ExecutionEngineFactory();12var engine = factory.Instantiate(new ExecutionEngineFactoryArgs { ConnectionString = "..." });13var factory = new ExecutionEngineFactory();14var engine = factory.Instantiate(new ExecutionEngineFactoryArgs { ConnectionString = "..." });15var factory = new ExecutionEngineFactory();16var engine = factory.Instantiate(new ExecutionEngineFactoryArgs { ConnectionString = "..." });17var factory = new ExecutionEngineFactory();18var engine = factory.Instantiate(new ExecutionEngineFactoryArgs { ConnectionString = "..." });19var factory = new ExecutionEngineFactory();20var engine = factory.Instantiate(new ExecutionEngineFactoryArgs { ConnectionString = "..." });21var factory = new ExecutionEngineFactory();

ExecutionEngineFactory

Using AI Code Generation

1using NBi.Core.Query.Execution;2using NBi.Core.Query.Execution.Odbc;3using NBi.Core.Query.Execution.OleDb;4using NBi.Core.Query.Execution.SqlClient;5using System;6using System.Data;7{8    {9        static void Main(string[] args)10        {11            string connectionString = "Data Source=.;Integrated Security=SSPI;Initial Catalog=AdventureWorks2012";12            string query = "select top 10 * from Sales.SalesOrderDetail";13            var factory = new ExecutionEngineFactory();14            var engine = factory.Instantiate(connectionString);15            var result = engine.Execute(query);16            foreach (DataRow row in result.Rows)17            {18                foreach (DataColumn column in result.Columns)19                    Console.Write(row[column] + "\t");20                Console.WriteLine();21            }22        }23    }24}

ExecutionEngineFactory

Using AI Code Generation

1var factory = new ExecutionEngineFactory();2var engine = factory.Instantiate("SqlServer");3engine.Build("connectionString");4var factory = new ConnectionStringFactory();5var connectionString = factory.Instantiate("connectionString");6var engine = new SqlServerExecutionEngine(connectionString);7var factory = new ConnectionStringFactory();8var connectionString = factory.Instantiate("connectionString");9var engine = new SqlServerExecutionEngine(connectionString);10var results = engine.Execute("select 1");11var factory = new ConnectionStringFactory();12var connectionString = factory.Instantiate("connectionString");13var engine = new SqlServerExecutionEngine(connectionString);14var results = engine.Execute("select 1");15var text = results.ToText();16var factory = new ConnectionStringFactory();17var connectionString = factory.Instantiate("connectionString");18var engine = new SqlServerExecutionEngine(connectionString);19var results = engine.Execute("select 1");20var text = results.ToText();21var xml = results.ToXml();22var csv = results.ToCsv();23var factory = new ConnectionStringFactory();24var connectionString = factory.Instantiate("connectionString");25var engine = new SqlServerExecutionEngine(connectionString);26var results = engine.Execute("select 1");27var text = results.ToText();28var xml = results.ToXml();29var csv = results.ToCsv();30var table = results.ToTable();31var factory = new ConnectionStringFactory();32var connectionString = factory.Instantiate("connectionString");33var engine = new SqlServerExecutionEngine(connectionString);34var results = engine.Execute("select 1");35var text = results.ToText();36var xml = results.ToXml();37var csv = results.ToCsv();38var table = results.ToTable();39var json = results.ToJson();40var factory = new ConnectionStringFactory();

ExecutionEngineFactory

Using AI Code Generation

1var factory = new ExecutionEngineFactory();2var engine = factory.Instantiate("SqlServer");3var connectionString = new ConnectionString("Data Source=.;Integrated Security=True;Initial Catalog=AdventureWorks2012");4var command = new Command("select * from Person.Person");5var result = engine.Execute(connectionString, command);6var table = result.Table;7var factory = new ExecutionEngineFactory();8var engine = factory.Instantiate("SqlServer");9var connectionString = new ConnectionString("Data Source=.;Integrated Security=True;Initial Catalog=AdventureWorks2012");10var command = new Command("select * from Person.Person");11var result = engine.Execute(connectionString, command);12var table = result.Table;13var factory = new ExecutionEngineFactory();14var engine = factory.Instantiate("SqlServer");15var connectionString = new ConnectionString("Data Source=.;Integrated Security=True;Initial Catalog=AdventureWorks2012");16var command = new Command("select * from Person.Person");17var result = engine.Execute(connectionString, command);18var table = result.Table;19var factory = new ExecutionEngineFactory();20var engine = factory.Instantiate("SqlServer");21var connectionString = new ConnectionString("Data Source=.;Integrated Security=True;Initial Catalog=AdventureWorks2012");22var command = new Command("select * from Person.Person");23var result = engine.Execute(connectionString, command);24var table = result.Table;25var factory = new ExecutionEngineFactory();26var engine = factory.Instantiate("SqlServer");27var connectionString = new ConnectionString("Data Source=.;Integrated Security=True;Initial Catalog=AdventureWorks2012");28var command = new Command("select * from Person.Person");29var result = engine.Execute(connectionString, command);30var table = result.Table;31var factory = new ExecutionEngineFactory();32var engine = factory.Instantiate("SqlServer");33var connectionString = new ConnectionString("Data Source=.;Integrated Security=True;Initial Catalog=AdventureWorks2012");34var command = new Command("select *

ExecutionEngineFactory

Using AI Code Generation

1var factory = new ExecutionEngineFactory();2var engine = factory.Instantiate(new QueryEngineType(QueryEngineType.SqlClient));3engine.Initialize(new ConnectionStringSettings("connName", "connString", "System.Data.SqlClient"));4var cmd = engine.Command;5cmd.CommandText = "SELECT * FROM table1";6var reader = cmd.ExecuteReader();7while (reader.Read())8{9    Console.WriteLine(reader.GetString(0));10}11var factory = new ExecutionEngineFactory();12var engine = factory.Instantiate(new QueryEngineType(QueryEngineType.SqlServer));13engine.Initialize(new ConnectionStringSettings("connName", "connString", "System.Data.SqlClient"));14var cmd = engine.Command;15cmd.CommandText = "SELECT * FROM table1";16var reader = cmd.ExecuteReader();17while (reader.Read())18{19    Console.WriteLine(reader.GetString(0));20}21var factory = new ExecutionEngineFactory();22var engine = factory.Instantiate(new QueryEngineType(QueryEngineType.OleDb));23engine.Initialize(new ConnectionStringSettings("connName", "connString", "System.Data.OleDb"));24var cmd = engine.Command;25cmd.CommandText = "SELECT * FROM table1";26var reader = cmd.ExecuteReader();27while (reader.Read())28{29    Console.WriteLine(reader.GetString(0));30}31var factory = new ExecutionEngineFactory();32var engine = factory.Instantiate(new QueryEngineType(QueryEngineType.Odbc));33engine.Initialize(new ConnectionStringSettings("connName", "connString", "System.Data.Odbc"));34var cmd = engine.Command;35cmd.CommandText = "SELECT * FROM table1";36var reader = cmd.ExecuteReader();37while (reader.Read())38{39    Console.WriteLine(reader.GetString(0));40}41var factory = new ExecutionEngineFactory();42var engine = factory.Instantiate(new QueryEngineType(QueryEngineType.MySqlClient));43engine.Initialize(new ConnectionStringSettings("connName", "connString", "MySql.Data.MySqlClient"));44var cmd = engine.Command;45cmd.CommandText = "SELECT * FROM table1";46var reader = cmd.ExecuteReader();47while (reader.Read())48{49    Console.WriteLine(reader.GetString(0));50}51var factory = new ExecutionEngineFactory();

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.