Powershell访问数据库查询返回结果集

1.     function Invoke-sql {
   
2. 
   
3.       param(
   
4. 
   
5.       [Parameter(Mandatory=$true)]
   
6. 
   
7.       $sql = "select * from Kunden",[Parameter(Mandatory=$true)]
   
8. 
   
9.       $connectionstring
   
10. 
    
11.       )
    
12. 
    
13.      
    
14. 
    
15.       $db = New-Object -comObject ADODB.Connection
    
16. 
    
17.       $db.Open($connectionstring)
    
18. 
    
19.       $rs = $db.Execute($sql)
    
20. 
    
21.       while (!$rs.EOF) {
    
22. 
    
23.         $hash = @{}
    
24. 
    
25.         foreach ($fIEld in $rs.FIElds) {
    
26. 
    
27.           $hash.$($fIEld.name) = $fIEld.Value
    
28. 
    
29.         }
    
30. 
    
31.         $rs.MoveNext()     
    
32. 
    
33.         New-Object PSObject -property $hash
    
34. 
    
35.       }
    
36. 
    
37.       $rs.Close()
    
38. 
    
39.       $db.Close()
    
40. 
    
41.     }

复制代码