Dukungan Objek Manajemen SQL Server untuk OLTP In-Memory
Berlaku untuk: SQL Server (semua versi yang didukung)
Azure SQL Database
Azure SQL Managed Instance
Topik ini menjelaskan item dalam SQL Server Management Objects (SMO) yang mendukung In-Memory OLTP.
Jenis dan anggota SMO
Jenis dan anggota berikut berada di namespace Microsoft.SqlServer.Management.Smo, dan mereka mendukung In-Memory OLTP:
- DurabilityType (enumerasi)
- FileGroup.FileGroupType (properti)
- FileGroup.FileGroup (Konstruktor)
- FileGroupType (enumerasi)
- Indeks.BucketCount (properti)
- IndexType.NonClusteredHashIndex (anggota enumerasi)
- Indeks.IsMemoryOptimized (properti)
- Server.IsXTPSupported (properti)
- StoredProcedure.IsNativelyCompiled (properti)
- StoredProcedure.IsSchemaBound (properti)
- Meja.Durability (properti)
- Meja.IsMemoryOptimized (properti)
- UserDefinedTableType.IsMemoryOptimized (properti)
Contoh kode C#
Rakitan yang dirujuk oleh contoh kode yang dikompilasi
- Microsoft.SqlServer.ConnectionInfo.dll
- Microsoft.SqlServer.Management.Sdk.Sfc.dll
- Microsoft.SqlServer.Smo.dll
- Microsoft.SqlServer.SqlEnum.dll
Tindakan yang diambil dalam contoh kode
- Buat database dengan grup file yang dioptimalkan memori dan file yang dioptimalkan memori.
- Buat tabel yang dioptimalkan memori yang tahan lama dengan kunci primer, indeks non-kluster, dan indeks hash non-kluster.
- Membuat kolom dan indeks.
- Buat jenis tabel yang dioptimalkan memori yang ditentukan pengguna.
- Buat prosedur tersimpan yang dikompilasi secara asli.
Kode sumber
using Microsoft.SqlServer.Management.Smo;
using System;
public class A {
static void Main(string[] args) {
Server server = new Server("(local)");
// Create a database with memory-optimized filegroup and memory-optimized file.
Database db = new Database(server, "MemoryOptimizedDatabase");
db.Create();
FileGroup fg = new FileGroup(
db,
"memOptFilegroup",
FileGroupType.MemoryOptimizedDataFileGroup);
db.FileGroups.Add(fg);
fg.Create();
// Change this path if needed.
DataFile file = new DataFile(
fg,
"memOptFile",
@"C:\Program Files\Microsoft SQL Server\MSSQL13.MSSQLSERVER\MSSQL\DATA\MSSQLmemOptFileName");
file.Create();
// Create a durable memory-optimized table with primary key, nonclustered index and nonclustered hash index.
// Define the table as memory optimized and set the durability.
Table table = new Table(db, "memOptTable");
table.IsMemoryOptimized = true;
table.Durability = DurabilityType.SchemaAndData;
// Create columns.
Column col1 = new Column(table, "col1", DataType.Int);
col1.Nullable = false;
table.Columns.Add(col1);
Column col2 = new Column(table, "col2", DataType.Float);
col2.Nullable = false;
table.Columns.Add(col2);
Column col3 = new Column(table, "col3", DataType.Decimal(2, 10));
col3.Nullable = false;
table.Columns.Add(col3);
// Create indexes.
Index pk = new Index(table, "PK_memOptTable");
pk.IndexType = IndexType.NonClusteredIndex;
pk.IndexKeyType = IndexKeyType.DriPrimaryKey;
pk.IndexedColumns.Add(new IndexedColumn(pk, col1.Name));
table.Indexes.Add(pk);
Index ixNonClustered = new Index(table, "ix_nonClustered");
ixNonClustered.IndexType = IndexType.NonClusteredIndex;
ixNonClustered.IndexKeyType = IndexKeyType.None;
ixNonClustered.IndexedColumns.Add(
new IndexedColumn(ixNonClustered, col2.Name));
table.Indexes.Add(ixNonClustered);
Index ixNonClusteredHash = new Index(table, "ix_nonClustered_Hash");
ixNonClusteredHash.IndexType = IndexType.NonClusteredHashIndex;
ixNonClusteredHash.IndexKeyType = IndexKeyType.None;
ixNonClusteredHash.BucketCount = 1024;
ixNonClusteredHash.IndexedColumns.Add(
new IndexedColumn(ixNonClusteredHash, col3.Name));
table.Indexes.Add(ixNonClusteredHash);
table.Create();
// Create a user-defined memory-optimized table type.
UserDefinedTableType uDTT = new UserDefinedTableType(db, "memOptUDTT");
uDTT.IsMemoryOptimized = true;
// Add columns.
Column udTTCol1 = new Column(uDTT, "udtCol1", DataType.Int);
udTTCol1.Nullable = false;
uDTT.Columns.Add(udTTCol1);
Column udTTCol2 = new Column(uDTT, "udtCol2", DataType.Float);
udTTCol2.Nullable = false;
uDTT.Columns.Add(udTTCol2);
Column udTTCol3 = new Column(uDTT, "udtCol3", DataType.Decimal(2, 10));
udTTCol3.Nullable = false;
uDTT.Columns.Add(udTTCol3);
// Add index.
Index ix = new Index(uDTT, "IX_UDT");
ix.IndexType = IndexType.NonClusteredHashIndex;
ix.BucketCount = 1024;
ix.IndexKeyType = IndexKeyType.DriPrimaryKey;
ix.IndexedColumns.Add(new IndexedColumn(ix, udTTCol1.Name));
uDTT.Indexes.Add(ix);
uDTT.Create();
// Create a natively compiled stored procedure.
StoredProcedure sProc = new StoredProcedure(db, "nCSProc");
sProc.TextMode = false;
sProc.TextBody = "--Type body here";
sProc.IsNativelyCompiled = true;
sProc.IsSchemaBound = true;
sProc.ExecutionContext = ExecutionContext.Owner;
sProc.Create();
}
}