增加虚谷dbfirst

Author: BobLi-Net

FreeSql.Tests/FreeSql.Tests.Provider.Xugu/UnitDbFirst.cs

@@ -22,15 +22,20 @@ public void GetTablesByDatabase()
         public void GetTableByName()
         {
             var fsql = g.xugu;
-            var t1 = fsql.DbFirst.GetTableByName("GENERAL.system_log");
-            Assert.NotNull(t1);
+            fsql.CodeFirst.SyncStructure(typeof(test_existstb01));
+            var t1 = fsql.DbFirst.GetTableByName("test_existstb01"); 
+            Assert.NotNull(t1); 
+            Assert.True(t1.Columns.Count > 0);  
+            var t3 = fsql.DbFirst.GetTableByName("notexists_tb");
+            Assert.Null(t3);
+            fsql.Ado.ExecuteNonQuery("drop table test_existstb01");
         }
 
         [Fact]
         public void ExistsTable()
         {
             var fsql = g.xugu;
-            Assert.False(fsql.DbFirst.ExistsTable("GENERAL.system_log"));
+            Assert.False(fsql.DbFirst.ExistsTable("test_existstb01"));
             fsql.CodeFirst.SyncStructure(typeof(test_existstb01));
             Assert.True(fsql.DbFirst.ExistsTable("test_existstb01"));
             fsql.Ado.ExecuteNonQuery("drop table test_existstb01");

FreeSql/FreeSql.xml

@@ -442,14 +442,15 @@ from all_INDEXES a
                 {
                     sql = $@"
 select 
-schema_name || '.' || b.table_name as table_id,
-cons_name as FKId,
-cons_type,
-define
+c.schema_name || '.' || b.table_name as table_id,
+a.cons_name as FKId,
+a.cons_type,
+a.define, 
+(select c2.schema_name || '.' || b2.table_name  from all_tables as b2 left join  all_SCHEMAS as c2 on b2.SCHEMA_ID=c2.SCHEMA_ID where b2.TABLE_id=b.table_id) as ref_table_id
 from all_constraints as a
 left join all_tables as b on a.Table_ID=b.Table_ID
 left Join all_SCHEMAS AS c on b.SCHEMA_ID=c.SCHEMA_ID
-where  IS_SYS=false AND {loc8.ToString().Replace("a.table_name", "schema_name || '.' || b.table_name")}
+where  IS_SYS=false AND a.cons_type='F' AND {loc8.ToString().Replace("a.table_name", "schema_name || '.' || b.table_name")}
 ";
                     ds = _orm.Ado.ExecuteArray(CommandType.Text, sql);
                     if (ds == null) return loc1;
@@ -458,15 +459,31 @@ from all_constraints as a
                     foreach (object[] row in ds)
                     {
                         var table_id = string.Concat(row[0]);
-                        var column = row[3] as string[];
+                        var ref_table_id = string.Concat(row[4]);
+                        //var ref_table_id = row[4] as long?;
+                        //if (!ref_table_id.HasValue || ref_table_id < 1)
+                        //    continue;
+
+                        //loc2 是所有表信息
+
+                        if (!string.IsNullOrWhiteSpace(ref_table_id) || loc2.ContainsKey(ref_table_id?.ToString()) == false) continue;
+
+
+                        var column_temps = (row[3] as string)
+                            .Replace(")(", "|")
+                            .Replace("\"","")
+                            .Replace("(", "")
+                            .Replace(")", "")
+                            .Split('|');
+                        var column = column_temps[0].Split(',');
                         var fk_id = string.Concat(row[1]);
-                        var ref_table_id = string.Concat(row[0]);
-                        var is_foreign_key = string.Concat(row[2]) == "F";
-                        var referenced_column = row[5] as string[];
+                        
+                        //var is_foreign_key = string.Concat(row[2]) == "F"; 
+                        var referenced_column = column_temps[1].Split(',');
                         //var referenced_db = string.Concat(row[6]);
                         //var referenced_table = string.Concat(row[7]);
 
-                        if (loc2.ContainsKey(ref_table_id) == false) continue;
+
 
                         Dictionary<string, DbForeignInfo> loc12 = null;
                         DbForeignInfo loc13 = null;