Используем IronPython из Transact SQL

Каким должен быть результат

select [dbo].[pyExecute]( ' import re re.findall("\d+","Всем счастья в 2013 !")[0] ' ) 

Что нам потребуется

Настройка сервера

-- Указываем серверу доверять нашей базе и нашему коду ALTER DATABASE CLR SET TRUSTWORTHY ON GO sp_configure 'show advanced options', 1; GO RECONFIGURE; GO -- Включаем выполнение управляемого кода sp_configure 'clr enabled', 1; GO RECONFIGURE; GO 

Сборка IronPython из исходников

private static string GetPrefix() { string prefix; #if SILVERLIGHT prefix = String.Empty; #else // prefix теперь всегда равен пустой строке prefix = String.Empty; /* try { prefix = Path.GetDirectoryName(Assembly.GetExecutingAssembly().Location); } catch (SecurityException) { prefix = String.Empty; } */ #endif return prefix; } 

Создание наших сборок

pyCore

CREATE ASSEMBLY PYCORE FROM N'<Полный путь к сборке…>\pyCore.dll' WITH PERMISSION_SET = UNSAFE 

pySQL

Функция CLR

public partial class UserDefinedFunctions { /// 
 /// Выполнение переданного кода на языке IronPython /// 
 /// Текст скрипта /// Результат работы скрипта [Microsoft.SqlServer.Server.SqlFunction] public static object pyFunc(string cmd) { return pyCore.pyCore.py_exec(cmd); }   /// 
 /// То же самое но с 1 аргументом /// 
 /// Текст скрипта /// Аргумент 1. Из скрипта доступен как args[0] /// Результат работы скрипта [Microsoft.SqlServer.Server.SqlFunction] public static object pyFunc1(string cmd, object arg1) { return pyCore.pyCore.py_exec(cmd,null,arg1); }   /// 
 /// То же самое но с 2 аргументами /// 
 /// Текст скрипта /// Аргумент 1. Из скрипта доступен как args[0] /// Аргумент 2. Из скрипта доступен как args[1] /// Результат работы скрипта [Microsoft.SqlServer.Server.SqlFunction] public static object pyFunc2(string cmd, object arg1, object arg2) { return pyCore.pyCore.py_exec(cmd,null,arg1,arg2); }   // pyFunc3, 4, ... , N }; 

-- Передача параметров при составлении скрипта select dbo.pyFunc('"'+name+'".upper()') from sys.all_objects -- Явная передача параметров select dbo.pyFunc1('str(args[0]).upper()',name) from sys.all_objects 

Процедура CLR

public partial class StoredProcedures { /// 
 /// Хранимая процедура CLR /// 
 /// Исполняемый код /// Результат работы Int,Число [Microsoft.SqlServer.Server.SqlProcedure] public static int pyProc(string cmd) { var scope = pyCore.pyCore.CreateScope(); // Передаем скрипту ссылку на SqlPipe scope.SetVariable("Pipe", SqlContext.Pipe); return (int)pyCore.pyCore.py_exec(cmd,scope); } }; 

Агрегирующая функция

Создание сборки pySQL в базе и объявление функций

CREATE ASSEMBLY PYSQL FROM N'<Полный путь к сборке…>\pySQL.dll' WITH PERMISSION_SET = UNSAFE 

-- Вариант передачи параметра, путем составления скрипта по частям CREATE FUNCTION [dbo].[pyFunc] (@cmd nvarchar(MAX)) RETURNS sql_variant AS EXTERNAL NAME PYSQL.[UserDefinedFunctions].[pyFunc]; GO  -- Вариант с явной передачей параметров CREATE FUNCTION [dbo].[pyFunc1] (@cmd nvarchar(MAX), @arg1 sql_variant) RETURNS sql_variant AS EXTERNAL NAME PYSQL.[UserDefinedFunctions].[pyFunc1]; GO  -- Вариант с явной передачей параметров CREATE FUNCTION [dbo].[pyFunc2] (@cmd nvarchar(MAX), @arg1 sql_variant, @arg2 sql_variant) RETURNS sql_variant AS EXTERNAL NAME PYSQL.[UserDefinedFunctions].[pyFunc2]; GO  -- Хранимая процедура CREATE PROCEDURE pyProc (@code nvarchar(MAX)) AS EXTERNAL NAME PYSQL.StoredProcedures.pyProc GO  -- Агрегирующая функция CREATE AGGREGATE [dbo].[pyAggregate] ( @value sql_variant, @init nvarchar(MAX), @accumulate nvarchar(MAX), @merge nvarchar(MAX), @terminate nvarchar(MAX), @save nvarchar(MAX), @restore nvarchar(MAX) ) RETURNS sql_variant EXTERNAL NAME PYSQL.[pyAggregate]; GO 

Результаты

Функция

select [dbo].[pyFunc]( ' import re mails = re.findall("[.\\-_a-z0-9]+@(?:[a-z0-9][\\-a-z0-9]+\\.)+[a-z]{2,6}","'+doc+'") result = "Найдено: " for mail in mails: result += mail + "," result[:-1] ' ) from ( select 'В этой строке нужно найти somebody@gmail.com' doc union select 'А в этой через запятую person1@mail.ru и person2@list.ru' doc ) SAMPLE_DATA 

select [dbo].[pyFunc1]( ' import re mails = re.findall("[.\\-_a-z0-9]+@(?:[a-z0-9][\\-a-z0-9]+\\.)+[a-z]{2,6}",str(args[0])) result = "Найдено: " for mail in mails: result += mail + "," result[:-1] ', SAMPLE_DATA.doc ) from ( select 'В этой строке нужно найти somebody@gmail.com' doc union select 'А в этой через запятую person1@mail.ru и person2@list.ru' doc ) SAMPLE_DATA 

declare @InputFromula as nvarchar(MAX) SET @InputFromula = 'math.log(math.cosh(int(args[0]))/math.e,int(args[1]))' select [dbo].[pyFunc2] ( 'import math '+@InputFromula, 100,5 ) 

Хранимая процедура

exec pyProc ' import clr clr.AddReference("System.Data") from Microsoft.SqlServer.Server import * from System.Data import * from System import DateTime  Pipe.Send("Пишем сообщение: поехали!") metadata = ( SqlMetaData("Имя работника", SqlDbType.NVarChar, 12), SqlMetaData("Ожидаемая заработная плата", SqlDbType.Int), SqlMetaData("Ожидаемая дата повышения", SqlDbType.DateTime) ) record = SqlDataRecord(metadata) record.SetString(0, "bocharovf"); record.SetInt32(1, 1000000); record.SetDateTime(2, DateTime.Now); #выдаем табличный результат Pipe.Send(record) 1 ' 

Агрегирующая функция

select dbo.pyAggregate ( -- Агрегируемое значение SAMPLE_DATA.[language], -- Инициализация 'data = ""', -- Аккумуляция 'data += str(value) + ", "', '# nop', -- Вывод результата 'data[:-2]', -- Сериализация 'writer.Write(str(data))', -- Десереализация 'data = reader.ReadString()' ) as Languages ,SAMPLE_DATA.IsUsed from ( select 'C#' [language], 'Используется в статье' IsUsed union select 'T-SQL', 'Используется в статье' union select 'IronPython', 'Используется в статье' union select 'Cobol', 'Не используется в статье' union select 'Ada', 'Не используется в статье' union select 'Lisp', 'Не используется в статье' union select 'Fortran', 'Не используется в статье' ) SAMPLE_DATA group by SAMPLE_DATA.IsUsed 

Производительность

Безопасность

exec pyProc ' from System.Net import WebClient content = WebClient().DownloadString("http://habrahabr.ru/") Pipe.Send(content[:4000]) 1 ' 

Вместо заключения