private void SaveAllByCopy(DateTime datetaken, string Weight, string lineno) { using (var connection = new NpgsqlConnection("Server=localhost ; port=5432; Database=testdb;Userid=postgres; Password=admin ")) { connection.Open(); using (var command = connection.CreateCommand()) { command.CommandText = "COPY finaltest(datetaken,Weight,lineip) FROM STDIN"; NpgsqlCopySerializer serializer = new NpgsqlCopySerializer(connection); NpgsqlCopyIn copyIn = new NpgsqlCopyIn(command, connection, serializer.ToStream); try { copyIn.Start(); foreach (var value in conairdata) { serializer.AddString(conairdata.datetaken); serializer.AddString(conairdata.Weight); serializer.AddDateTime(conairdata.lineno); serializer.EndRow(); serializer.Flush(); } copyIn.End(); serializer.Close(); }
var
This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)