Devart Forums

Code: Select all

CREATE OR REPLACE FUNCTION Abc(a INT, b INT, c INT)
    RETURNS INT AS $$
    DECLARE a INT;
    BEGIN
        ...
	RETURN a;
    END;
    $$ LANGUAGE plpgsql VOLATILE;

Code: Select all

            PgSqlCommand comm = new PgSqlCommand("myfunction", conn);
            comm.CommandType = CommandType.StoredProcedure;
            //comm.ParameterCheck = true; // doesn't work with ParameterCheck either

            // Add parameters.
            comm.Parameters.Add(new PgSqlParameter("a", PgSqlType.Int));
            comm.Parameters.Add(new PgSqlParameter("b", PgSqlType.Int));
            comm.Parameters.Add(new PgSqlParameter("return_value", PgSqlType.VarChar)).Direction = ParameterDirection.Output; // doesn't work with ReturnValue either

            comm.Parameters["a"].Value = 10;
            comm.Parameters["b"].Value = 3;

            comm.ExecuteNonQuery();

            PgSqlCursor cursor = comm.Parameters["return_value"].PgSqlValue as PgSqlCursor;

            using (PgSqlDataReader rd = cursor.GetDataReader()) { 
                while (rd.Read()) 
                     Console.WriteLine(rd.GetValue(0)); 
            }

Code: Select all

CREATE TABLE abc (
ida INT NOT NULL REFERENCES A (ida) ON DELETE CASCADE,
idb INT NOT NULL REFERENCES B (ida) ON DELETE CASCADE,
seq INT NOT NULL,
PRIMARY KEY (ida, idb, seq),
x REAL ARRAY,
n INT)
WITHOUT OIDS;

Code: Select all

CREATE TABLE A (ida SERIAL PRIMARY KEY, ...) WITHOUT OIDS;
CREATE TABLE B (
ida INT NOT NULL PRIMARY KEY REFERENCES A (ida) ON DELETE CASCADE,
...)
WITHOUT OIDS;

Code: Select all

public class Key {
  public int IdA { get; set; }
  public int IdB { get; set; }
  public int Seq { get; set; }
}
...
using (AbcDataContext ctxt = new AbcDataContext())
{
  IEnumerable q =
    from a in ctxt.abcs
    where IdA = X && IdB == Y
    orderby Seq
    select new Key { IdA = a.IdA, IdB = a.IdB, IdC = a.IdC };

  foreach (Key k in q)
  {
     // This foreach goes over only 100 entities, even though the table
     // has 81715; in this case, if I remove the usage of the class Key,
     // and do select a (the Abc type), then the loop goes over the
     // correct set of entities.
  }
}

Code: Select all

object[] a = { 1e-1, 2e-1, 3e-2, 4e-2, 5e-2, 6e-2, 7e-2, 8e-2, 9e-2, 1e-1 };

PgSqlLoader loader = new PgSqlLoader("public.abc", conn);

loader.Columns.Add("arraycolumn", PgSqlType.Array, 0, 0, 0);
loader.Open();
loader.SetValue(0, new PgSqlArray(a, PgSqlType.Double, 1, a.Length));
loader.NextRow();
loader.Close();

Code: Select all

x0000:  4500 0049 64e4 4000 4006 5266 c0a8 010a  E..Id.@[email protected]....
0x0010:  c0a8 010a 839a 1538 7c02 bed2 7b5e 5954  .......8|...{^YT
0x0020:  8018 0212 83a0 0000 0101 080a 0077 f964  .............w.d
0x0030:  0077 dab1 5100 0000 1473 656c 6563 7420  .w..Q....select.
0x0040:  7371 7274 2832 293b 00                   sqrt(2);.

0x0000:  4500 007e 82fc 4000 4006 3419 c0a8 010a  E..~..@[email protected].....
0x0010:  c0a8 010a 1538 839a 7b5e 5954 7c02 bee7  .....8..{^YT|...
0x0020:  8018 0200 83d5 0000 0101 080a 0077 f965  .............w.e
0x0030:  0077 f964 5400 0000 1d00 0173 7172 7400  .w.dT......sqrt.
0x0040:  0000 0000 0000 0000 02bd 0008 ffff ffff  ................
0x0050:  0000 4400 0000 1900 0100 0000 0f31 2e34  ..D..........1.4
0x0060:  3134 3231 3335 3632 3337 3331 4300 0000  142135623731C...
0x0070:  0b53 454c 4543 5400 5a00 0000 0549       .SELECT.Z....I

0x0000:  4500 0034 64e5 4000 4006 527a c0a8 010a  E..4d.@[email protected]....
0x0010:  c0a8 010a 839a 1538 7c02 bee7 7b5e 599e  .......8|...{^Y.
0x0020:  8010 0212 54d3 0000 0101 080a 0077 f965  ....T........w.e
0x0030:  0077 f965                                .w.e

Code: Select all

            string sql =
                "COPY (SELECT column1, column2 FROM table1 JOIN table2 WHERE column1 > :param1) " +
                " TO STDOUT WITH BINARY";

            PgSqlCommand comm = new PgSqlCommand(sql, conn);

            comm.Parameters.Add(new PgSqlParameter("param1", 0));

            comm.PgSqlDataReader reader = comm.ExecuteReader();
            List list = new List();
            try
            {
                while (reader.Read())
                {
                    list.Add(new MyObject()
                    {
                        Column1 = reader.GetInt32(0),
                        Column2 = reader.GetInt32(1)
                    });
                }
            }
            finally
            {
                reader.Close();
            }

Code: Select all

        [Function(Name=@"getEntity", IsComposable=true)]
        public System.Linq.IQueryable GetEntity([Parameter(Name="$1", DbType="int4")] System.Nullable i)
        {
            return this.CreateMethodCallQuery(this, ((MethodInfo)(MethodInfo.GetCurrentMethod())), i);
        }