using System;

using System.Collections.Generic;

using System.Data;

using System.Linq;

using SqlKata.Compilers;

namespace SqlKata.Execution

{

public class XQuery : Query

{

public IDbConnection Connection { get; set; }

public Compiler Compiler { get; set; }

public Action<SqlResult> Logger = result => { };

public QueryFactory QueryFactory { get; set; }

public XQuery(IDbConnection connection, Compiler compiler)

{

this.QueryFactory = new QueryFactory(connection, compiler);

this.Connection = connection;

this.Compiler = compiler;

}

public override Query Clone()

{

var query = new XQuery(this.QueryFactory.Connection, this.QueryFactory.Compiler);

if (this.QueryFactory?.QueryTimeout != null)

{

query.QueryFactory.QueryTimeout = this.QueryFactory?.QueryTimeout ?? 30;

}

query.Clauses = this.Clauses.Select(x => x.Clone()).ToList();

query.Logger = this.Logger;

query.QueryAlias = QueryAlias;

query.IsDistinct = IsDistinct;

query.Method = Method;

query.Includes = Includes.Select(i => i.Clone()).ToList();

query.Variables = new Dictionary<string, object>(Variables);

query.SetEngineScope(EngineScope);

return query;

}

}

}