sql >> Databasteknik >  >> NoSQL >> MongoDB

Hur dekorerar man ett klassobjekt för att vara ett index och får samma sak som att använda sureIndex?

Jag tycker att det här är en bra idé, men du måste göra det här själv, det finns inget inbyggt stöd för det. Om du har ett åtkomstlager kan du göra det där. Du skulle behöva en attributklass, något sånt här;

public enum IndexConstraints
{
    Normal     = 0x00000001, // Ascending, non-indexed
    Descending = 0x00000010,
    Unique     = 0x00000100,
    Sparse     = 0x00001000, // allows nulls in the indexed fields
}

// Applied to a member
[AttributeUsage(AttributeTargets.Property | AttributeTargets.Field)]
public class EnsureIndexAttribute : EnsureIndexes
{
    public EnsureIndex(IndexConstraints ic = IndexConstraints.Normal) : base(ic) { }
}

// Applied to a class
[AttributeUsage(AttributeTargets.Class)]
public class EnsureIndexesAttribute : Attribute
{
    public bool Descending { get; private set; }
    public bool Unique { get; private set; }
    public bool Sparse { get; private set; }
    public string[] Keys { get; private set; }

    public EnsureIndexes(params string[] keys) : this(IndexConstraints.Normal, keys) {}
    public EnsureIndexes(IndexConstraints ic, params string[] keys)
    {
        this.Descending = ((ic & IndexConstraints.Descending) != 0);
        this.Unique = ((ic & IndexConstraints.Unique) != 0); ;
        this.Sparse = ((ic & IndexConstraints.Sparse) != 0); ;
        this.Keys = keys;
    }

}//class EnsureIndexes

Du kan sedan tillämpa attribut på antingen klass- eller medlemsnivå enligt följande. Jag upptäckte att det var mindre sannolikt att lägga till på medlemsnivå att det skulle hamna ur synk med schemat jämfört med att lägga till på klassnivå. Du måste naturligtvis se till att du får det faktiska elementnamnet i motsats till C#-medlemsnamnet;

[CollectionName("People")]
//[EnsureIndexes("k")]// doing it here would allow for multi-key configs
public class Person 
{
    [BsonElement("k")] // name mapping in the DB schema
    [BsonIgnoreIfNull]
    [EnsureIndex(IndexConstraints.Unique|IndexConstraints.Sparse)] // name is implicit here
    public string userId{ get; protected set; }

// other properties go here
}

och sedan i din DB-åtkomstimplementering (eller repository) behöver du något sånt här;

    private void AssureIndexesNotInlinable()
    {
                // We can only index a collection if there's at least one element, otherwise it does nothing
                if (this.collection.Count() > 0)
                {

                    // Check for EnsureIndex Attribute
                    var theClass = typeof(T);

                    // Walk the members of the class to see if there are any directly attached index directives
                    foreach (var m in theClass.GetProperties(BindingFlags.Public | BindingFlags.NonPublic | BindingFlags.Instance | BindingFlags.FlattenHierarchy))
                    {
                        List<string> elementNameOverride = new List<string>(1);
                        EnsureIndexes indexAttr = null;

                        // For each members attribs
                        foreach (Attribute attr in m.GetCustomAttributes())
                        {
                            if (attr.GetType() == typeof(EnsureIndex))
                                indexAttr = (EnsureIndex)attr;

                            if (attr.GetType() == typeof(RepoElementAttribute))
                                elementNameOverride.Add(((RepoElementAttribute)attr).ElementName);

                            if ((indexAttr != null) && (elementNameOverride.Count != 0))
                                break;
                        }

                        // Index
                        if (indexAttr != null)
                        {
                            if (elementNameOverride.Count() > 0)
                                EnsureIndexesAsDeclared(indexAttr, elementNameOverride);
                            else
                                EnsureIndexesAsDeclared(indexAttr);
                        }
                    }

                    // Walk the atributes on the class itself. WARNING: We don't validate the member names here, we just create the indexes
                    // so if you create a unique index and don't have a field to match you'll get an exception as you try to add the second
                    // item with a null value on that key
                    foreach (Attribute attr in theClass.GetCustomAttributes(true))
                    {
                        if (attr.GetType() == typeof(EnsureIndexes))
                            EnsureIndexesAsDeclared((EnsureIndexes)attr);

                    }//foreach

                }//if this.collection.count

    }//AssureIndexesNotInlinable()

EnsureIndex ser då ut så här;

    private void EnsureIndexesAsDeclared(EnsureIndexes attr, List<string> indexFields = null)
    {
        var eia = attr as EnsureIndexes;

        if (indexFields == null)
            indexFields = eia.Keys.ToList();

        // use driver specific methods to actually create this index on the collection
        var db = GetRepositoryManager(); // if you have a repository or some other method of your own 
        db.EnsureIndexes(indexFields, attr.Descending, attr.Unique, attr.Sparse);

    }//EnsureIndexes()

Observera att du kommer att placera detta efter varje uppdatering eftersom om du glömmer någonstans kanske dina index inte skapas. Det är därför viktigt att se till att du optimerar samtalet så att det återkommer snabbt om det inte finns någon indexering att göra innan du går igenom all den reflektionskoden. Helst skulle du göra detta bara en gång, eller åtminstone en gång per programstart. Så ett sätt skulle vara att använda en statisk flagga för att spåra om du redan har gjort det, och du skulle behöva ytterligare låsskydd kring det, men alltför förenklat ser det ut ungefär så här;

    void AssureIndexes()
    {
        if (_requiresIndexing)
            AssureIndexesInit();
    }

det är metoden du vill ha i varje DB-uppdatering du gör, som, om du har tur, också kommer in i JIT-optimeraren.



  1. Hur maskin-id/värdnamn mappas/avbildas till 3 byte i objekt-id?

  2. Returnera det sista sanna värdet för varje grupp

  3. Vad är maxstorleken på samlingen i mongodb

  4. Hur ställer jag in och avaktiverar tillsammans med aggregate-update i mongodb?