|
1 | | -using Densen.Models.ids; |
| 1 | +using Confluent.Kafka; |
| 2 | +using Densen.Models.ids; |
2 | 3 | using FreeSql; |
3 | 4 | using FreeSql.DataAnnotations; |
4 | 5 | using FreeSql.Extensions; |
@@ -566,8 +567,8 @@ static void Main(string[] args) |
566 | 567 | ////.UseConnectionString(FreeSql.DataType.PostgreSQL, "Host=192.168.164.10;Port=5432;Username=postgres;Password=123456;Database=toc;Pooling=true;Maximum Pool Size=2") |
567 | 568 | //.UseNameConvert(FreeSql.Internal.NameConvertType.ToLower) |
568 | 569 |
|
569 | | - //.UseConnectionString(FreeSql.DataType.Oracle, "user=user1;password=123456;data source=//127.0.0.1:1521/XE;Pooling=true;Max Pool Size=2") |
570 | | - //.UseNameConvert(FreeSql.Internal.NameConvertType.ToUpper) |
| 570 | + .UseConnectionString(FreeSql.DataType.Oracle, "user id=user1;password=123456;data source=//127.0.0.1:1521/XE;Pooling=true;Max Pool Size=2") |
| 571 | + .UseNameConvert(FreeSql.Internal.NameConvertType.ToUpper) |
571 | 572 |
|
572 | 573 | //.UseConnectionString(FreeSql.DataType.Dameng, "server=127.0.0.1;port=5236;user=2user;password=123456789;database=2user;poolsize=5;") |
573 | 574 | //.UseNameConvert(FreeSql.Internal.NameConvertType.ToUpper) |
@@ -599,6 +600,18 @@ static void Main(string[] args) |
599 | 600 | BaseEntity.Initialization(fsql, () => _asyncUow.Value); |
600 | 601 | #endregion |
601 | 602 |
|
| 603 | + var lstKafka = fsql.Ado.Query<ProducerModel_Kafka>("SELECT 123 AS ID,'10.0.0.0' AS IP FROM dual "); |
| 604 | + |
| 605 | + |
| 606 | + |
| 607 | + |
| 608 | + |
| 609 | + |
| 610 | + |
| 611 | + var subsql01 = fsql.Select<User1>().Where(a => |
| 612 | + fsql.Select<UserGroup>().Where(b => b.Id == a.GroupId).Max(b => b.CreateTime) > DateTime.Now) |
| 613 | + .ToSql(); |
| 614 | + |
602 | 615 | var cccsql1 = fsql.Select<CCC>().Page(1, 10).ToSql(); |
603 | 616 | var cccsql2 = fsql.Select<CCC>().Page(2, 10).ToSql(); |
604 | 617 |
|
@@ -2525,4 +2538,24 @@ class pgjson_copy001 |
2525 | 2538 | public Guid id { get; set; } |
2526 | 2539 | public JObject json { get; set; } |
2527 | 2540 | } |
| 2541 | + public class ProducerModel_Kafka |
| 2542 | + { |
| 2543 | + /// <summary> |
| 2544 | + /// 这个可以 |
| 2545 | + /// </summary> |
| 2546 | + public IProducer<string, string> Sender { get; set; } |
| 2547 | + /// <summary> |
| 2548 | + /// ID |
| 2549 | + /// </summary> |
| 2550 | + public long ID { get; set; } |
| 2551 | + /// <summary> |
| 2552 | + /// IP |
| 2553 | + /// </summary> |
| 2554 | + public string IP { get; set; } |
| 2555 | + |
| 2556 | + /// <summary> |
| 2557 | + /// 这个不行 |
| 2558 | + /// </summary> |
| 2559 | + public ProducerConfig PConfig { get; set; } |
| 2560 | + } |
2528 | 2561 | } |
0 commit comments