-
Notifications
You must be signed in to change notification settings - Fork 858
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
53 changed files
with
11,771 additions
and
182 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
98 changes: 98 additions & 0 deletions
98
FreeSql.Tests/FreeSql.Tests.Provider.Duckdb/Duckdb/Curd/DuckdbDeleteTest.cs
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,98 @@ | ||
| using FreeSql.DataAnnotations; | ||
| using System; | ||
| using System.Collections.Generic; | ||
| using System.Linq; | ||
| using Xunit; | ||
|
|
||
| namespace FreeSql.Tests.Duckdb | ||
| { | ||
| public class DuckdbDeleteTest | ||
| { | ||
| IFreeSql fsql => g.duckdb; | ||
| IDelete<Topic> delete => fsql.Delete<Topic>(); | ||
|
|
||
| [Table(Name = "tb_topic_del")] | ||
| class Topic | ||
| { | ||
| [Column(IsIdentity = true, IsPrimary = true)] | ||
| public int Id { get; set; } | ||
| public int Clicks { get; set; } | ||
| public string Title { get; set; } | ||
| public DateTime CreateTime { get; set; } | ||
| } | ||
|
|
||
| [Fact] | ||
| public void Dywhere() | ||
| { | ||
| Assert.Null(fsql.Delete<Topic>().ToSql()); | ||
| var sql = fsql.Delete<Topic>(new[] { 1, 2 }).ToSql(); | ||
| Assert.Equal("DELETE FROM \"tb_topic_del\" WHERE (\"id\" IN (1,2))", sql); | ||
|
|
||
| sql = fsql.Delete<Topic>(new Topic { Id = 1, Title = "test" }).ToSql(); | ||
| Assert.Equal("DELETE FROM \"tb_topic_del\" WHERE (\"id\" = 1)", sql); | ||
|
|
||
| sql = fsql.Delete<Topic>(new[] { new Topic { Id = 1, Title = "test" }, new Topic { Id = 2, Title = "test" } }).ToSql(); | ||
| Assert.Equal("DELETE FROM \"tb_topic_del\" WHERE (\"id\" IN (1,2))", sql); | ||
|
|
||
| sql = fsql.Delete<Topic>(new { id = 1 }).ToSql(); | ||
| Assert.Equal("DELETE FROM \"tb_topic_del\" WHERE (\"id\" = 1)", sql); | ||
|
|
||
| sql = fsql.Delete<MultiPkTopic>(new[] { new { Id1 = 1, Id2 = 10 }, new { Id1 = 2, Id2 = 20 } }).ToSql(); | ||
| Assert.Equal("DELETE FROM \"multipktopic\" WHERE (\"id1\" = 1 AND \"id2\" = 10 OR \"id1\" = 2 AND \"id2\" = 20)", sql); | ||
| } | ||
| class MultiPkTopic | ||
| { | ||
| [Column(IsPrimary = true)] | ||
| public int Id1 { get; set; } | ||
| [Column(IsPrimary = true)] | ||
| public int Id2 { get; set; } | ||
| public int Clicks { get; set; } | ||
| public string Title { get; set; } | ||
| public DateTime CreateTime { get; set; } | ||
| } | ||
|
|
||
| [Fact] | ||
| public void Where() | ||
| { | ||
| var sql = delete.Where(a => a.Id == 1).ToSql().Replace("\r\n", ""); | ||
| Assert.Equal("DELETE FROM \"tb_topic_del\" WHERE (\"id\" = 1)", sql); | ||
|
|
||
| sql = delete.Where("id = @id", new { id = 1 }).ToSql().Replace("\r\n", ""); | ||
| Assert.Equal("DELETE FROM \"tb_topic_del\" WHERE (id = @id)", sql); | ||
|
|
||
| var item = new Topic { Id = 1, Title = "newtitle" }; | ||
| sql = delete.Where(item).ToSql().Replace("\r\n", ""); | ||
| Assert.Equal("DELETE FROM \"tb_topic_del\" WHERE (\"id\" = 1)", sql); | ||
|
|
||
| var items = new List<Topic>(); | ||
| for (var a = 0; a < 10; a++) items.Add(new Topic { Id = a + 1, Title = $"newtitle{a}", Clicks = a * 100 }); | ||
|
|
||
| sql = delete.Where(items).ToSql().Replace("\r\n", ""); | ||
| Assert.Equal("DELETE FROM \"tb_topic_del\" WHERE (\"id\" IN (1,2,3,4,5,6,7,8,9,10))", sql); | ||
| } | ||
| [Fact] | ||
| public void ExecuteAffrows() | ||
| { | ||
|
|
||
| var id = fsql.Insert<Topic>(new Topic { Title = "xxxx" }).ExecuteIdentity(); | ||
| Assert.Equal(1, delete.Where(a => a.Id == id).ExecuteAffrows()); | ||
| } | ||
|
|
||
| [Fact] | ||
| public void AsTable() | ||
| { | ||
| Assert.Null(fsql.Delete<Topic>().ToSql()); | ||
| var sql = fsql.Delete<Topic>(new[] { 1, 2 }).AsTable(a => "TopicAsTable").ToSql(); | ||
| Assert.Equal("DELETE FROM \"topicastable\" WHERE (\"id\" IN (1,2))", sql); | ||
|
|
||
| sql = fsql.Delete<Topic>(new Topic { Id = 1, Title = "test" }).AsTable(a => "TopicAsTable").ToSql(); | ||
| Assert.Equal("DELETE FROM \"topicastable\" WHERE (\"id\" = 1)", sql); | ||
|
|
||
| sql = fsql.Delete<Topic>(new[] { new Topic { Id = 1, Title = "test" }, new Topic { Id = 2, Title = "test" } }).AsTable(a => "TopicAsTable").ToSql(); | ||
| Assert.Equal("DELETE FROM \"topicastable\" WHERE (\"id\" IN (1,2))", sql); | ||
|
|
||
| sql = fsql.Delete<Topic>(new { id = 1 }).AsTable(a => "TopicAsTable").ToSql(); | ||
| Assert.Equal("DELETE FROM \"topicastable\" WHERE (\"id\" = 1)", sql); | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.