Add SQLite basic exection tests

Author: ahmad-moussawi

QueryBuilder.Tests/SQLiteExecutionTest.cs

@@ -0,0 +1,224 @@
+using SqlKata.Compilers;
+using Xunit;
+using SqlKata.Execution;
+using MySql.Data.MySqlClient;
+using System;
+using System.Linq;
+using static SqlKata.Expressions;
+using System.Collections.Generic;
+using Microsoft.Data.Sqlite;
+
+namespace SqlKata.Tests
+{
+    public class SqliteExecutionTest
+    {
+        [Fact]
+        public void EmptySelect()
+        {
+
+            var db = DB().Create("Cars", new[] {
+                    "Id INTEGER PRIMARY KEY AUTOINCREMENT",
+                    "Brand TEXT NOT NULL",
+                    "Year INT NOT NULL",
+                    "Color TEXT NULL",
+            });
+
+
+            var tables = db.Select(@"SELECT name FROM sqlite_schema WHERE type ='table' AND name NOT LIKE 'sqlite_%'");
+
+            var rows = db.Query("Cars").Get();
+
+            Assert.Empty(rows);
+
+            db.Drop("Cars");
+        }
+
+        [Fact]
+        public void SelectWithLimit()
+        {
+            var db = DB().Create("Cars", new[] {
+                    "Id INTEGER PRIMARY KEY AUTOINCREMENT",
+                    "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.Single(rows);
+
+            db.Drop("Cars");
+        }
+
+        [Fact]
+        public void InsertGetId()
+        {
+            var db = DB().Create("Cars", new[] {
+                    "Id INTEGER PRIMARY KEY AUTOINCREMENT",
+                    "Brand TEXT NOT NULL",
+                    "Year INT NOT NULL",
+            });
+
+            var id = db.Query("Cars").InsertGetId<int>(new
+            {
+                Brand = "Toyota",
+                Year = 1900
+            });
+
+            Assert.Equal(1, id);
+
+            id = db.Query("Cars").InsertGetId<int>(new
+            {
+                Brand = "Toyota 2",
+                Year = 1901
+            });
+
+            Assert.Equal(2, id);
+
+            id = db.Query("Cars").InsertGetId<int>(new
+            {
+                Brand = "Toyota 2",
+                Year = 1901
+            });
+
+            Assert.Equal(3, id);
+
+
+            db.Drop("Cars");
+        }
+
+
+
+        [Fact]
+        public void Count()
+        {
+            var db = DB().Create("Cars", new[] {
+                    "Id INTEGER PRIMARY KEY AUTOINCREMENT",
+                    "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>();
+            Assert.Equal(1, count);
+
+            db.Statement("INSERT INTO `Cars`(Brand, Year) VALUES ('Toyota', 2021)");
+            count = db.Query("Cars").Count<int>();
+            Assert.Equal(2, count);
+
+            int affected = db.Query("Cars").Delete();
+            Assert.Equal(2, affected);
+
+            count = db.Query("Cars").Count<int>();
+            Assert.Equal(0, count);
+
+            db.Drop("Cars");
+        }
+
+        [Fact]
+        public void CloneThenCount()
+        {
+            var db = DB().Create("Cars", new[] {
+                    "Id INTEGER PRIMARY KEY AUTOINCREMENT",
+                    "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 query = db.Query("Cars").Where("Id", "<", 5);
+            var count = query.Count<int>();
+            var cloneCount = query.Clone().Count<int>();
+
+            Assert.Equal(4, count);
+            Assert.Equal(4, cloneCount);
+
+            db.Drop("Cars");
+        }
+
+        [Fact]
+        public void QueryWithVariable()
+        {
+            var db = DB().Create("Cars", new[] {
+                    "Id INTEGER PRIMARY KEY AUTOINCREMENT",
+                    "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 INTEGER PRIMARY KEY AUTOINCREMENT",
+                    "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.Single(rows);
+            Assert.Equal(5, rows.First().AmountConverted);
+
+            db.Drop("Transaction");
+        }
+
+        QueryFactory DB()
+        {
+            var cs = $"Data Source=file::memory:;Cache=Shared";
+
+            var connection = new SqliteConnection(cs);
+
+            var db = new QueryFactory(connection, new SqliteCompiler());
+
+            return db;
+        }
+
+
+
+    }
+}