Noundry.Slurp

# Simplest: SQLite
slurp data.csv -p sqlite -d mydata.db

# PostgreSQL
slurp orders.csv -p postgres -s localhost -d ecommerce -u admin --password secret

# SQL Server with Windows Auth
slurp products.csv -p sqlserver -s .\SQLEXPRESS -d ProductDB

# MySQL with custom port
slurp users.csv -p mysql -s localhost --port 3307 -d userdb -u root --password root

# Custom table name and schema
slurp data.csv -p postgres -s localhost -d mydb -t imported_data --schema staging

# Drop and recreate table
slurp fresh_data.csv -p sqlite -d app.db --drop

# Skip indexes for faster initial load
slurp bulk_import.csv -p sqlserver -d analytics --no-indexes

# Semicolon-delimited European file
slurp european_data.csv -p postgres -d mydb --delimiter ";"

using Noundry.Slurp;
using Noundry.Slurp.Configuration;

var config = new SlurpConfiguration
{
 Provider = "postgres",
 Server = "localhost",
 Port = 5432,
 Database = "mydb",
 Username = "user",
 Password = "pass",
 TableName = "imported_data",
 BatchSize = 10000,
 Parallel = true,
 CreateIndexes = true
};

using var engine = new SlurpEngine(config);
var result = await engine.IngestAsync("data.csv");

Console.WriteLine($"Inserted {result.RowsInserted:N0} rows in {result.Duration.TotalSeconds:F2}s");
Console.WriteLine($"Speed: {result.RowsPerSecond:N0} rows/sec");

using var engine = new SlurpEngine(config);

engine.ProgressChanged += (sender, e) =>
{
 Console.WriteLine($"Progress: {e.PercentComplete:F1}% - {e.RowsProcessed:N0}/{e.TotalRows:N0}");
};

engine.StatusChanged += (sender, message) =>
{
 Console.WriteLine($"Status: {message}");
};

var result = await engine.IngestAsync("customers.csv", CancellationToken.None);

if (result.Success)
 Console.WriteLine($"Table created: {result.TableCreated}, Indexes: {result.IndexesCreated}");
else
 Console.WriteLine($"Error: {result.ErrorMessage}");

{
 "provider": "postgres",
 "server": "db.example.com",
 "port": 5432,
 "database": "production",
 "username": "app_user",
 "password": "${DB_PASSWORD}",
 "schema": "imports",
 "batchSize": 10000,
 "createIndexes": true,
 "dropTableIfExists": false,
 "parallel": true,
 "timeout": 600,
 "columnMappings": {
 "Original Column Name": "new_column_name"
 },
 "columnTypes": {
 "id": "BIGINT",
 "amount": "DECIMAL"
 }
}