Manquant de la bibliothèque de référence de connexion OLEDB types
J'ai eu le morceau de code suivant à partir de SSIS Blog de l'Équipe pour lancer la connexion OLEDB type de sorte qu'il peut être utilisé par les AcquireConnection () la méthode. Maintenant, je ne suis pas sûr pourquoi, la Dts.Connexions partie ne fonctionne pas. Je ne sais pas la bibliothèque que j'aurais à ajouter pour le faire fonctionner. J'ai ajouté les plus importants, y compris le Dts.RuntimeWrap. S'il vous plaît laissez-moi savoir si vous avez besoin de plus d'informations sur la question.
ConnectionManager cm = Dts.Connections["oledb"];
Microsoft.SqlServer.Dts.Runtime.Wrapper.IDTSConnectionManagerDatabaseParameters100 cmParams = cm.InnerObject as Microsoft.SqlServer.Dts.Runtime.Wrapper.IDTSConnectionManagerDatabaseParameters100;
OleDbConnection conn = cmParams.GetConnectionForSchema() as OleDbConnection;MODIFIER
Ci-dessous le code complet de ce composant.
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using Microsoft.SqlServer.Dts.Runtime;
using System.Data.OleDb;
using System.Data.Common;
using System.Linq;
using System.Configuration;
using System.Collections;
//using System.Data.OleDb;
namespace AOC.SqlServer.Dts.Tasks
{
[DtsTask(
DisplayName = "Custom Logging Task",
Description = "Writes logging info into a table")]
public class CustomLoggingTask : Task
{
private string _packageName;
private string _taskName;
private string _errorCode;
private string _errorDescription;
private string _machineName;
private double _packageDuration;
private string _connectionName;
private string _eventType;
private string _executionid;
private DateTime _handlerdatetime;
private string _uid;
public string ConnectionName
{
set
{
_connectionName = value;
}
get
{
return _connectionName;
}
}
public string Event
{
set
{
_eventType = value;
}
get
{
return _eventType;
}
}
public override DTSExecResult Validate(Connections connections, VariableDispenser variableDispenser, IDTSComponentEvents componentEvents, IDTSLogging log)
{
const string METHOD_NAME = "CustomLoggingTask-Validate";
try
{
if (string.IsNullOrEmpty(_eventType))
{
componentEvents.FireError(0, METHOD_NAME, "The event property must be specified", "", -1);
return DTSExecResult.Failure;
}
if (string.IsNullOrEmpty(_connectionName))
{
componentEvents.FireError(0, METHOD_NAME, "No connection has been specified", "", -1);
return DTSExecResult.Failure;
}
//SqlConnection connection = connections[_connectionName].AcquireConnection(null) as SqlConnection;
DbConnection connection = connections[_connectionName].AcquireConnection(null) as DbConnection;
ConnectionManager cm = Dts.Connections["oledb"];
Microsoft.SqlServer.Dts.Runtime.Wrapper.IDTSConnectionManagerDatabaseParameters100 cmParams = cm.InnerObject as Microsoft.SqlServer.Dts.Runtime.Wrapper.IDTSConnectionManagerDatabaseParameters100;
OleDbConnection conn = cmParams.GetConnectionForSchema() as OleDbConnection;
if (connection == null)
{
componentEvents.FireError(0, METHOD_NAME, "The connection is not a valid ADO.NET connection", "", -1);
return DTSExecResult.Failure;
}
if (!variableDispenser.Contains("System::SourceID"))
{
componentEvents.FireError(0, METHOD_NAME, "No System::SourceID variable available. This task can only be used in an Event Handler", "", -1);
return DTSExecResult.Failure;
}
return DTSExecResult.Success;
}
catch (Exception exc)
{
componentEvents.FireError(0, METHOD_NAME, "Validation Failed: " + exc.ToString(), "", -1);
return DTSExecResult.Failure;
}
}
public override DTSExecResult Execute(Connections connections, VariableDispenser variableDispenser, IDTSComponentEvents componentEvents, IDTSLogging log, object transaction)
{
try
{
string commandText =
@"INSERT INTO SSISLog (EventType, PackageName, TaskName, EventCode, EventDescription, PackageDuration, Host, ExecutionID, EventHandlerDateTime,UID)
VALUES (@EventType, @PackageName, @TaskName, @EventCode, @EventDescription, @PackageDuration, @Host, @Executionid, @handlerdatetime,@uid)";
ReadVariables(variableDispenser);
DbConnection connection = connections[_connectionName].AcquireConnection(transaction) as DbConnection;
//SqlConnection connection = (SqlConnection)connections[_connectionName].AcquireConnection(transaction);
DbCommand command = null;
//using (SqlCommand command = new SqlCommand())
if (connection is SqlConnection)
command = new SqlCommand();
else if (connection is OleDbConnection)
command = new OleDbCommand();
{
command.CommandText = commandText;
command.CommandType = CommandType.Text;
command.Connection = connection;
command.Parameters.Add(new SqlParameter("@EventType", _eventType));
command.Parameters.Add(new SqlParameter("@PackageName", _packageName));
command.Parameters.Add(new SqlParameter("@TaskName", _taskName));
command.Parameters.Add(new SqlParameter("@EventCode", _errorCode ?? string.Empty));
command.Parameters.Add(new SqlParameter("@EventDescription", _errorDescription ?? string.Empty));
command.Parameters.Add(new SqlParameter("@PackageDuration", _packageDuration));
command.Parameters.Add(new SqlParameter("@Host", _machineName));
command.Parameters.Add(new SqlParameter("@ExecutionID", _executionid));
command.Parameters.Add(new SqlParameter("@handlerdatetime", _handlerdatetime));
command.Parameters.Add(new SqlParameter("@uid", _uid));
command.ExecuteNonQuery();
}
connection.Close();
return DTSExecResult.Success;
}
catch (Exception exc)
{
componentEvents.FireError(0, "CustomLoggingTask-Execute", "Task Errored: " + exc.ToString(), "", -1);
return DTSExecResult.Failure;
}
}
private void ReadVariables(VariableDispenser variableDispenser)
{
variableDispenser.LockForRead("System::StartTime");
variableDispenser.LockForRead("System::PackageName");
variableDispenser.LockForRead("System::SourceName");
variableDispenser.LockForRead("System::MachineName");
variableDispenser.LockForRead("System::ExecutionInstanceGUID");
variableDispenser.LockForRead("System::EventHandlerStartTime");
variableDispenser.LockForRead("User::UID");
bool includesError = variableDispenser.Contains("System::ErrorCode");
if (includesError)
{
variableDispenser.LockForRead("System::ErrorCode");
variableDispenser.LockForRead("System::ErrorDescription");
}
Variables vars = null;
variableDispenser.GetVariables(ref vars);
DateTime startTime = (DateTime)vars["System::StartTime"].Value;
_packageDuration = DateTime.Now.Subtract(startTime).TotalSeconds;
_packageName = vars["System::PackageName"].Value.ToString();
_taskName = vars["System::SourceName"].Value.ToString();
_machineName = vars["System::MachineName"].Value.ToString();
_executionid = vars["System::ExecutionInstanceGUID"].Value.ToString();
_handlerdatetime = (DateTime)vars["System::EventHandlerStartTime"].Value;
_uid = vars["User::UID"].Value.ToString();
if (includesError)
{
_errorCode = vars["System::ErrorCode"].Value.ToString();
_errorDescription = vars["System::ErrorDescription"].Value.ToString();
}
//release the variable locks.
vars.Unlock();
//reset the dispenser
variableDispenser.Reset();
}
}
}- quelle erreur il jette? J'ai testé le code que vous avez souligné et semble correcte.
- J'ai eu un problème similaire en utilisant les connexions Oledb. J'ai abandonné et peu utilisé ADO.net connexions et a cessé d'avoir ces problèmes. Ne sais pas si c'est possible dans votre cas, si...
- Le message d'erreur que j'obtiens est "Erreur 1 le type ou Le nom d'espace de noms 'Connexions' n'existe pas dans l'espace de noms 'AOC.SqlServer.Dts' (vous manque une référence d'assembly?)" J'ai vérifié toutes mes références et des trucs, mais ne sais pas ce qui me manque.
- Mmm c'est bizarre. Est votre tâche de script principal de la classe de l'extension de
Microsoft.SqlServer.Dts.Tasks.ScriptTask.VSTARTScriptObjectModelBase? Pouvez-vous montrer votre tâche de script code? - Cette pièce ne marche pas appartenir à une tâche de script. Je suis en train de mettre en œuvre ce à l'intérieur d'un composant de journalisation personnalisé. Je suis coller le code entier comme une modification.
Vous devez vous connecter pour publier un commentaire.
Avec le code que vous avez posté, j'ai enfin compris ce que vous essayez d'accomplir.
Ce sont les choses que j'ai fait pour le faire fonctionner:
A) L'erreur de compilation que vous recevez:
est tout simplement parce que la façon dont vous essayez d'avoir le oledb gestionnaire de connexion:
La
Dtsobjet est une ressource disponible dans la tâche de script composant. Vous devez remplacer cette ligne par:Que j'ai vu dans votre code que vous avez accès à un
Connection Managerde cette façon, donc c'était peut-être quelque chose que vous venez de gauche derrière.B) afin De valider si le gestionnaire de connexion est soit un ADO.NET gestionnaire de connexion ou un OLEDB un, changé cette partie de votre code:
Premièrement, on ajoute une variable privée au niveau de la classe pour stocker la connexion:
et puis, la modification de la validation pour vérifier si la connexion est ADO.NET et dans le cas où il n'est pas, pour vérifier si il est OLEDB:
Noter que j'ai remplacé le codé en dur
"oledb"avec le_connectionNamevariable, et aussi modifié la chaîne d'erreur lors de l'_connectionest nulle dans les deux cas.C) Pour exécuter la commande à l'aide d'un fournisseur OLEDB ont été nécessaire les modifications suivantes:
_connectionvariable, qui détient le récupérés précédemment connexion.OleDbParameterau lieu deSqlParameter.VALUESpartie dans leINSERTinstruction de commande doit être modifié pour utiliser?.D) C'est le travail complet code:
Juste pour mémoire, je vous laisse quelques liens que j'ai trouvé utile pour développer, déployer et déboguer des composants personnalisés (mais peut-être que vous avez déjà allés à travers eux!):
http://bennyaustin.wordpress.com/2009/06/30/steps-to-build-and-deploy-custom-ssis-components/
http://msdn.microsoft.com/en-us/library/ms403356%28v=sql.105%29.aspx
http://toddmcdermid.blogspot.com.ar/2009/06/converting-your-script-task-into-custom_22.html
Acclamations.