VAR/VAR.DatabaseExplorer
1
0
Fork 0
Code Issues 4 Pull Requests Packages Projects Releases Wiki Activity

ExportSchema: Export routines with checking dependencies.

Browse Source
This commit is contained in:
Valeriano A.R.
2019-08-02 11:48:24 +02:00
parent 1356ee0e51
commit efc193d94c
8 changed files with 305 additions and 111 deletions
Download Patch File Download Diff File Expand all files Collapse all files

102
VAR.DatabaseExplorer/Code/BusinessLogic/DatabaseBL.cs
View File

@@ -1,4 +1,5 @@
using System.IO;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using VAR.DatabaseExplorer.Code.DataAccess;
using VAR.DatabaseExplorer.Code.DataTransfer;
@@ -72,40 +73,29 @@ namespace VAR.DatabaseExplorer.Code.BusinessLogic
// Desactivar todas las FKs
txtWriter.WriteLine("-- Disable all constraints");
foreach (Table t in database.Tables)
foreach (Table table in database.Tables)
{
if (t.Type != "BASE TABLE") { continue; }
if (table.Type != "BASE TABLE") { continue; }
string tableName = string.Format("[{0}].[{1}]", t.Schema, t.Name);
string tableName = string.Format("[{0}].[{1}]", table.Schema, table.Name);
txtWriter.WriteLine(string.Format("ALTER TABLE {0} NOCHECK CONSTRAINT all;", tableName));
}
txtWriter.WriteLine("GO");
txtWriter.WriteLine(string.Empty);
// Prepara información a exportar
foreach (Table t in database.Tables)
foreach (Table table in database.Tables)
{
if (t.Type != "BASE TABLE") { continue; }
string tableName = string.Format("{0}.{1}", t.Schema, t.Name);
txtWriter.WriteLine(string.Format("PRINT '*** Importing data of {0}....';", tableName));
if (t.Columns.Any(c => c.Indentity))
{
TableBL.Table_ExportDataWithIdentity(t, txtWriter, connectionString, tableName);
}
else
{
TableBL.Table_ExportData(t, txtWriter, connectionString, tableName);
}
TableBL.Table_ExportData(table, txtWriter, connectionString);
}
// Activar todas las FKs
txtWriter.WriteLine("-- Enable all constraints");
foreach (Table t in database.Tables)
foreach (Table table in database.Tables)
{
if (t.Type != "BASE TABLE") { continue; }
if (table.Type != "BASE TABLE") { continue; }
string tableName = string.Format("[{0}].[{1}]", t.Schema, t.Name);
string tableName = string.Format("[{0}].[{1}]", table.Schema, table.Name);
txtWriter.WriteLine(string.Format("ALTER TABLE {0} WITH CHECK CHECK CONSTRAINT all;", tableName));
}
txtWriter.WriteLine("GO");
@@ -114,70 +104,36 @@ namespace VAR.DatabaseExplorer.Code.BusinessLogic
public static void Database_ExportTables(TextWriter txtWriter, string connectionString, Database database)
{
foreach (Table t in database.Tables)
foreach (Table table in database.Tables)
{
if (t.Type != "BASE TABLE") { continue; }
TableBL.Table_GenerateCreate(table, txtWriter);
}
}
string tableName = string.Format("{0}.{1}", t.Schema, t.Name);
txtWriter.WriteLine(string.Format("PRINT '*** Creating tabla {0}....';", tableName));
public static void Database_ExportFunctions(StreamWriter txtWriter, Database database)
{
List<Procedure> exportedRoutines = new List<Procedure>();
txtWriter.WriteLine(string.Format("CREATE TABLE {0} (", tableName));
bool firstColumn = true;
foreach (Column c in t.Columns)
int exportedOnLoopCount = 0;
do
{
if (firstColumn == false)
exportedOnLoopCount = 0;
foreach (Procedure routine in database.Procedures)
{
txtWriter.WriteLine(",");
}
txtWriter.Write(" [");
txtWriter.Write(c.Name);
txtWriter.Write("] ");
if (
c.Type == "nvarchar" ||
c.Type == "varchar" ||
c.Type == "char" ||
c.Type == "nchar" ||
c.Type == "binary" ||
c.Type == "varbinary" ||
c.Type == "image")
if (exportedRoutines.Any(er => er.Schema == routine.Schema && er.Name == routine.Name)) { continue; }
if (routine.Dependencies.Count > 0)
{
if (c.Size < 0)
if (routine.Dependencies.Any(pd => exportedRoutines.Any(er => er.Schema == pd.Schema && er.Name == pd.Name) == false))
{
txtWriter.Write(string.Format("{0}(MAX)", c.Type));
}
else
{
txtWriter.Write(string.Format("{0}({1})", c.Type, c.Size));
continue;
}
}
else
{
txtWriter.Write(c.Type);
}
if (c.Nullable)
{
txtWriter.Write(" NULL");
}
else
{
txtWriter.Write(" NOT NULL");
}
if (c.PK)
{
txtWriter.Write(" PRIMARY KEY");
}
if (c.Indentity)
{
txtWriter.Write(" IDENTITY(1,1)");
}
firstColumn = false;
ProcedureBL.Procedure_GenerateCreate(routine, txtWriter);
exportedRoutines.Add(routine);
exportedOnLoopCount++;
}
txtWriter.WriteLine();
txtWriter.WriteLine(string.Format(");"));
txtWriter.WriteLine("GO");
txtWriter.WriteLine();
}
} while (exportedOnLoopCount > 0);
}
}
}

98
VAR.DatabaseExplorer/Code/BusinessLogic/ProcedureBL.cs
View File

@@ -1,4 +1,7 @@
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using VAR.DatabaseExplorer.Code.DataAccess;
using VAR.DatabaseExplorer.Code.DataTransfer;
@@ -11,12 +14,105 @@ namespace VAR.DatabaseExplorer.Code.BusinessLogic
List<Procedure> procedures = ProcedureDA.GetAllProcedures(connectionString);
if (fillDefinition)
{
// Get all definitions
List<ProcedureDefinition> definitions = ProcedureDA.GetProcedureDefinitions(connectionString, null, null);
foreach (Procedure procedure in procedures)
{
procedure.Definition = ProcedureDA.GetProcedureDefinition(connectionString, procedure.Schema, procedure.Name);
var sbDefinition = new StringBuilder();
foreach (ProcedureDefinition definition in definitions)
{
if (procedure.Schema == definition.ProcedureSchema && procedure.Name == definition.ProcedureName)
{
sbDefinition.Append(definition.Definition);
}
}
procedure.Definition = sbDefinition.ToString();
}
Procedure_AssingDependencies(procedures);
}
return procedures;
}
private static void Procedure_AssignDependency(Procedure procedure, Procedure procedureDep)
{
if (procedure.Dependencies.Any(pd => procedureDep.Schema == pd.Schema && procedureDep.Name == pd.Name)) { return; }
procedure.Dependencies.Add(procedureDep);
}
private static void Procedure_CheckDependencies(IEnumerable<Procedure> procedures, Procedure procedureDep, string strProcFullName)
{
foreach (Procedure procedure in procedures)
{
if (procedure.Schema == procedureDep.Schema && procedure.Name == procedureDep.Name) { continue; }
if (string.IsNullOrEmpty(procedure.DefinitionLowercase))
{
procedure.DefinitionLowercase = procedure.Definition.ToLower();
}
if (procedure.DefinitionLowercase.Contains(strProcFullName))
{
Procedure_AssignDependency(procedure, procedureDep);
}
}
}
private static void Procedure_AssingDependencies(IEnumerable<Procedure> procedures)
{
foreach (Procedure procedureDep in procedures)
{
string strProcFullName;
string strProcedureSchema = procedureDep.Schema.ToLower();
string strProcedureName = procedureDep.Name.ToLower();
strProcFullName = string.Format("{0}.{1} ", strProcedureSchema, strProcedureName);
Procedure_CheckDependencies(procedures, procedureDep, strProcFullName);
strProcFullName = string.Format("{0}.{1}(", strProcedureSchema, strProcedureName);
Procedure_CheckDependencies(procedures, procedureDep, strProcFullName);
strProcFullName = string.Format("[{0}].{1} ", strProcedureSchema, strProcedureName);
Procedure_CheckDependencies(procedures, procedureDep, strProcFullName);
strProcFullName = string.Format("[{0}].{1}(", strProcedureSchema, strProcedureName);
Procedure_CheckDependencies(procedures, procedureDep, strProcFullName);
strProcFullName = string.Format("{0}.[{1}]", strProcedureSchema, strProcedureName);
Procedure_CheckDependencies(procedures, procedureDep, strProcFullName);
strProcFullName = string.Format("[{0}].[{1}]", strProcedureSchema, strProcedureName);
Procedure_CheckDependencies(procedures, procedureDep, strProcFullName);
strProcFullName = string.Format("\"{0}\".{1} ", strProcedureSchema, strProcedureName);
Procedure_CheckDependencies(procedures, procedureDep, strProcFullName);
strProcFullName = string.Format("\"{0}\".{1}(", strProcedureSchema, strProcedureName);
Procedure_CheckDependencies(procedures, procedureDep, strProcFullName);
strProcFullName = string.Format("{0}.\"{1}\"", strProcedureSchema, strProcedureName);
Procedure_CheckDependencies(procedures, procedureDep, strProcFullName);
strProcFullName = string.Format("\"{0}\".\"{1}\"", strProcedureSchema, strProcedureName);
Procedure_CheckDependencies(procedures, procedureDep, strProcFullName);
}
}
internal static void Procedure_GenerateCreate(Procedure routine, StreamWriter txtWriter)
{
string routineName = string.Format("{0}.{1}", routine.Schema, routine.Name);
if (routine.Type.ToUpper() == "PROCEDURE")
{
txtWriter.WriteLine(string.Format("PRINT '*** Creating procedure {0}....';", routineName));
txtWriter.WriteLine(string.Format("IF EXISTS (SELECT TOP 1 1 FROM INFORMATION_SCHEMA.ROUTINES WHERE ROUTINE_SCHEMA = '{0}' AND ROUTINE_NAME = '{1}')", routine.Schema, routine.Name));
txtWriter.WriteLine("BEGIN");
txtWriter.WriteLine(string.Format(" DROP PROCEDURE {0};", routineName));
txtWriter.WriteLine("END");
}
if (routine.Type.ToUpper() == "FUNCTION")
{
txtWriter.WriteLine(string.Format("PRINT '*** Creating function {0}....';", routineName));
txtWriter.WriteLine(string.Format("IF EXISTS (SELECT TOP 1 1 FROM INFORMATION_SCHEMA.ROUTINES WHERE ROUTINE_SCHEMA = '{0}' AND ROUTINE_NAME = '{1}')", routine.Schema, routine.Name));
txtWriter.WriteLine("BEGIN");
txtWriter.WriteLine(string.Format(" DROP FUNCTION {0};", routineName));
txtWriter.WriteLine("END");
}
txtWriter.WriteLine("GO");
txtWriter.WriteLine(routine.Definition);
txtWriter.WriteLine("GO");
txtWriter.WriteLine();
}
}
}

103
VAR.DatabaseExplorer/Code/BusinessLogic/TableBL.cs
View File

@@ -23,32 +23,105 @@ namespace VAR.DatabaseExplorer.Code.BusinessLogic
return tables;
}
public static void Table_ExportDataWithIdentity(Table t, TextWriter txtWriter, string conectionString, string tableFullName)
public static void Table_ExportData(Table t, TextWriter txtWriter, string conectionString)
{
DataTable dtData = TableDA.GetData(conectionString, tableFullName);
if (t.Type != "BASE TABLE") { return; }
txtWriter.WriteLine(string.Format("-- {0}", tableFullName));
txtWriter.WriteLine(string.Format("DELETE FROM {0};", tableFullName));
txtWriter.WriteLine(string.Format("DBCC CHECKIDENT ('{0}', RESEED, 0);", tableFullName));
txtWriter.WriteLine(string.Format("SET IDENTITY_INSERT {0} ON;", tableFullName));
string tableName = string.Format("{0}.{1}", t.Schema, t.Name);
txtWriter.WriteLine(string.Format("PRINT '*** Importing data of {0}....';", tableName));
DataTable dtData = TableDA.GetData(conectionString, tableName);
if (t.Columns.Any(c => c.Indentity))
{
txtWriter.WriteLine(string.Format("-- {0}", tableName));
txtWriter.WriteLine(string.Format("DELETE FROM {0};", tableName));
txtWriter.WriteLine(string.Format("DBCC CHECKIDENT ('{0}', RESEED, 0);", tableName));
txtWriter.WriteLine(string.Format("SET IDENTITY_INSERT {0} ON;", tableName));
txtWriter.WriteLine("GO");
DataTableHelper.DataTable_GenerateInserts(txtWriter, dtData, tableFullName);
DataTableHelper.DataTable_GenerateInserts(txtWriter, dtData, tableName);
txtWriter.WriteLine("GO");
txtWriter.WriteLine(string.Format("SET IDENTITY_INSERT {0} OFF;", tableFullName));
txtWriter.WriteLine(string.Format("SET IDENTITY_INSERT {0} OFF;", tableName));
txtWriter.WriteLine("GO");
txtWriter.WriteLine(string.Empty);
}
public static void Table_ExportData(Table t, TextWriter txtWriter, string conectionString, string tableFullName)
else
{
DataTable dtData = TableDA.GetData(conectionString, tableFullName);
txtWriter.WriteLine(string.Format("-- {0}", tableFullName));
txtWriter.WriteLine(string.Format("DELETE FROM {0};", tableFullName));
txtWriter.WriteLine(string.Format("-- {0}", tableName));
txtWriter.WriteLine(string.Format("DELETE FROM {0};", tableName));
txtWriter.WriteLine("GO");
DataTableHelper.DataTable_GenerateInserts(txtWriter, dtData, tableFullName);
DataTableHelper.DataTable_GenerateInserts(txtWriter, dtData, tableName);
txtWriter.WriteLine("GO");
txtWriter.WriteLine(string.Empty);
}
}
public static void Table_GenerateCreate(Table table, TextWriter txtWriter)
{
if (table.Type != "BASE TABLE") { return; }
string tableName = string.Format("{0}.{1}", table.Schema, table.Name);
txtWriter.WriteLine(string.Format("PRINT '*** Creating tabla {0}....';", tableName));
txtWriter.WriteLine(string.Format("IF EXISTS (SELECT TOP 1 1 FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA = '{0}' AND TABLE_NAME = '{1}')", table.Schema, table.Name));
txtWriter.WriteLine("BEGIN");
txtWriter.WriteLine(string.Format(" DROP TABLE {0};", tableName));
txtWriter.WriteLine("END");
txtWriter.WriteLine("GO");
txtWriter.WriteLine(string.Format("CREATE TABLE {0} (", tableName));
bool firstColumn = true;
foreach (Column c in table.Columns)
{
if (firstColumn == false)
{
txtWriter.WriteLine(",");
}
txtWriter.Write(" [");
txtWriter.Write(c.Name);
txtWriter.Write("] ");
if (
c.Type == "nvarchar" ||
c.Type == "varchar" ||
c.Type == "char" ||
c.Type == "nchar" ||
c.Type == "binary" ||
c.Type == "varbinary" ||
c.Type == "image")
{
if (c.Size < 0)
{
txtWriter.Write(string.Format("{0}(MAX)", c.Type));
}
else
{
txtWriter.Write(string.Format("{0}({1})", c.Type, c.Size));
}
}
else
{
txtWriter.Write(c.Type);
}
if (c.Nullable)
{
txtWriter.Write(" NULL");
}
else
{
txtWriter.Write(" NOT NULL");
}
if (c.PK)
{
txtWriter.Write(" PRIMARY KEY");
}
if (c.Indentity)
{
txtWriter.Write(" IDENTITY(1,1)");
}
firstColumn = false;
}
txtWriter.WriteLine();
txtWriter.WriteLine(string.Format(");"));
txtWriter.WriteLine("GO");
txtWriter.WriteLine();
}
}
}

54
VAR.DatabaseExplorer/Code/DataAccess/ProcedureDA.cs
View File

@@ -45,6 +45,8 @@ namespace VAR.DatabaseExplorer.Code.DataAccess
{
dataAdapter = new SqlDataAdapter(@"
SELECT
sn.name ProcedureSchema,
sp.name ProcedureName,
ISNULL(smsp.definition, ssmsp.definition) AS [Definition]
FROM sys.all_objects AS sp
INNER JOIN sys.schemas sn ON sp.schema_id = sn.schema_id
@@ -53,7 +55,8 @@ namespace VAR.DatabaseExplorer.Code.DataAccess
WHERE
(sp.type = N'P' OR sp.type = N'RF' OR sp.type = N'PC' OR sp.type = N'IF' OR sp.type = N'FN' OR sp.type = N'TF')
AND
(sp.name = @name and sn.name = @schema)
(@name IS NULL OR sp.name = @name) AND
(@schema IS NULL OR sn.name = @schema)
", cnx);
dataAdapter.SelectCommand.Parameters.AddWithValue("@Name", name);
dataAdapter.SelectCommand.Parameters.AddWithValue("@Schema", schema);
@@ -78,5 +81,54 @@ namespace VAR.DatabaseExplorer.Code.DataAccess
return sbProc.ToString();
}
public static List<ProcedureDefinition> GetProcedureDefinitions(string connectionString, string schema, string name)
{
SqlDataAdapter dataAdapter;
var cnx = new SqlConnection(connectionString);
cnx.Open();
if (cnx.ServerVersion.StartsWith("10.") || cnx.ServerVersion.StartsWith("11."))
{
dataAdapter = new SqlDataAdapter(@"
SELECT
sn.name ProcedureSchema,
sp.name ProcedureName,
ISNULL(smsp.definition, ssmsp.definition) AS [Definition]
FROM sys.all_objects AS sp
INNER JOIN sys.schemas sn ON sp.schema_id = sn.schema_id
LEFT OUTER JOIN sys.sql_modules AS smsp ON smsp.object_id = sp.object_id
LEFT OUTER JOIN sys.system_sql_modules AS ssmsp ON ssmsp.object_id = sp.object_id
WHERE
(sp.type = N'P' OR sp.type = N'RF' OR sp.type = N'PC' OR sp.type = N'IF' OR sp.type = N'FN' OR sp.type = N'TF')
AND
(@name IS NULL OR sp.name = @name) AND
(@schema IS NULL OR sn.name = @schema)
", cnx);
dataAdapter.SelectCommand.Parameters.AddWithValue("@Name", (object)name ?? DBNull.Value);
dataAdapter.SelectCommand.Parameters.AddWithValue("@Schema", (object)schema ?? DBNull.Value);
}
else
{
cnx.Close();
return null;
}
var dt = new DataTable();
dataAdapter.Fill(dt);
cnx.Close();
var definitions = new List<ProcedureDefinition>();
foreach (DataRow dr in dt.Rows)
{
string strProcSchema = Convert.ToString(dr["ProcedureSchema"]);
string strProcName = Convert.ToString(dr["ProcedureName"]);
string strProcBlock = Convert.ToString(dr["Definition"]);
strProcBlock = strProcBlock.Replace("\r", "").Replace("\n", "\r\n");
definitions.Add(new ProcedureDefinition { ProcedureSchema = strProcSchema, ProcedureName = strProcName, Definition = strProcBlock });
}
return definitions;
}
}
}

7
VAR.DatabaseExplorer/Code/DataTransfer/Procedure.cs
View File

@@ -1,4 +1,5 @@
using System;
using System.Collections.Generic;
using System.Xml.Serialization;
namespace VAR.DatabaseExplorer.Code.DataTransfer
@@ -20,5 +21,11 @@ namespace VAR.DatabaseExplorer.Code.DataTransfer
[XmlElement]
public string Definition { get; set; }
[XmlIgnore]
public string DefinitionLowercase { get; set; }
[XmlIgnore]
public List<Procedure> Dependencies { get; } = new List<Procedure>();
}
}

9
VAR.DatabaseExplorer/Code/DataTransfer/ProcedureDefinition.cs Normal file
View File

@@ -0,0 +1,9 @@
namespace VAR.DatabaseExplorer.Code.DataTransfer
{
public class ProcedureDefinition
{
public string ProcedureSchema { get; set; }
public string ProcedureName { get; set; }
public string Definition { get; set; }
}
}

18
VAR.DatabaseExplorer/UI/FrmBaseDatos.cs
View File

@@ -116,7 +116,7 @@ namespace VAR.DatabaseExplorer.UI
Database database = DatabaseBL.Database_GetSchema(connectionString: _connectionString, fillTableDefinitions: true);
string fixedDatabaseName = database.Name.Replace(' ', '_');
var streamWriter = new StreamWriter(fixedDatabaseName + ".data.sql");
var streamWriter = new StreamWriter(fixedDatabaseName + ".Data.sql");
DatabaseBL.Database_ExportData(streamWriter, _connectionString, database);
streamWriter.Close();
@@ -127,21 +127,21 @@ namespace VAR.DatabaseExplorer.UI
{
Parent.Enabled = false;
Database database = DatabaseBL.Database_GetSchema(connectionString: _connectionString, fillTableDefinitions: true);
Database database = DatabaseBL.Database_GetSchema(connectionString: _connectionString, fillTableDefinitions: true, fillProcDefinitions: true);
string fixedDatabaseName = database.Name.Replace(' ', '_');
// Tables
var streamWriter = new StreamWriter(fixedDatabaseName + ".Tables.sql");
DatabaseBL.Database_ExportTables(streamWriter, _connectionString, database);
streamWriter.Close();
var streamWriterTables = new StreamWriter(fixedDatabaseName + ".Tables.sql");
DatabaseBL.Database_ExportTables(streamWriterTables, _connectionString, database);
streamWriterTables.Close();
// TODO Functions
// Routines
var streamWriterRoutines = new StreamWriter(fixedDatabaseName + ".Routines.sql");
DatabaseBL.Database_ExportFunctions(streamWriterRoutines, database);
streamWriterRoutines.Close();
// TODO Views
// TODO Procedures
Parent.Enabled = true;
}
}

1
VAR.DatabaseExplorer/VAR.DatabaseExplorer.csproj
View File

@@ -91,6 +91,7 @@
<Compile Include="Code\DataTransfer\Column.cs" />
<Compile Include="Code\DataTransfer\Database.cs" />
<Compile Include="Code\DataTransfer\Procedure.cs" />
<Compile Include="Code\DataTransfer\ProcedureDefinition.cs" />
<Compile Include="Code\DataTransfer\Server.cs" />
<Compile Include="Code\DataTransfer\Table.cs" />
<Compile Include="Code\DataTransfer\User.cs" />