mirror of
https://github.com/nsnail/FreeSql.git
synced 2025-04-30 14:32:50 +08:00
439 lines
16 KiB
C#
439 lines
16 KiB
C#
using FreeSql.DataAnnotations;
|
||
using Newtonsoft.Json;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.ComponentModel.DataAnnotations;
|
||
using System.Data;
|
||
using System.Linq;
|
||
using System.Text;
|
||
using Xunit;
|
||
|
||
namespace FreeSql.Tests.Dameng
|
||
{
|
||
public class DamengCodeFirstTest
|
||
{
|
||
[Fact]
|
||
public void InsertUpdateParameter()
|
||
{
|
||
var fsql = g.dameng;
|
||
fsql.CodeFirst.SyncStructure<ts_iupstr_bak>();
|
||
var item = new ts_iupstr { id = Guid.NewGuid(), title = string.Join(",", Enumerable.Range(0, 2000).Select(a => "ÎÒÊÇÖйúÈË")) };
|
||
Assert.Equal(1, fsql.Insert(item).ExecuteAffrows());
|
||
var find = fsql.Select<ts_iupstr>().Where(a => a.id == item.id).First();
|
||
Assert.NotNull(find);
|
||
Assert.Equal(find.id, item.id);
|
||
Assert.Equal(find.title, item.title);
|
||
}
|
||
[Table(Name = "ts_iupstr_bak", DisableSyncStructure = true)]
|
||
class ts_iupstr
|
||
{
|
||
public Guid id { get; set; }
|
||
public string title { get; set; }
|
||
}
|
||
class ts_iupstr_bak
|
||
{
|
||
public Guid id { get; set; }
|
||
[Column(StringLength = -1)]
|
||
public string title { get; set; }
|
||
}
|
||
|
||
[Fact]
|
||
public void StringLength36()
|
||
{
|
||
using (var conn = g.dameng.Ado.MasterPool.Get())
|
||
{
|
||
var cmd = conn.Value.CreateCommand();
|
||
cmd.CommandText = @"SELECT a.""ID"", a.""CREATORID""
|
||
FROM ""TS_SL361"" a
|
||
WHERE (a.""ID"" = 1) AND ROWNUM < 2";
|
||
using (var dr = cmd.ExecuteReader())
|
||
{
|
||
if (dr.Read())
|
||
{
|
||
var id1 = dr.GetInt64(0);
|
||
var creatorId1 = dr.GetString(1);
|
||
|
||
var id = dr.GetValue(0);
|
||
//var creatorId = dr.GetValue(1); //±¨´í
|
||
}
|
||
}
|
||
}
|
||
|
||
//var repo = g.dameng.GetRepository<TS_SL361, long>();
|
||
|
||
//var item1 = new TS_SL361 { CreatorId = "xxx '123 " };
|
||
//repo.Insert(item1);
|
||
//var item2 = repo.Get(item1.Id);
|
||
|
||
//Assert.Equal(item1.CreatorId, item2.CreatorId);
|
||
}
|
||
class TS_SL361
|
||
{
|
||
[Column(IsIdentity = true)]
|
||
public long Id { get; set; }
|
||
[Column(StringLength = 36)]
|
||
public string CreatorId { get; set; }
|
||
}
|
||
|
||
|
||
[Fact]
|
||
public void Text_StringLength_1()
|
||
{
|
||
var str1 = string.Join(",", Enumerable.Range(0, 10000).Select(a => "ÎÒÊÇÖйúÈË"));
|
||
|
||
var item1 = new TS_TEXT02 { Data = str1 };
|
||
Assert.Equal(1, g.dameng.Insert(item1).ExecuteAffrows());
|
||
|
||
var item2 = g.dameng.Select<TS_TEXT02>().Where(a => a.Id == item1.Id).First();
|
||
Assert.Equal(str1, item2.Data);
|
||
|
||
//NoneParameter
|
||
item1 = new TS_TEXT02 { Data = str1 };
|
||
Assert.Equal(1, g.dameng.Insert(item1).NoneParameter().ExecuteAffrows());
|
||
}
|
||
class TS_TEXT02
|
||
{
|
||
public Guid Id { get; set; }
|
||
[Column(StringLength = -1)]
|
||
public string Data { get; set; }
|
||
}
|
||
|
||
[Fact]
|
||
public void Text()
|
||
{
|
||
var str1 = string.Join(",", Enumerable.Range(0, 10000).Select(a => "ÎÒÊÇÖйúÈË"));
|
||
|
||
var item1 = new TS_TEXT01 { Data = str1 };
|
||
Assert.Equal(1, g.dameng.Insert(item1).ExecuteAffrows());
|
||
|
||
var item2 = g.dameng.Select<TS_TEXT01>().Where(a => a.Id == item1.Id).First();
|
||
Assert.Equal(str1, item2.Data);
|
||
|
||
//NoneParameter
|
||
item1 = new TS_TEXT01 { Data = str1 };
|
||
Assert.Equal(1, g.dameng.Insert(item1).NoneParameter().ExecuteAffrows());
|
||
}
|
||
class TS_TEXT01
|
||
{
|
||
public Guid Id { get; set; }
|
||
[Column(DbType = "text")]
|
||
public string Data { get; set; }
|
||
}
|
||
[Fact]
|
||
public void Blob()
|
||
{
|
||
var str1 = string.Join(",", Enumerable.Range(0, 10000).Select(a => "ÎÒÊÇÖйúÈË"));
|
||
var data1 = Encoding.UTF8.GetBytes(str1);
|
||
|
||
var item1 = new TS_BLB01 { Data = data1 };
|
||
Assert.Equal(1, g.dameng.Insert(item1).ExecuteAffrows());
|
||
|
||
var item2 = g.dameng.Select<TS_BLB01>().Where(a => a.Id == item1.Id).First();
|
||
Assert.Equal(item1.Data.Length, item2.Data.Length);
|
||
|
||
var str2 = Encoding.UTF8.GetString(item2.Data);
|
||
Assert.Equal(str1, str2);
|
||
|
||
//NoneParameter
|
||
item1 = new TS_BLB01 { Data = data1 };
|
||
Assert.Throws<Exception>(() => g.dameng.Insert(item1).NoneParameter().ExecuteAffrows());
|
||
//DmException: ×Ö·û´®½Ø¶Ï
|
||
}
|
||
class TS_BLB01
|
||
{
|
||
public Guid Id { get; set; }
|
||
[MaxLength(-1)]
|
||
public byte[] Data { get; set; }
|
||
}
|
||
[Fact]
|
||
public void StringLength()
|
||
{
|
||
var dll = g.dameng.CodeFirst.GetComparisonDDLStatements<TS_SLTB>();
|
||
g.dameng.CodeFirst.SyncStructure<TS_SLTB>();
|
||
}
|
||
class TS_SLTB
|
||
{
|
||
public Guid Id { get; set; }
|
||
[Column(StringLength = 50)]
|
||
public string Title { get; set; }
|
||
|
||
[Column(IsNullable = false, StringLength = 50)]
|
||
public string TitleSub { get; set; }
|
||
}
|
||
|
||
[Fact]
|
||
public void Êý×Ö±í_×Ö¶Î()
|
||
{
|
||
var sql = g.dameng.CodeFirst.GetComparisonDDLStatements<²âÊÔÊý×Ö±í>();
|
||
g.dameng.CodeFirst.SyncStructure<²âÊÔÊý×Ö±í>();
|
||
|
||
var item = new ²âÊÔÊý×Ö±í
|
||
{
|
||
±êÌâ = "²âÊÔ±êÌâ",
|
||
´´½¨Ê±¼ä = DateTime.Now
|
||
};
|
||
Assert.Equal(1, g.dameng.Insert<²âÊÔÊý×Ö±í>().AppendData(item).ExecuteAffrows());
|
||
Assert.NotEqual(Guid.Empty, item.񅧏);
|
||
var item2 = g.dameng.Select<²âÊÔÊý×Ö±í>().Where(a => a.±àºÅ == item.±àºÅ).First();
|
||
Assert.NotNull(item2);
|
||
Assert.Equal(item.񅧏, item2.񅧏);
|
||
Assert.Equal(item.±êÌâ, item2.±êÌâ);
|
||
|
||
item.±êÌâ = "²âÊÔ±êÌâ¸üÐÂ";
|
||
Assert.Equal(1, g.dameng.Update<²âÊÔÊý×Ö±í>().SetSource(item).ExecuteAffrows());
|
||
item2 = g.dameng.Select<²âÊÔÊý×Ö±í>().Where(a => a.±àºÅ == item.±àºÅ).First();
|
||
Assert.NotNull(item2);
|
||
Assert.Equal(item.񅧏, item2.񅧏);
|
||
Assert.Equal(item.±êÌâ, item2.±êÌâ);
|
||
|
||
item.±êÌâ = "²âÊÔ±êÌâ¸üÐÂ_repo";
|
||
var repo = g.dameng.GetRepository<²âÊÔÊý×Ö±í>();
|
||
Assert.Equal(1, repo.Update(item));
|
||
item2 = g.dameng.Select<²âÊÔÊý×Ö±í>().Where(a => a.±àºÅ == item.±àºÅ).First();
|
||
Assert.NotNull(item2);
|
||
Assert.Equal(item.񅧏, item2.񅧏);
|
||
Assert.Equal(item.±êÌâ, item2.±êÌâ);
|
||
|
||
item.±êÌâ = "²âÊÔ±êÌâ¸üÐÂ_repo22";
|
||
Assert.Equal(1, repo.Update(item));
|
||
item2 = g.dameng.Select<²âÊÔÊý×Ö±í>().Where(a => a.±àºÅ == item.±àºÅ).First();
|
||
Assert.NotNull(item2);
|
||
Assert.Equal(item.񅧏, item2.񅧏);
|
||
Assert.Equal(item.±êÌâ, item2.±êÌâ);
|
||
}
|
||
[Table(Name = "123²âÊÔÊý×Ö±í")]
|
||
class ²âÊÔÊý×Ö±í
|
||
{
|
||
[Column(IsPrimary = true, Name = "123񅧏")]
|
||
public Guid 񅧏 { get; set; }
|
||
|
||
[Column(Name = "123±êÌâ")]
|
||
public string ±êÌâ { get; set; }
|
||
|
||
[Column(Name = "123´´½¨Ê±¼ä")]
|
||
public DateTime ´´½¨Ê±¼ä { get; set; }
|
||
}
|
||
|
||
[Fact]
|
||
public void ÖÐÎıí_×Ö¶Î()
|
||
{
|
||
var sql = g.dameng.CodeFirst.GetComparisonDDLStatements<²âÊÔÖÐÎıí>();
|
||
g.dameng.CodeFirst.SyncStructure<²âÊÔÖÐÎıí>();
|
||
|
||
var item = new ²âÊÔÖÐÎıí
|
||
{
|
||
±êÌâ = "²âÊÔ±êÌâ",
|
||
´´½¨Ê±¼ä = DateTime.Now
|
||
};
|
||
Assert.Equal(1, g.dameng.Insert<²âÊÔÖÐÎıí>().AppendData(item).ExecuteAffrows());
|
||
Assert.NotEqual(Guid.Empty, item.񅧏);
|
||
var item2 = g.dameng.Select<²âÊÔÖÐÎıí>().Where(a => a.±àºÅ == item.±àºÅ).First();
|
||
Assert.NotNull(item2);
|
||
Assert.Equal(item.񅧏, item2.񅧏);
|
||
Assert.Equal(item.±êÌâ, item2.±êÌâ);
|
||
|
||
item.±êÌâ = "²âÊÔ±êÌâ¸üÐÂ";
|
||
Assert.Equal(1, g.dameng.Update<²âÊÔÖÐÎıí>().SetSource(item).ExecuteAffrows());
|
||
item2 = g.dameng.Select<²âÊÔÖÐÎıí>().Where(a => a.±àºÅ == item.±àºÅ).First();
|
||
Assert.NotNull(item2);
|
||
Assert.Equal(item.񅧏, item2.񅧏);
|
||
Assert.Equal(item.±êÌâ, item2.±êÌâ);
|
||
|
||
item.±êÌâ = "²âÊÔ±êÌâ¸üÐÂ_repo";
|
||
var repo = g.dameng.GetRepository<²âÊÔÖÐÎıí>();
|
||
Assert.Equal(1, repo.Update(item));
|
||
item2 = g.dameng.Select<²âÊÔÖÐÎıí>().Where(a => a.±àºÅ == item.±àºÅ).First();
|
||
Assert.NotNull(item2);
|
||
Assert.Equal(item.񅧏, item2.񅧏);
|
||
Assert.Equal(item.±êÌâ, item2.±êÌâ);
|
||
|
||
item.±êÌâ = "²âÊÔ±êÌâ¸üÐÂ_repo22";
|
||
Assert.Equal(1, repo.Update(item));
|
||
item2 = g.dameng.Select<²âÊÔÖÐÎıí>().Where(a => a.±àºÅ == item.±àºÅ).First();
|
||
Assert.NotNull(item2);
|
||
Assert.Equal(item.񅧏, item2.񅧏);
|
||
Assert.Equal(item.±êÌâ, item2.±êÌâ);
|
||
}
|
||
class ²âÊÔÖÐÎıí
|
||
{
|
||
[Column(IsPrimary = true)]
|
||
public Guid 񅧏 { get; set; }
|
||
|
||
public string ±êÌâ { get; set; }
|
||
|
||
public DateTime ´´½¨Ê±¼ä { get; set; }
|
||
}
|
||
|
||
[Fact]
|
||
public void AddUniques()
|
||
{
|
||
var sql = g.dameng.CodeFirst.GetComparisonDDLStatements<AddUniquesInfo>();
|
||
g.dameng.CodeFirst.SyncStructure<AddUniquesInfo>();
|
||
g.dameng.CodeFirst.SyncStructure(typeof(AddUniquesInfo), "AddUniquesInf1");
|
||
}
|
||
[Table(Name = "AddUniquesInf", OldName = "AddUniquesInfo2")]
|
||
[Index("{tablename}_uk_phone", "phone", true)]
|
||
[Index("{tablename}_uk_group_index", "group,index", true)]
|
||
[Index("{tablename}_uk_group_index22", "group, index22", true)]
|
||
class AddUniquesInfo
|
||
{
|
||
public Guid id { get; set; }
|
||
public string phone { get; set; }
|
||
|
||
public string group { get; set; }
|
||
public int index { get; set; }
|
||
public string index22 { get; set; }
|
||
}
|
||
[Fact]
|
||
public void AddField()
|
||
{
|
||
var sql = g.dameng.CodeFirst.GetComparisonDDLStatements<TopicAddField>();
|
||
|
||
var id = g.dameng.Insert<TopicAddField>().AppendData(new TopicAddField { }).ExecuteIdentity();
|
||
|
||
//var inserted = g.dameng.Insert<TopicAddField>().AppendData(new TopicAddField { }).ExecuteInserted();
|
||
}
|
||
|
||
[Table(Name = "TopicAddField", OldName = "xxxtb.TopicAddField")]
|
||
public class TopicAddField
|
||
{
|
||
[Column(IsIdentity = true)]
|
||
public int Id { get; set; }
|
||
|
||
public string name { get; set; }
|
||
|
||
[Column(DbType = "varchar2(200) not null", OldName = "title")]
|
||
public string title2 { get; set; } = "10";
|
||
|
||
[Column(IsIgnore = true)]
|
||
public DateTime ct { get; set; } = DateTime.Now;
|
||
}
|
||
|
||
[Fact]
|
||
public void GetComparisonDDLStatements()
|
||
{
|
||
var sql = g.dameng.CodeFirst.GetComparisonDDLStatements<TableAllType>();
|
||
Assert.True(string.IsNullOrEmpty(sql)); //²âÊÔÔËÐÐÁ½´Îºó
|
||
//sql = g.dameng.CodeFirst.GetComparisonDDLStatements<Tb_alltype>();
|
||
}
|
||
|
||
IInsert<TableAllType> insert => g.dameng.Insert<TableAllType>();
|
||
ISelect<TableAllType> select => g.dameng.Select<TableAllType>();
|
||
|
||
[Fact]
|
||
public void CurdAllField()
|
||
{
|
||
g.dameng.Delete<TableAllType>().Where("1=1").ExecuteAffrows();
|
||
var item2 = new TableAllType
|
||
{
|
||
Bool = true,
|
||
BoolNullable = true,
|
||
Byte = 255,
|
||
ByteNullable = 127,
|
||
Bytes = Encoding.UTF8.GetBytes("ÎÒÊÇÖйúÈË"),
|
||
DateTime = DateTime.Now,
|
||
DateTimeNullable = DateTime.Now.AddHours(-1),
|
||
Decimal = 99.99M,
|
||
DecimalNullable = 99.98M,
|
||
Double = 999.99,
|
||
DoubleNullable = 999.98,
|
||
Enum1 = TableAllTypeEnumType1.e5,
|
||
Enum1Nullable = TableAllTypeEnumType1.e3,
|
||
Enum2 = TableAllTypeEnumType2.f2,
|
||
Enum2Nullable = TableAllTypeEnumType2.f3,
|
||
Float = 19.99F,
|
||
FloatNullable = 19.98F,
|
||
Guid = Guid.NewGuid(),
|
||
GuidNullable = Guid.NewGuid(),
|
||
Int = int.MaxValue,
|
||
IntNullable = int.MinValue,
|
||
SByte = 100,
|
||
SByteNullable = 99,
|
||
Short = short.MaxValue,
|
||
ShortNullable = short.MinValue,
|
||
String = "ÎÒÊÇÖйúÈËstring'\\?!@#$%^&*()_+{}}{~?><<>",
|
||
Char = 'X',
|
||
TimeSpan = TimeSpan.FromSeconds(999),
|
||
TimeSpanNullable = TimeSpan.FromSeconds(60),
|
||
UInt = uint.MaxValue,
|
||
UIntNullable = uint.MinValue,
|
||
ULong = ulong.MaxValue,
|
||
ULongNullable = ulong.MinValue,
|
||
UShort = ushort.MaxValue,
|
||
UShortNullable = ushort.MinValue,
|
||
testFielLongNullable = long.MinValue
|
||
};
|
||
var sqlPar = insert.AppendData(item2).ToSql();
|
||
var sqlText = insert.AppendData(item2).NoneParameter().ToSql();
|
||
var item3NP = insert.AppendData(item2).NoneParameter().ExecuteIdentity();
|
||
|
||
item2.Id = (int)insert.AppendData(item2).ExecuteIdentity();
|
||
var newitem2 = select.Where(a => a.Id == item2.Id).ToOne();
|
||
Assert.Equal(item2.String, newitem2.String);
|
||
Assert.Equal(item2.Char, newitem2.Char);
|
||
|
||
item2.Id = (int)insert.NoneParameter().AppendData(item2).ExecuteIdentity();
|
||
newitem2 = select.Where(a => a.Id == item2.Id).ToOne();
|
||
Assert.Equal(item2.String, newitem2.String);
|
||
Assert.Equal(item2.Char, newitem2.Char);
|
||
|
||
var items = select.ToList();
|
||
var itemstb = select.ToDataTable();
|
||
}
|
||
|
||
[Table(Name = "tb_alltype")]
|
||
class TableAllType
|
||
{
|
||
[Column(IsIdentity = true, IsPrimary = true)]
|
||
public int Id { get; set; }
|
||
|
||
public string id2 { get; set; } = "id2=10";
|
||
|
||
public bool Bool { get; set; }
|
||
public sbyte SByte { get; set; }
|
||
public short Short { get; set; }
|
||
public int Int { get; set; }
|
||
public long Long { get; set; }
|
||
public byte Byte { get; set; }
|
||
public ushort UShort { get; set; }
|
||
public uint UInt { get; set; }
|
||
public ulong ULong { get; set; }
|
||
public double Double { get; set; }
|
||
public float Float { get; set; }
|
||
public decimal Decimal { get; set; }
|
||
public TimeSpan TimeSpan { get; set; }
|
||
public DateTime DateTime { get; set; }
|
||
public DateTime DateTimeOffSet { get; set; }
|
||
public byte[] Bytes { get; set; }
|
||
public string String { get; set; }
|
||
public char Char { get; set; }
|
||
public Guid Guid { get; set; }
|
||
|
||
public bool? BoolNullable { get; set; }
|
||
public sbyte? SByteNullable { get; set; }
|
||
public short? ShortNullable { get; set; }
|
||
public int? IntNullable { get; set; }
|
||
public long? testFielLongNullable { get; set; }
|
||
public byte? ByteNullable { get; set; }
|
||
public ushort? UShortNullable { get; set; }
|
||
public uint? UIntNullable { get; set; }
|
||
public ulong? ULongNullable { get; set; }
|
||
public double? DoubleNullable { get; set; }
|
||
public float? FloatNullable { get; set; }
|
||
public decimal? DecimalNullable { get; set; }
|
||
public TimeSpan? TimeSpanNullable { get; set; }
|
||
public DateTime? DateTimeNullable { get; set; }
|
||
public DateTime? DateTimeOffSetNullable { get; set; }
|
||
public Guid? GuidNullable { get; set; }
|
||
|
||
public TableAllTypeEnumType1 Enum1 { get; set; }
|
||
public TableAllTypeEnumType1? Enum1Nullable { get; set; }
|
||
public TableAllTypeEnumType2 Enum2 { get; set; }
|
||
public TableAllTypeEnumType2? Enum2Nullable { get; set; }
|
||
}
|
||
|
||
public enum TableAllTypeEnumType1 { e1, e2, e3, e5 }
|
||
[Flags] public enum TableAllTypeEnumType2 { f1, f2, f3 }
|
||
}
|
||
}
|