Devart Forums

Code: Select all

var query = 
  from Table1 in entity.TblTable1
  join Table2 in entity.TblTable2 on Table1.TblTable2.OID equals Table2.OID
  join Table3 in entity.TblTable3 on Table1.TblTable2.OID equals Table3.TblTable2.OID
  let leftOuterEmail = (from Table4 in entity.TblMail
    where Table3.TblName.OID == Table4.TblName.OID
      && ((Table3.TblName.IsDeceased != true
      && Table3.TblName.IsPerson)
      || !Table3.TblName.IsPerson)
      select new
      {
          EmailAdd = ((Table4.EmailAdd.Length > 0) ? Table4.EmailAdd : "")
      }).FirstOrDefault()

      where (ForEmail && leftOuterEmail.EmailAddress.Length > 0) || !ForEmail
        orderby Table1.TblTable2.Reference
        select new
        {
          OID = Table2.OID,
          OIDCT = Table2.TblTable1s.FirstOrDefault().TblContactType.OIDContactType,
          ..........
        };

Code: Select all

var dataBackup = new PgSqlDump()
                    { 
                        Connection = myConnection.getConnection(),
                        QuoteIdentifier = true,
                        IncludeBlob = true,
                        IncludeDrop = false, 
                        IncludeUsers = false, 
                        GenerateHeader = false,
                        ObjectTypes = PgSqlDumpObjects.All ^ PgSqlDumpObjects.Users ^ PgSqlDumpObjects.Languages 
                            ^ PgSqlDumpObjects.Views ^ PgSqlDumpObjects.Indexes ^ PgSqlDumpObjects.Constraints,
                        Mode =  DumpMode.All
                    };

                    string name = Path.Combine(Destination, "dump_data.backup");
                    dataBackup.Backup(name);

Code: Select all

var viewsBackup = new PgSqlDump()
                    {
                        Connection = myConnection.getConnection(),
                        QuoteIdentifier = true,
                        GenerateHeader = false,
                        ObjectTypes = PgSqlDumpObjects.Views
                    };

                    name = Path.Combine(Destination, "dump_views.backup");
                    viewsBackup.Backup(name);
                    

Code: Select all

var indiciesBackup = new PgSqlDump()
                    {
                        Connection = myConnection.getConnection(),
                        QuoteIdentifier = true,
                        GenerateHeader = false,
                        ObjectTypes = PgSqlDumpObjects.Indexes
                    };

                    name = Path.Combine(Destination, "dump_indicies.backup");
                    indiciesBackup.Backup(name);
                    

Code: Select all

var constraintsBackup = new PgSqlDump()
                    {
                        Connection = myConnection.getConnection(),
                        QuoteIdentifier = true,
                        GenerateHeader = false,
                        ObjectTypes = PgSqlDumpObjects.Constraints
                    };

                    name = Path.Combine(Destination, "dump_constraints.backup");
                    constraintsBackup.Backup(name);
                    

Code: Select all

DoDevartRestore("Data", openWhat.InitialDirectory, openWhat.FileName, "dump_data.backup");
                    DoDevartRestore("Indicies", openWhat.InitialDirectory, openWhat.FileName, "dump_indicies.backup");
                    DoDevartRestore("Constraints", openWhat.InitialDirectory, openWhat.FileName, "dump_constraints.backup");
                    DoDevartRestore("Views", openWhat.InitialDirectory, openWhat.FileName, "dump_views.backup");
                    

Code: Select all

private bool DoDevartRestore(string myMessage, string myDirectory, string zipFile, string myFile)
        {
            bool result = false;
            try
            {
                ...
                string myFilePath = Path.Combine(myDirectory, myFile);
                try
                {
                    if (File.Exists(myFilePath))
                        File.Delete(myFilePath);
                }
                catch { };
                
                ...
                    RunDevartRestore();
                    result = true;
                }
            }
            catch { };
            return result;
        }

Code: Select all

public void RunDevartRestore()
        {
            try
            {
                CSLConnect myConnection = new CSLConnect(teUser.Text,tePassword.Text, tePort.Text, teHost.Text, teDB.Text);

                if (myConnection.Login())
                {
                    using (PgSqlDump DataRestore = new PgSqlDump { Connection = myConnection.getConnection() })
                    {
                        if (File.Exists(RestoreString))
                        {
...                            
                            DataRestore.Restore(RestoreString);
                            myConnection.Logout();
                            File.Delete(RestoreString);
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                Message = ex.Message;
            }
        }

Code: Select all

2012-11-29 21:47:28 GMT	ERROR	syntax error at or near "" PRIMARY KEY ("" at character 104237	
2012-11-29 21:47:28 GMT	STATEMENT	CREATE OR REPLACE FUNCTION "public"."dblink"( text, text)	
			  RETURNS SETOF record AS	
			$BODY$dblink_record$BODY$	
			  LANGUAGE 'c';	

Code: Select all

DataRestore.Restore(RestoreString);

Code: Select all

  var myConnection = new CSLConnect(UserName, Password, Port, HostName, DBName);
  if (myConnection.Login())
  {
    using (var dataBackup = new PgSqlDump()
    {
      Connection = myConnection.getConnection(),
      IncludeBlob = true,
      ObjectTypes = PgSqlDumpObjects.All,
      GenerateHeader = true,
      Mode = DumpMode.All
    })
    {
      dataBackup.Backup(Path.Combine(Destination, BackupName + ".backup"));
    }
    myConnection.Logout();
}

Code: Select all

Code: Select all

Code: Select all

try
{using (PgSqlConnection conn = new PgSqlConnection())
                    {
                        conn.ConnectionString = string.Format("... ...",
                            teDestinationHost.Text, teDestinationPort.Text, teDestinationDatabase.Text);
                        conn.Open();
                        conn.Close();
                        DbExists = true;
                    }
} ...

if (DbExists)
                    {
                        ...
using (PgSqlConnection conn = new PgSqlConnection())
            {
                conn.ConnectionString = string.Format("... ...",
                    teDestinationHost.Text, teDestinationPort.Text);
                conn.Open();
                string cmdstring = "DROP DATABASE IF EXISTS \"" + teDestinationDatabase.Text.Trim() + "\";";

                PgSqlCommand cmd = new PgSqlCommand();
                cmd.CommandType = CommandType.Text;
                cmd.Connection = conn;
                cmd.CommandText = cmdstring;
                try
                {
                    cmd.ExecuteNonQuery();
                    result = true;
                }
                catch(Exception ex)
                {
                    MessageBox.Show("Failed to drop Database\n"+ex.Message);
                };
            }

Code: Select all

StreamReader streamReader = new StreamReader("pgDumpScript.sql");
                    string text = streamReader.ReadToEnd();
                    streamReader.Close();
                    PgSqlScript cmdScript = new PgSqlScript(text, conn);
                    
                    foreach (SqlStatement pgStatement in cmdScript.Statements)
                    {
                        try
                        {
                            pgStatement.Execute();
                         }
                        catch
                        {
                            Console.WriteLine("  Failed");
                        }
                    } 
                    conn.Close();