Discussion :

[SQL_EVAN]

Salut!

J'espère que vous pouvez m'aider

Je crée un système de copie de tables dynamique d'un server datafactory vers un server web (des tables SSRS précalculées)

Pour cela j'ai créé une table qui stocke les tables prête à être copier (avec leur base de données source aussi)

Maintanent dans SSIS je veux:

1.Créer un variable de type objet pour stocker les résultats de mon SELECT (les noms de tables à exporter et leur base de données (TABLE_LIB, DATABASE_LIB)
2. Boucler avec un foreach sur chaque table (recuperer ThisDataBase et ThisTable)
3. Créer un flux de données avec source et destination dynamique en fonction de ThisDataBase et ThisTable

Etapes 1 et 2 sont faites et marchent. Cependant j'ai du mal à faire l'étape 3 puisque je n'ai forcémment pas les même nombre de colonnes pour chaque itération de Foreach et donc je ne peux pas mapper la source et destination.

Avez-vous des idées?? HELP!

[SQL_EVAN]

pour info, je voulais pas le faire par fichier pour augmenté les perfs.

[d.joubert]

Tu pourras pas le faire avec un data flow task.

Par contre, dans ton cas, si c'est bien du SQL Server des deux côtés, j'essaierai bien un "Transfer SQL Server Objects Task"

[FrancoisJehl]

Avez-vous des idées?? HELP!

Ne fait pas de data flow.
Ne fait pas de data flow.
Ne fait pas de data flow.
En SMO tu serais plus à l'aise. http://blogs.msdn.com/b/mattm/archiv...ects-task.aspx

[SQL_EVAN]

C'est gentil merci. Mais j'ai essayé une tâche de transfert d'objets SQL Server.

Le problème c'est que ma source est toujour la même instance mais la base de données et la table peux varier...

J'ai déjà les noms de la base et la table en tant que variable string. Comment continuer? J'ai pu mapper le nom de la base source dans Expressions (SourceDatabase : @[User::ThisDataBase]) mais comment faire pour le nom de la table? Je ne vois pas l'option de nom de table....

[d.joubert]

Avec une expression sur la propriété TablesList, ça ne marche pas?

[SQL_EVAN]

Il n'y a pas de propriété TablesList. J'ai que CopyAllTables ou peut être Name mais je sais pas à quoi ça correspond. C'est quand même assez limité si on peut pas faire ce genre de chose

[d.joubert]

Ah ouais tiens c'est marrant, y a bien la propriété TablesList mais on peut pas lui assigner une expression (alors qu'on peut sur 2008R2)

Bon bah sinon, faut construire les requêtes dans un SQL Task

[FrancoisJehl]

Non mais sinon - pour l'avoir déjà fait - une script task de 10 lignes et c'est plié. Y a trop de trucs manquants dans la Transfer Objects Task.

[SQL_EVAN]

Oui je pense que le seul option est le script, par contre j'ai aucune idée comment le faire.

Pourriez vous m'aider à l'écrire s'il vous plaît?

En gros j'ai en statique l'instance source et la base et instance destination. J'ai les variables @ThisDataBase et @ThisTable dans le boucle where. La table peut avoir le même nom sur la source et le destination. /cry

[FrancoisJehl]

Même script que celui posté précédemment. Simplement la destDB doit être référencée par un autre objet SMO de type Server (ici les deux db référencent le même Server). Ensuite tu instancies un objet Transfer et ça roule.

[SQL_EVAN]

OK Je comprends, J'ai fait un premier script. Cependant il y a deux problèmes.

1. Je veux pas copier toutes les tables mais plutôt @ThisTable et le fonction xfr.ObjectList n'accepte que le type ArrayList.

2. Pour assigner les serveurs nommés il faut faire comment? J'ai tenté

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
Dim srvDest As Server = "MonServeur\MonInstance"
srvDest = New Server

mais cela n'est pas accepté en tant que string.

Voici mon script entier

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
 
#Region "Imports"
Imports System
Imports System.Data
Imports System.Math
Imports Microsoft.SqlServer.Dts.Runtime
Imports Microsoft.SqlServer.Management.Smo
Imports Microsoft.SqlServer.Management.Common
 
#End Region
 
 
<Microsoft.SqlServer.Dts.Tasks.ScriptTask.SSISScriptTaskEntryPointAttribute()> _
<System.CLSCompliantAttribute(False)> _
Partial Public Class ScriptMain
    Inherits Microsoft.SqlServer.Dts.Tasks.ScriptTask.VSTARTScriptObjectModelBase
 
 
 
 
    Public Sub Main()
 
 
        Dts.Variables("User::ThisDataBase").Value = Dts.Variables("User::ThisDataBase").Value
        Dts.Variables("User::ThisTable").Value = Dts.Variables("User::ThisTable").Value
 
        Dim dbSourceName As String = ("User::ThisDataBase")
        Dim dbDestName As String = "Publication_REPORTS"
 
 
 
 
 
        Dim srvSource As Server = "MonServeurSource\MonInstanceSource"
 
        srvSource = New Server
 
 
        Dim srvDest As Server = "MonServeurDest\MonInstanceDest"
 
        srvDest = New Server
 
 
 
 
 
        Dim dbSource As Database
 
        dbSource = srvSource.Databases(dbSourceName)
 
        Dim dbDest As Database
 
        dbDest = srvDest.Databases(dbDestName)
 
 
 
 
 
        Dim xfr As Transfer
 
        xfr = New Transfer(dbSource)
 
        xfr.CopyAllTables = False
 
        xfr.ObjectList = ("User::ThisTable")
 
        xfr.Options.WithDependencies = True
 
        xfr.Options.ContinueScriptingOnError = True
 
        xfr.DestinationDatabase = dbDest.Name
 
        xfr.DestinationServer = srvDest.Name
 
        xfr.DestinationLoginSecure = True
 
        xfr.CopySchema = True
 
 
 
        'Include data
 
        xfr.CopyData = True
 
 
 
        'Execute the transfer
 
        xfr.TransferData()
 
 
 
        Dts.TaskResult = Dts.Results.Success
 
    End Sub
 
#Region "ScriptResults declaration"
    'This enum provides a convenient shorthand within the scope of this class for setting the
    'result of the script.
 
    'This code was generated automatically.
    Enum ScriptResults
        Success = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Success
        Failure = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Failure
    End Enum
 
#End Region
 
End Class

[SQL_EVAN]

Ok j'ai réussi à faire compilé le code. Cependant, j'ai une erreur. Je vous donne l'erreur et le code. J'avoue que je comprend rien du tout :

Erreur:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
 à System.RuntimeMethodHandle._InvokeMethodFast(IRuntimeMethodInfo method, Object target, Object[] arguments, SignatureStruct& sig, MethodAttributes methodAttributes, RuntimeType typeOwner)
   à System.RuntimeMethodHandle.InvokeMethodFast(IRuntimeMethodInfo method, Object target, Object[] arguments, Signature sig, MethodAttributes methodAttributes, RuntimeType typeOwner)
   à System.Reflection.RuntimeMethodInfo.Invoke(Object obj, BindingFlags invokeAttr, Binder binder, Object[] parameters, CultureInfo culture, Boolean skipVisibilityChecks)
   à System.Reflection.RuntimeMethodInfo.Invoke(Object obj, BindingFlags invokeAttr, Binder binder, Object[] parameters, CultureInfo culture)
   à System.RuntimeType.InvokeMember(String name, BindingFlags bindingFlags, Binder binder, Object target, Object[] providedArgs, ParameterModifier[] modifiers, CultureInfo culture, String[] namedParams)
   à Microsoft.SqlServer.Dts.Tasks.ScriptTask.VSTATaskScriptingEngine.ExecuteScript()

Et code :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
 
#Region "Imports"
Imports System
Imports System.Data
Imports System.Math
Imports Microsoft.SqlServer.Dts.Runtime
Imports Microsoft.SqlServer.Management.Smo
Imports Microsoft.SqlServer.Management.Common
 
#End Region
 
 
<Microsoft.SqlServer.Dts.Tasks.ScriptTask.SSISScriptTaskEntryPointAttribute()> _
<System.CLSCompliantAttribute(False)> _
Partial Public Class ScriptMain
    Inherits Microsoft.SqlServer.Dts.Tasks.ScriptTask.VSTARTScriptObjectModelBase
 
 
 
 
    Public Sub Main()
 
 
        Dts.Variables("User::ThisDataBase").Value = Dts.Variables("User::ThisDataBase").Value
        Dts.Variables("User::ThisTable").Value = Dts.Variables("User::ThisTable").Value
 
        Dim dbSourceName As String = ("User::ThisDataBase")
        Dim dbDestName As String = "Publication_REPORTS"
 
 
 
 
 
        Dim srvSource As Server
 
        srvSource = New Server("MonServeurSource\MonInstanceSource")
 
 
        Dim srvDest As Server
 
        srvDest = New Server("MonServeurDest\MonInstanceDest")
 
 
        Dim ArrayObjet As ArrayList
 
        ArrayObjet(0) = Dts.Variables("User::ThisTable").Value
 
 
 
        Dim dbSource As Database
 
        dbSource = srvSource.Databases(dbSourceName)
 
        Dim dbDest As Database
 
        dbDest = srvDest.Databases(dbDestName)
 
 
 
 
 
        Dim xfr As Transfer
 
        xfr = New Transfer(dbSource)
 
        xfr.CopyAllTables = False
 
        xfr.ObjectList = ArrayObjet
 
        xfr.Options.WithDependencies = False
 
        xfr.Options.ContinueScriptingOnError = True
 
        xfr.DestinationDatabase = dbDest.Name
 
        xfr.DestinationServer = srvDest.Name
 
        xfr.DestinationLoginSecure = True
 
        xfr.CopySchema = True
 
 
 
        'Include data
 
        xfr.CopyData = True
 
 
 
        'Execute the transfer
 
        xfr.TransferData()
 
 
 
        Dts.TaskResult = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Success
 
    End Sub
 
#Region "ScriptResults declaration"
    'This enum provides a convenient shorthand within the scope of this class for setting the
    'result of the script.
 
    'This code was generated automatically.
    Enum ScriptResults
        Success = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Success
        Failure = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Failure
    End Enum
 
#End Region
 
End Class

[rw72000]

L'erreur que tu copies est incomplète.
Il manque les premières lignes contenant l'erreur. Néanmoins, dans ton code, cette ligne

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

Dim dbSourceName AS String = ("User::ThisDataBase")

devrait sans doute être remplacée par

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

Dim dbSourceName AS String = Dts.VARIABLES("User::ThisDataBase").Value

[SQL_EVAN]

Merci, j'ai mis ça à jour.

Pour l'erreur c'est tout ce que Visual Studio me donne. Voici la capture

[SQL_EVAN]

OK j'ai réparé les exceptions et j'ai réussi à faire copier les deux tables en question. Cependant, j'ai besoin de changer le comportement un peu mais je ne trouve pas comment.

En gros il faut copier la table source en ajoutant un suffixe sur la fin du nom "_bis" (ainsi que la clé primaire). Une fois les données sont copiées et la PK créée en _bis je vais faire un drop de l'ancienne table et un sp_rename pour la remplacer avec la table _bis.

Ceci est pour eviter le temps de coupure pendant la livraison.

Donc ma question est :

Comment faire pour avoir un nom de table et PK différent sur la source et la destination toute en gardant le mapping avec la classe transfer??

[SQL_EVAN]

Bon beh je pense que ce n'est pas possible avec la classe transfer. Je vais faire avec. Merci de votre aide