Click here to Skip to main content
15,881,882 members
Articles / Database Development / SQL Server

A Model to Represent Directed Acyclic Graphs (DAG) on SQL Databases

Rate me:
Please Sign up or sign in to vote.
4.97/5 (50 votes)
26 Jan 2021CPOL20 min read 299.8K   9   114  
Addressing the general problem of representing directed acyclic graphs (DAGs) in SQL databases
The use of the adjacency list method, augmented with addition of transitive closure rows, enables standard SQL to be used with a model of Directed Acyclic Graphs. However, some additional disk space and additional insertion time are required.
#region copyright

// Copyright (C) 2008 Kemal ERDOGAN
// 
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU Lesser General Public License as published by
// the Free Software Foundation, version 3 of the License.
// 
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU Lesser General Public License for more details.
// 
// You should have received a copy of the GNU Lesser General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.

#endregion

namespace ADSync.Utils {
    using System;
    using System.Collections;
    using System.Collections.Generic;
    using System.Collections.Specialized;
    using System.Diagnostics.CodeAnalysis;
    using System.DirectoryServices;
    using Afcas.Objects;
    using Objects;

    /// <summary>
    /// Helper class for Active directory access
    /// </summary>
    internal static class ADHelper {
        #region active directory user property names

        private const string DESCRIPTION = "description";
        private const string DISPLAY_NAME = "displayName";

        private const string EMAIL_ADDRESS = "mail";
        private const string GROUPS = "memberOf";
        private const string PRINCIPAL_NAME = "sAMAccountName";

        #endregion

        [ SuppressMessage( "Microsoft.Design", "CA1031:DoNotCatchGeneralExceptionTypes" ) ]
        public static IList< ADPrincipal > FetchADPrincipals( StringCollection ldapPathList ) {
            IList< ADPrincipal > ret = new List< ADPrincipal >( );

            foreach( string path in ldapPathList ) {
                using( DirectoryEntry root = LoadDirectoryEntry( path ) ) {
                    if( root == null ) {
                        Console.WriteLine( "Skipping DirectoryEntry {0} as it cannot be load", path );
                        continue;
                    }
                    using( DirectorySearcher src = new DirectorySearcher( root ) ) {
                        src.Filter = "(|(&(objectCategory=person)(objectClass=user))(objectCategory=group))";
                        src.SecurityMasks = SecurityMasks.None;
                        src.PageSize = 16;
                        using( SearchResultCollection res = src.FindAll( ) ) {
                            foreach( SearchResult sr in res ) {
                                using( DirectoryEntry de = sr.GetDirectoryEntry( ) ) {
                                    try {
                                        ret.Add( ConstructADPrincipal( de ) );
                                    } catch( Exception ex ) {
                                        Console.WriteLine( "ERROR: while reading data from Active Directory, current item: " );
                                        Console.WriteLine( de.Path );
                                        Console.WriteLine( Environment.NewLine );
                                        Console.WriteLine( ex.Message );
                                    }
                                }
                            }
                        }
                    }
                }
            }
            return ret;
        }

        private static ADPrincipal ConstructADPrincipal( DirectoryEntry de ) {
            string id = de.Guid.ToString( );
            string name = ( string )de.Properties[ PRINCIPAL_NAME ].Value;
            string adPath = de.Path.Replace( "LDAP://", "" );
            PrincipalType type = de.SchemaClassName.Equals( "group", StringComparison.OrdinalIgnoreCase )
                                         ? PrincipalType.Group
                                         : PrincipalType.User;
            string email = ( string )de.Properties[ EMAIL_ADDRESS ].Value ?? "";
            string displayName = ( string )de.Properties[ DISPLAY_NAME ].Value ?? "";
            string description = ( string )de.Properties[ DESCRIPTION ].Value ?? "";

            IList grpl = de.Properties[ GROUPS ];
            string[ ] groups;
            if( grpl != null ) {
                groups = new string[grpl.Count];
                grpl.CopyTo( groups, 0 );
            } else {
                groups = new string[0];
            }
            return new ADPrincipal( id, name, adPath, type, email, displayName, description, groups );
        }

        private static DirectoryEntry LoadDirectoryEntry( string path ) {
            DirectoryEntry res = new DirectoryEntry( path );

            try {
                return null == res.NativeGuid ? null : res;
                // will cause an exception if not found
            } catch( DirectoryServicesCOMException ex ) {
                if( ex.ExtendedError != 8333 ) {
                    throw;
                }
                return null;
            }
        }
    }
}

By viewing downloads associated with this article you agree to the Terms of Service and the article's licence.

If a file you wish to view isn't highlighted, and is a text file (not binary), please let us know and we'll add colourisation support for it.

License

This article, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)


Written By
France France
This member has not yet provided a Biography. Assume it's interesting and varied, and probably something to do with programming.

Comments and Discussions