TVP parameters work over the TDS wire: RPC TYPE_INFO 0xF3 decodes TVP_TYPENAME + client column metadata + row stream through new TdsValueReader/TdsColumnDecoder shared with the bulk-load reader, binds positionally for both proc RPC and sp_executesql text commands, and structured-parameter row insertion now enforces NOT NULL/CHECK/PK/UNIQUE (515/547/2627/2601) on the wire and in-process paths alike with IEnumerable<SqlDataRecord> sources working over the wire, identity-DBNull auto-generation retained as a documented divergence from real's Msg 1077, and the four built-in rowset dispatch blocks in FROM-source parsing (OPENJSON / STRING_SPLIT / GENERATE_SERIES / fn_listextendedproperty) collapsed into a shared BuiltInRowsetSource helper.

Author: RyanLamansky

CLAUDE.md

@@ -164,7 +164,7 @@ Per-feature deep-dives live under `docs/claude/`. Each entry below is a trigger:
 - **New top-level statement parser or dispatch-loop separator rules, double-quoted identifiers / QUOTED_IDENTIFIER** → [`grammar.md`](docs/claude/grammar.md) + [`control-flow.md`](docs/claude/control-flow.md).
 - **BACPAC import** (`Simulation.ImportBacpac` — multi-database via repeated calls, `BacpacImportOptions`, `ModelXmlReader` dispatcher, BCP wire format, `BacpacBuilder` test harness) → [`bacpac-loader.md`](docs/claude/bacpac-loader.md).
 - **Linked servers** (`Simulation.AddRemoteSimulation`, `sp_addlinkedserver` / `sp_dropserver`, four-part FROM routing through the remote's ADO.NET pipeline, `OPENQUERY(server,'query')` ad-hoc pass-through + compile-time schema discovery, `sys.servers`) → [`linked-servers.md`](docs/claude/linked-servers.md).
-- **TDS network endpoint** (`Simulation.ListenAsync` → `SimulatedNetworkListener`; real SqlClient over loopback TCP+TLS; SQLBatch/RPC/TM/BulkLoad (`SqlBulkCopy`); `sp_cursor*` API-server-cursor RPC family; credential enforcement via the `CREATE LOGIN` registry, Msg 18456 on mismatch; EF via plain `UseSqlServer`; oracles = `*.Tests.SqlClient` + `*.Tests.Smo`, the real-SMO consumer oracle) → [`tds-endpoint.md`](docs/claude/tds-endpoint.md).
+- **TDS network endpoint** (`Simulation.ListenAsync` → `SimulatedNetworkListener`; real SqlClient over loopback TCP+TLS; SQLBatch/RPC/TM/BulkLoad (`SqlBulkCopy`); TVP (`0xF3` `SqlDbType.Structured`) RPC params via the shared `TdsColumnDecoder`; `sp_cursor*` API-server-cursor RPC family; credential enforcement via the `CREATE LOGIN` registry, Msg 18456 on mismatch; EF via plain `UseSqlServer`; oracles = `*.Tests.SqlClient` + `*.Tests.Smo`, the real-SMO consumer oracle) → [`tds-endpoint.md`](docs/claude/tds-endpoint.md).
 
 ## Not modeled
 

SqlServerSimulator.Tests.SqlClient/RpcErrorTests.cs

@@ -32,35 +32,6 @@ public async Task ParameterizedDivideByZero_Number8134()
         AreEqual(8134, ex.Number);
     }
 
-    // A table-valued parameter (SqlDbType.Structured) is decoded to the 0xF3
-    // wire token, which the RPC parser rejects. The unsupported-type error
-    // surfaces as Msg 50000 naming the table-valued form. Asserts the observed
-    // behavior; the message text documents the surface.
-    [TestMethod]
-    public async Task TableValuedParameter_SurfacesAsUnsupported()
-    {
-        var simulation = new Simulation();
-        await using var listener = await simulation.ListenAsync(0, TestContext.CancellationToken);
-        await using var connection = await Wire.OpenAsync(listener, TestContext.CancellationToken);
-
-        var table = new DataTable();
-        _ = table.Columns.Add("id", typeof(int));
-        _ = table.Rows.Add(1);
-        _ = table.Rows.Add(2);
-
-        var ex = await Assert.ThrowsAsync<SqlException>(async () =>
-        {
-            await using var command = new SqlCommand("select count(*) from @t", connection);
-            var parameter = command.Parameters.AddWithValue("@t", table);
-            parameter.SqlDbType = SqlDbType.Structured;
-            parameter.TypeName = "dbo.IntList";
-            _ = await command.ExecuteScalarAsync(TestContext.CancellationToken);
-        });
-
-        AreEqual(50000, ex.Number);
-        Contains("table-valued", ex.Message);
-    }
-
     [TestMethod]
     public async Task OutputParameterBeforeErrorInBatch_ThrowsButWritesOutput()
     {

SqlServerSimulator.Tests.SqlClient/TvpRpcTests.cs

@@ -417,6 +417,78 @@ public void Structured_DataTable_IdentityValueSupplied_RaisesMsg1077()
         AreEqual("1077", ex.Data["HelpLink.EvtID"]);
     }
 
+    [TestMethod]
+    public void Structured_DataTable_NullIntoNotNullColumn_RaisesMsg515()
+    {
+        var simulation = new Simulation();
+        _ = simulation.ExecuteNonQuery("create type dbo.t1 as table (id int not null, v int)");
+
+        using var con = simulation.CreateDbConnection();
+        con.Open();
+        using var cmd = con.CreateCommand();
+        cmd.CommandText = "select id from @rows";
+        var dt = new DataTable();
+        _ = dt.Columns.Add("id", typeof(int));
+        _ = dt.Columns.Add("v", typeof(int));
+        _ = dt.Rows.Add(DBNull.Value, 1);
+        var p = cmd.CreateParameter();
+        p.ParameterName = "@rows";
+        p.Value = dt;
+        p.TypeName = "dbo.t1";
+        _ = cmd.Parameters.Add(p);
+
+        var ex = Throws<System.Data.Common.DbException>(() => cmd.ExecuteNonQuery());
+        AreEqual("515", ex.Data["HelpLink.EvtID"]);
+    }
+
+    [TestMethod]
+    public void Structured_DataTable_DuplicatePrimaryKey_RaisesMsg2627()
+    {
+        var simulation = new Simulation();
+        _ = simulation.ExecuteNonQuery("create type dbo.t1 as table (id int not null primary key, v int)");
+
+        using var con = simulation.CreateDbConnection();
+        con.Open();
+        using var cmd = con.CreateCommand();
+        cmd.CommandText = "select id from @rows";
+        var dt = new DataTable();
+        _ = dt.Columns.Add("id", typeof(int));
+        _ = dt.Columns.Add("v", typeof(int));
+        _ = dt.Rows.Add(1, 10);
+        _ = dt.Rows.Add(1, 20);
+        var p = cmd.CreateParameter();
+        p.ParameterName = "@rows";
+        p.Value = dt;
+        p.TypeName = "dbo.t1";
+        _ = cmd.Parameters.Add(p);
+
+        var ex = Throws<System.Data.Common.DbException>(() => cmd.ExecuteNonQuery());
+        AreEqual("2627", ex.Data["HelpLink.EvtID"]);
+    }
+
+    [TestMethod]
+    public void Structured_DataTable_CheckViolation_RaisesMsg547()
+    {
+        var simulation = new Simulation();
+        _ = simulation.ExecuteNonQuery("create type dbo.t1 as table (id int not null check (id > 0))");
+
+        using var con = simulation.CreateDbConnection();
+        con.Open();
+        using var cmd = con.CreateCommand();
+        cmd.CommandText = "select id from @rows";
+        var dt = new DataTable();
+        _ = dt.Columns.Add("id", typeof(int));
+        _ = dt.Rows.Add(-5);
+        var p = cmd.CreateParameter();
+        p.ParameterName = "@rows";
+        p.Value = dt;
+        p.TypeName = "dbo.t1";
+        _ = cmd.Parameters.Add(p);
+
+        var ex = Throws<System.Data.Common.DbException>(() => cmd.ExecuteNonQuery());
+        AreEqual("547", ex.Data["HelpLink.EvtID"]);
+    }
+
     [TestMethod]
     public void Structured_IDataReader_BindsViaCommand()
     {