高效的一对多SQL查询

本文关键字:查询 SQL 一对多 高效 | 更新日期: 2023-09-27 18:13:20

我正在编写一个应用程序,该应用程序使用数据库来存储应用程序及其所依赖的系统。我使用微软Access数据库来存储我的信息。我的应用程序是在vs2013中使用c#编写的,使用OleDbCommand和OleDbDataReader与数据库进行交互。

当我在数据库中存储一个应用程序时,它可以有任意数量的它所依赖的系统。为了增加"乐趣",每个系统也可以有任意数量的屏幕,每个屏幕可以或不可以被使用该系统的应用程序使用,每个屏幕可以有任意数量的字段。我使用一对多表跟踪这两种情况,如下面的模拟模式所示:

AppTable
| ID | Name | 
SystemTable
| ID | Name |
AppToSystemTable
| AppID | SystemID |
ScreenTable
| ID | NAME | SystemID | 
AppToScreenTable
| AppID | ScreenID |
FieldTable
| ID | Name | ScreenID |
AppToFieldTable
| AppID | FieldID |

现在,我可以成功地读取应用程序的所有数据,但是效率非常低。首先,我查询AppTable以获取只有一个值的属性,然后将它们存储到我的App对象中。然后,我查询我的一对多表,以获得我需要的id列表。然后,我查询SystemTable以构建应用程序的系统列表。我查询screenable和FieldTable,并构建屏幕和字段的字典,以跟踪哪个系统/屏幕是它的父系统/屏幕。总而言之,我使用7个查询只是为了获得我的系统列表!这很糟糕,我知道。

我要问的是我如何重构我的查询更有效地做到这一点?我希望只查询一个问题,但我不知道这是否可能。我已经研究过join,我可以看到它们可以帮助立即获得系统、屏幕和字段,而无需捕获id的中间步骤,但是我不知道如何更有效地查询每个应用程序的X系统、Y屏幕和Z字段。谁能提出一些方法来有效地查询一对多关系?

编辑

按要求,这里是我当前的查询。我知道它们不是按照典型的c#风格构建的,但那是因为这是我用c#做的第一个项目,我一直在学习。

*注意

实际的App对象比示例模式中显示的要复杂得多。这被简化了,以隔离我的问题中我感到困惑的一对多部分。

还要注意,对GetLanguage(langId)GetDeveloper(oridDevId)或其他属性的调用都调用一个简单的方法来从数据库中读取该属性是什么。其中许多是自定义对象。我不担心如何清理这些。我正在从我已经得到的答案和其他来源中找到答案。我只是还没有重写它们。这正在发生。

internal static App GetApp(int id)
    {
        App app = new App("");
        int langId = -1, origDevId = -1, mainDevId = -1, updateId = -1;
        List<SystemObj> systemList = new List<SystemObj>();
        bool wasOpen = true;
        try
        {
            // Get app core info.
            StringBuilder appSql = new StringBuilder();
            appSql.Append("SELECT " + DbContract.Apps.NAME + "," + DbContract.Apps.ORIGINAL_DEV_ID + 
                "," + DbContract.Apps.LANGUAGE_ID + "," + DbContract.Apps.MAINTENANCE_DEV_ID + "," + 
                DbContract.Apps.DEACTIVATION_DATE + "," + DbContract.Apps.DEPLOYMENT_METHOD + "," + 
                DbContract.Apps.UPDATE_ID + " FROM " + DbContract.Apps.TABLE + " WHERE " + 
                DbContract.Apps.ID + "=" + id);
            if (readConn.State == System.Data.ConnectionState.Closed)
            {
                wasOpen = false;
                open(readConn);
            }
            OleDbCommand appCommand = new OleDbCommand(appSql.ToString(), readConn);
            OleDbDataReader reader = appCommand.ExecuteReader();
            reader.Read();
            int appOrd = reader.GetOrdinal(DbContract.Apps.NAME);
            int langOrd = reader.GetOrdinal(DbContract.Apps.LANGUAGE_ID);
            int origDevOrd = reader.GetOrdinal(DbContract.Apps.ORIGINAL_DEV_ID);
            int mainDevOrd = reader.GetOrdinal(DbContract.Apps.MAINTENANCE_DEV_ID);
            int updateOrd = reader.GetOrdinal(DbContract.Apps.UPDATE_ID);
            int deployOrd = reader.GetOrdinal(DbContract.Apps.DEPLOYMENT_METHOD);
            int deactiveOrd = reader.GetOrdinal(DbContract.Apps.DEACTIVATION_DATE);
            app = new App(reader.GetString(appOrd), id);
            langId = reader.GetInt32(langOrd);
            origDevId = reader.GetInt32(origDevOrd);
            mainDevId = reader.GetInt32(mainDevOrd);
            updateId = reader.GetInt32(updateOrd);
            app.DeploymentMethod = reader.GetValue(deployOrd).ToString();
            app.DeactivationDate = reader.GetValue(deactiveOrd).ToString();
            reader.Close();
            if (!wasOpen) { close(readConn); }
            // Get app Language.
            app.Language = GetLanguage(langId);
            // Get app Developers.
            app.OriginalDeveloper = GetDeveloper(origDevId);
            app.MaintainingDeveloper = GetDeveloper(mainDevId);
            // Get app Update.
            app.LastUpdate = GetUpdate(updateId);
            // Get ids for app systems, screens & fields.
            List<int> sysIds = new List<int>();
            List<int> screenIds = new List<int>();
            List<int> fieldIds = new List<int>();
            if (!wasOpen) { open(readConn); }
            string appToSysSql = "SELECT " + DbContract.Apps.Systems.SYSTEM_ID + " FROM " +
                DbContract.Apps.Systems.TABLE + " WHERE " + DbContract.Apps.Systems.APP_ID +
                "=" + id;
            OleDbCommand appToSysCommand = new OleDbCommand(appToSysSql, readConn);
            reader = appToSysCommand.ExecuteReader();
            while (reader.Read())
            {
                sysIds.Add(reader.GetInt32(0));
            }
            reader.Close();
            string appToScreenSql = "SELECT " + DbContract.Apps.Screens.SCREEN_ID + " FROM " +
                DbContract.Apps.Screens.TABLE + " WHERE " + DbContract.Apps.Screens.APP_ID +
                "=" + id;
            OleDbCommand appToScreenCommand = new OleDbCommand(appToScreenSql, readConn);
            reader = appToScreenCommand.ExecuteReader();
            while (reader.Read())
            {
                screenIds.Add(reader.GetInt32(0));
            }
            reader.Close();
            string appToFieldSql = "SELECT " + DbContract.Apps.Fields.FIELD_ID + " FROM " +
                DbContract.Apps.Fields.TABLE + " WHERE " + DbContract.Apps.Fields.APP_ID +
                "=" + id;
            OleDbCommand appToFieldCommand = new OleDbCommand(appToFieldSql, readConn);
            reader = appToFieldCommand.ExecuteReader();
            while (reader.Read())
            {
                fieldIds.Add(reader.GetInt32(0));
            }
            reader.Close();
            if (!wasOpen) { close(readConn); }
            List<SystemObj> sysList = GetSystems(sysIds);
            Dictionary<Screen, int> scrnDict = GetScreens(screenIds);
            Dictionary<Field, int> fldDict = GetFields(fieldIds);
            foreach (SystemObj sys in sysList)
            {
                if (scrnDict.Values.Contains(sys.Id))
                {
                    foreach (Screen scrn in scrnDict.Keys)
                    {
                        if (scrnDict[scrn] == sys.Id)
                        {
                            sys.AddScreen(scrn);
                            if (fldDict.Values.Contains(scrn.Id))
                            {
                                foreach (Field fld in fldDict.Keys)
                                {
                                    if (fldDict[fld] == scrn.Id)
                                    {
                                        scrn.AddField(fld);
                                    }
                                }
                            }
                        }
                    }
                }
            }
            app.SystemList = sysList;
        } catch (Exception e)
        {
            if (!wasOpen) { close(readConn); }
            LogWriter.Log(e, DateTime.Now);
        }
        return app;
    }

我相信你可以看到这里有很多优化的空间。我刚开始只是让它工作;

高效的一对多SQL查询

我可能误解了您的问题,因为这看起来相对简单——为什么不创建一个单一的查询,作为包含所有数据的"平面文件"?

试试这样写:

SELECT AppTable.Name AS AppName, SystemTable.Name AS SystemName, ScreenTable.NAME AS ScreenName, FieldTable.Name AS FieldName
FROM (((((AppTable INNER JOIN AppToSystemTable ON AppTable.ID = AppToSystemTable.AppID) INNER JOIN SystemTable ON AppToSystemTable.SystemID = SystemTable.ID) INNER JOIN AppToScreenTable ON AppTable.ID = AppToScreenTable.AppID) INNER JOIN ScreenTable ON (ScreenTable.SystemID = SystemTable.ID) AND (AppToScreenTable.ScreenID = ScreenTable.ID)) INNER JOIN ApptoFieldTable ON AppTable.ID = ApptoFieldTable.AppID) INNER JOIN FieldTable ON ApptoFieldTable.FieldID = FieldTable.ID;

我相信我在这里正确地连接了所有的id(并且我为Name字段分配了别名,因此您可以实际告诉它们属于哪个表)。