Skip to content

Add more execution test for InlineTable, Variable #603

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
ahmad-moussawi merged 1 commit into from
Sep 10, 2022
Merged

Add more execution test for InlineTable, Variable #603

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
156 changes: 108 additions & 48 deletions QueryBuilder.Tests/MySqlExecutionTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,8 @@
using MySql.Data.MySqlClient;
using System;
using System.Linq;
using static SqlKata.Expressions;
using System.Collections.Generic;

namespace SqlKata.Tests
{
Expand All @@ -13,61 +15,48 @@ public class MySqlExecutionTest
public void EmptySelect()
{

var db = SetupDb();
var sql = @"
CREATE TABLE Cars(
Id INT PRIMARY KEY AUTO_INCREMENT,
Brand TEXT NOT NULL,
Year INT NOT NULL,
Color TEXT NULL
)
";
db.Statement(sql);
var db = DB().Create("Cars", new[] {
"Id INT PRIMARY KEY AUTO_INCREMENT",
"Brand TEXT NOT NULL",
"Year INT NOT NULL",
"Color TEXT NULL",
});

var rows = db.Query("Cars").Get();

Assert.Empty(rows);

db.Statement("DROP TABLE IF EXISTS `Cars`");
db.Drop("Cars");
}

[Fact]
public void SelectWithLimit()
{

var db = SetupDb();
var sql = @"
CREATE TABLE Cars(
Id INT PRIMARY KEY AUTO_INCREMENT,
Brand TEXT NOT NULL,
Year INT NOT NULL,
Color TEXT NULL
)
";
db.Statement(sql);
var db = DB().Create("Cars", new[] {
"Id INT PRIMARY KEY AUTO_INCREMENT",
"Brand TEXT NOT NULL",
"Year INT NOT NULL",
"Color TEXT NULL",
});

db.Statement("INSERT INTO `Cars`(Brand, Year) VALUES ('Honda', 2020)");

var rows = db.Query("Cars").Get().ToList();

Assert.Equal(1, rows.Count());

db.Statement("DROP TABLE IF EXISTS `Cars`");
db.Drop("Cars");
}

[Fact]
public void Count()
{
var db = SetupDb();
var sql = @"
CREATE TABLE Cars(
Id INT PRIMARY KEY AUTO_INCREMENT,
Brand TEXT NOT NULL,
Year INT NOT NULL,
Color TEXT NULL
)
";
db.Statement(sql);
var db = DB().Create("Cars", new[] {
"Id INT PRIMARY KEY AUTO_INCREMENT",
"Brand TEXT NOT NULL",
"Year INT NOT NULL",
"Color TEXT NULL",
});

db.Statement("INSERT INTO `Cars`(Brand, Year) VALUES ('Honda', 2020)");
var count = db.Query("Cars").Count<int>();
Expand All @@ -83,22 +72,18 @@ Color TEXT NULL
count = db.Query("Cars").Count<int>();
Assert.Equal(0, count);

db.Statement("DROP TABLE IF EXISTS `Cars`");
db.Drop("Cars");
}

[Fact]
public void CloneThenCount()
{
var db = SetupDb();
var sql = @"
CREATE TABLE Cars(
Id INT PRIMARY KEY AUTO_INCREMENT,
Brand TEXT NOT NULL,
Year INT NOT NULL,
Color TEXT NULL
)
";
db.Statement(sql);
var db = DB().Create("Cars", new[] {
"Id INT PRIMARY KEY AUTO_INCREMENT",
"Brand TEXT NOT NULL",
"Year INT NOT NULL",
"Color TEXT NULL",
});

for (int i = 0; i < 10; i++)
{
Expand All @@ -116,23 +101,98 @@ Color TEXT NULL
Assert.Equal(4, count);
Assert.Equal(4, cloneCount);

db.Statement("DROP TABLE IF EXISTS `Cars`");
db.Drop("Cars");
}

public QueryFactory SetupDb()
[Fact]
public void QueryWithVariable()
{
var db = DB().Create("Cars", new[] {
"Id INT PRIMARY KEY AUTO_INCREMENT",
"Brand TEXT NOT NULL",
"Year INT NOT NULL",
"Color TEXT NULL",
});

for (int i = 0; i < 10; i++)
{
db.Query("Cars").Insert(new
{
Brand = "Brand " + i,
Year = "2020",
});
}


var count = db.Query("Cars")
.Define("Threshold", 5)
.Where("Id", "<", SqlKata.Expressions.Variable("Threshold"))
.Count<int>();

Assert.Equal(4, count);

db.Drop("Cars");
}

[Fact]
public void InlineTable()
{
var db = DB().Create("Transaction", new[] {
"Id INT PRIMARY KEY AUTO_INCREMENT",
"Amount int NOT NULL",
"Date DATE NOT NULL",
});

db.Query("Transaction").Insert(new
{
Date = "2022-01-01",
Amount = 10
});


var rows = db.Query("Transaction")
.With("Rates", new[] { "Date", "Rate" }, new object[][] {
new object[] {"2022-01-01", 0.5},
})
.Join("Rates", "Rates.Date", "Transaction.Date")
.SelectRaw("Transaction.Amount * Rates.Rate as AmountConverted")
.Get();

Assert.Equal(1, rows.Count());
Assert.Equal(5, rows.First().AmountConverted);

db.Drop("Transaction");
}

QueryFactory DB()
{
var host = System.Environment.GetEnvironmentVariable("SQLKATA_MYSQL_HOST");
var user = System.Environment.GetEnvironmentVariable("SQLKATA_MYSQL_USER");
var dbName = System.Environment.GetEnvironmentVariable("SQLKATA_MYSQL_DB");
var cs = $"server={host};user={user};database={dbName}";
Console.WriteLine($"Using cs: {cs}");

var connection = new MySqlConnection(cs);

var db = new QueryFactory(connection, new MySqlCompiler());

db.Statement("DROP TABLE IF EXISTS `Cars`");
return db;
}



}
static class QueryFactoryExtensions
{
public static QueryFactory Create(this QueryFactory db, string table, IEnumerable<string> cols)
{
db.Drop(table);
db.Statement($"CREATE TABLE `{table}`({string.Join(", ", cols)})");
return db;
}

public static QueryFactory Drop(this QueryFactory db, string table)
{
db.Statement($"DROP TABLE IF EXISTS `{table}`");
return db;
}
}
Expand Down