Можно ли использовать SqlGeography с Linq to Sql? - PullRequest
Новая
       48

Можно ли использовать SqlGeography с Linq to Sql?

10 голосов
/ 17 мая 2010

У меня было довольно много проблем при попытке использовать Microsoft.SqlServer.Types.SqlGeography. Я прекрасно знаю, что поддержка этого в Linq to Sql не велика. Я пробовал множество способов, начиная с того, что было бы ожидаемым способом (тип базы данных geography, тип CLR SqlGeography). Это приводит к NotSupportedException, который широко обсуждается в блогах.

Затем я пошел по пути обработки столбца geography как varbinary(max), поскольку geography - это UDT, хранящийся в двоичном виде. Кажется, это работает нормально (с некоторыми двоичными методами расширения для чтения и записи).

Однако сейчас я сталкиваюсь с довольно неясной проблемой, которая, похоже, не случалась со многими другими людьми.

System.InvalidCastException: Невозможно привести объект типа 'Microsoft.SqlServer.Types.SqlGeography' к типу 'System.Byte []'.

Эта ошибка выдается из ObjectMaterializer при итерации по запросу. Похоже, это происходит только тогда, когда таблицы, содержащие столбцы географии, неявно включены в запрос (т. Е. Используются свойства EntityRef<> для объединения).

System.Data.Linq.SqlClient.ObjectReaderCompiler.ObjectReader`2.MoveNext ()

Мой вопрос: если я получаю столбец geography как varbinary(max), я могу ожидать обратную ошибку: невозможно привести byte[] к SqlGeography. Это я бы понял. Это я не У меня есть некоторые свойства в частичных классах LINQ to SQL, которые скрывают двоичное преобразование ... это может быть проблемой?

Любая помощь приветствуется, и я знаю, что, вероятно, недостаточно информации.

Дополнительно:

  • Столбец geography в Visual Studio dbml Designer с «Типом данных сервера» = geography генерирует эту ошибку: The specified type 'geography' is not a valid provider type.
  • Столбец geography в Visual Studio dbml Designer без «Типа данных сервера» генерирует эту ошибку: Could not format node 'Value' for execution as SQL.

Ответы [ 2 ]

16 голосов
/ 03 июня 2010

Если все, что вы хотите сделать с SqlGeography, это отслеживать точки и использовать пространственные индексы SQL Server 2008, вы можете, как отмечали другие, скрыть столбец пространственных данных из Linq в SQL и использовать UDF или хранимые процедуры. Предположим, что у вас есть таблица AddressFields, которая включает поля широты и долготы. Добавьте эту таблицу в ваш файл DBML и напишите любой код, который вы хотите, который устанавливает поля широты и долготы. Затем приведенный ниже код SQL добавит поле Geo geogarphy в эту таблицу и создаст триггер в базе данных, который автоматически устанавливает поле Geo на основе полей широты и долготы. Между тем, приведенный ниже код также создает другие полезные функции UDF и хранимые процедуры: DistanceBetween2 (у меня уже был DistanceBetween) возвращает расстояние между адресом, представленным в AddressField, и указанной парой широта / долгота; DistanceWithin возвращает различные поля из всех AddressFields в пределах указанного мили; UDFDistanceWithin делает то же самое, что и пользовательская функция (полезно, если вы хотите встроить это в запрос большего размера); и UDFNearestNeighbors возвращает поля из AddressField, соответствующие указанному количеству соседей, ближайших к конкретной точке. (Одна из причин использования UDFNearestNeighbors заключается в том, что SQL Server 2008 не будет оптимизировать использование пространственного индекса, если вы просто вызовете order, вызвав DistanceBetween2.)

Вам нужно будет настроить это, изменив AddressFields на свою таблицу и настроив поля из этой таблицы, которые вы хотите вернуть (посмотрите в коде ссылки на AddressFieldID). Затем вы можете запустить это в своей базе данных и скопировать полученные хранимые процедуры и пользовательские функции в ваш DBML, а затем использовать их в запросах. В целом, это позволяет довольно легко воспользоваться пространственным индексом точек. 

-----------------------------------------------------------------------------------------

- [1] 

--INITIAL AUDIT
select * from dbo.AddressFields
GO
--ADD COLUMN GEO
IF EXISTS (SELECT name FROM sysindexes WHERE name = 'SIndx_AddressFields_geo')
DROP INDEX SIndx_AddressFields_geo ON AddressFields
GO
IF EXISTS (SELECT b.name FROM sysobjects a, syscolumns b 
            WHERE a.id = b.id and a.name = 'AddressFields' and b.name ='Geo' and a.type ='U' )  
ALTER TABLE AddressFields DROP COLUMN Geo

GO
alter table AddressFields add Geo geography

- [2] * * +1010 --SET GEO VALUE GO UPDATE AddressFields SET Geo = geography::STPointFromText('POINT(' + CAST([Longitude] AS VARCHAR(20)) + ' ' + CAST([Latitude] AS VARCHAR(20)) + ')', 4326) - [3] ИНДЕКС СОЗДАНИЯ 

IF EXISTS (SELECT name FROM sysindexes WHERE name = 'SIndx_AddressFields_geo')
DROP INDEX SIndx_AddressFields_geo ON AddressFields

GO

CREATE SPATIAL INDEX SIndx_AddressFields_geo 
   ON AddressFields(geo)

--UPDATE STATS
UPDATE STATISTICS AddressFields

--AUDIT
GO
select * from dbo.AddressFields

- [4] CREATE PROCEDURE USP_SET_GEO_VALUE PARA 1 LATITUDE 2 LONGITUDE 

IF EXISTS (SELECT name FROM sysobjects  WHERE name = 'USPSetGEOValue' AND type = 'P')
    DROP PROC USPSetGEOValue
GO

GO
CREATE PROC USPSetGEOValue @latitude decimal(18,8), @longitude decimal(18,8)
AS
    UPDATE AddressFields
    SET Geo = geography::STPointFromText('POINT(' + CAST(@longitude AS VARCHAR(20)) + ' ' + 
                    CAST(@latitude AS VARCHAR(20)) + ')', 4326)
    WHERE [Longitude] =@longitude and [Latitude] = @latitude

GO
--TEST
EXEC USPSetGEOValue 38.87350500,-76.97627500

GO

- [5] СОЗДАТЬ ТРИГГЕР НА ЛАТ / ИЗМЕНЕНИЕ ДЛИННОГО ЗНАЧЕНИЯ / ВСТАВИТЬ ---> УСТАНОВИТЬ ГЕОКОД 

IF EXISTS (SELECT name FROM sysobjects  WHERE name = 'TRGSetGEOCode' AND type = 'TR')
DROP TRIGGER TRGSetGEOCode

GO

CREATE TRIGGER TRGSetGEOCode 
ON AddressFields
AFTER INSERT,UPDATE
AS
    DECLARE @latitude decimal(18,8), @longitude decimal(18,8)

    IF ( UPDATE (Latitude) OR UPDATE (Longitude) )
        BEGIN

            SELECT @latitude = latitude ,@longitude = longitude from inserted

            UPDATE AddressFields
            SET Geo = geography::STPointFromText('POINT(' + CAST(@longitude AS VARCHAR(20)) + ' ' + 
                        CAST(@latitude AS VARCHAR(20)) + ')', 4326)
            WHERE [Longitude] =@longitude and [Latitude] = @latitude
        END 
    ELSE
        BEGIN
            SELECT @latitude = latitude ,@longitude = longitude from inserted

            UPDATE AddressFields
            SET Geo = geography::STPointFromText('POINT(' + CAST(@longitude AS VARCHAR(20)) + ' ' + 
                        CAST(@latitude AS VARCHAR(20)) + ')', 4326)
            WHERE [Longitude] =@longitude and [Latitude] = @latitude
        END 
GO

- [6] CREATE PROC USP_SET_GEO_VALUE_INITIAL_LOAD ----> ONE TIME RUN ONLY 

IF EXISTS (SELECT name FROM sysobjects  WHERE name = 'USPSetAllGeo' AND type = 'P')
    DROP PROC USPSetAllGeo
GO

CREATE PROC USPSetAllGeo
AS
UPDATE AddressFields
SET Geo = geography::STPointFromText('POINT(' + CAST([Longitude] AS VARCHAR(20)) + ' ' + 
                    CAST([Latitude] AS VARCHAR(20)) + ')', 4326)

GO

- [7] EXISTING PROC DistanceBetween, который возвращает расстояние между двумя указанными точками

- по парам координат широта / долгота. - ALTER PROC DistanceBetween2 

IF EXISTS (SELECT name FROM sysobjects  WHERE name = 'DistanceBetween2' AND type = 'FN')
DROP FUNCTION DistanceBetween2

GO

CREATE FUNCTION [dbo].[DistanceBetween2] 
(@AddressFieldID as int, @Lat1 as real,@Long1 as real)
RETURNS real
AS
BEGIN

    DECLARE @KMperNM float = 1.0/1.852;

    DECLARE @nwi geography =(select geo from addressfields where AddressFieldID  = @AddressFieldID)

    DECLARE @edi geography = geography::STPointFromText('POINT(' + CAST(@Long1 AS VARCHAR(20)) + ' ' + 
                                CAST(@Lat1 AS VARCHAR(20)) + ')', 4326)

    DECLARE @dDistance as real = (SELECT (@nwi.STDistance(@edi)/1000.0) * @KMperNM)

    return (@dDistance);  

END

GO --Test

Расстояние между 2 12159,40,75889600, -73,99228900

- [8] СОЗДАНИЕ ПРОЦЕДУРЫ USPРасстояние

- ВОЗВРАЩАЕТ СПИСОК АДРЕСОВ ИЗ таблицы AddressFields

ЕСЛИ СУЩЕСТВУЕТ (ВЫБЕРИТЕ имя ОТ СИСТЕМНЫХ ОБЪЕКТОВ, ГДЕ имя = 'USPDistanceWithin' И тип = 'P') ПРОЦЕДУРА УДАЛЕНИЯ USPРасстояние 

GO

CREATE PROCEDURE [dbo].USPDistanceWithin 
(@lat as real,@long as real, @distance as float)
AS
BEGIN

    DECLARE @edi geography = geography::STPointFromText('POINT(' + CAST(@Long AS VARCHAR(20)) + ' ' + 
                                CAST(@Lat AS VARCHAR(20)) + ')', 4326)

    SET @distance = @distance * 1609.344 -- convert distance into meter

    select 
         AddressFieldID
        ,FieldID
        ,AddressString
        ,Latitude
        ,Longitude
        ,LastGeocode
        ,Status
        --,Geo
    from 
        AddressFields a WITH(INDEX(SIndx_AddressFields_geo))
    where 
        a.geo.STDistance(@edi) < = @Distance 

END

GO

- ТЕСТ

- в пределах 3 миль USPDistanceWithin 38.90606200, -76,92943500,3 ИДТИ - в 5 милях USPDistanceWithin 38.90606200, -76,92943500,5 ИДТИ - в 10 милях USPDistanceWithin 38.90606200, -76,92943500,10

- [9] СОЗДАТЬ ФУНКЦИЮ FNDistanceWithin

- ВОЗВРАЩАЕТ СПИСОК АДРЕСОВ ИЗ таблицы AddressFields

ЕСЛИ СУЩЕСТВУЕТ (ВЫБЕРИТЕ имя ОТ СИСТЕМНЫХ ОБЪЕКТОВ, ГДЕ имя = 'UDFDistanceWithin' И тип = 'TF') DROP FUNCTION UDFDistanceWithin 

GO

CREATE FUNCTION UDFDistanceWithin 
(@lat as real,@long as real, @distance as real)
RETURNS @AddressIdsToReturn TABLE 
    (
         AddressFieldID INT
        ,FieldID INT
    )
AS
BEGIN

    DECLARE @edi geography = geography::STPointFromText('POINT(' + CAST(@Long AS VARCHAR(20)) + ' ' + 
                                CAST(@Lat AS VARCHAR(20)) + ')', 4326)

    SET @distance = @distance * 1609.344 -- convert distance into meter

    INSERT INTO @AddressIdsToReturn
    select 
         AddressFieldID
        ,FieldID
    from 
        AddressFields a WITH(INDEX(SIndx_AddressFields_geo))
    where 
        a.geo.STDistance(@edi) < = @Distance 

    RETURN 

END

GO

- ТЕСТ

- в пределах 3 миль выберите * из UDFDistanceWithin (38.90606200, -76.92943500,3) ИДТИ - в 5 милях выберите * из UDFDistanceWithin (38.90606200, -76.92943500,5) ИДТИ - в 10 милях выберите * из UDFDistanceWithin (38.90606200, -76.92943500,10)

- [9] СОЗДАТЬ ФУНКЦИЮ UDFNearestNeighbors

- ВОЗВРАЩАЕТ СПИСОК АДРЕСОВ ИЗ таблицы AddressFields

ЕСЛИ СУЩЕСТВУЕТ (ВЫБЕРИТЕ имя ОТ СИСТЕМНЫХ ОБЪЕКТОВ, ГДЕ имя = 'UDFNearestNeighbors' И тип = 'TF') DROP FUNCTION UDFNearestNeighbors 

GO

ЕСЛИ ЕСТЬ DROP TABLE цифры 

GO
-- First, create a Numbers table that we will use below.
SELECT TOP 100000 IDENTITY(int,1,1) AS n INTO numbers FROM MASTER..spt_values a, MASTER..spt_values b CREATE UNIQUE CLUSTERED INDEX idx_1 ON numbers(n)

GO

CREATE FUNCTION UDFNearestNeighbors 
(@lat as real,@long as real, @neighbors as int)
RETURNS @AddressIdsToReturn TABLE 
    (
         AddressFieldID INT
        ,FieldID INT
    )
AS
BEGIN

    DECLARE @edi geography = geography::STPointFromText('POINT(' + CAST(@Long AS VARCHAR(20)) + ' ' + 
                                CAST(@Lat AS VARCHAR(20)) + ')', 4326)
    DECLARE @start FLOAT = 1000;

    WITH NearestPoints AS

    (

      SELECT TOP(@neighbors) WITH TIES *,  AddressFields.geo.STDistance(@edi) AS dist

      FROM Numbers JOIN AddressFields WITH(INDEX(SIndx_AddressFields_geo)) 

      ON AddressFields.geo.STDistance(@edi) < @start*POWER(2,Numbers.n)

      ORDER BY n

    )


    INSERT INTO @AddressIdsToReturn

    SELECT TOP(@neighbors)
         AddressFieldID
        ,FieldID
    FROM NearestPoints
    ORDER BY n DESC, dist

    RETURN 

END

GO

- ТЕСТ

- 50 соседей выберите * из UDFNearestNeighbors (38.90606200, -76.92943500,50) ИДТИ --200 соседей выберите * из UDFNearestNeighbors (38.90606200, -76.92943500,200) GO

13 голосов
/ 17 мая 2010

Пространственные типы не поддерживаются Linq to SQL. Поддержка не "не велика" - она ​​не существует.

Вы можете читать их как BLOB, но вы не можете сделать это, просто изменив тип столбца в Linq на SQL. Вам нужно изменить свои запросы на уровне базы данных, чтобы вернуть столбец как varbinary, используя оператор CAST. Вы можете сделать это на уровне таблицы, добавив вычисляемый столбец varbinary, который Linq с радостью отобразит в byte[].

Другими словами, некоторые DDL похожи на это: 

ALTER TABLE FooTable
ADD LocationData AS CAST(Location AS varbinary(max))

Затем удалите столбец Location из класса Linq to SQL и используйте вместо него LocationData.

Если вам нужен доступ к фактическому экземпляру SqlGeography, вам необходимо преобразовать его в байтовый массив и из него, используя STGeomFromWKB и STAsBinary .

Вы можете сделать этот процесс немного более "автоматическим", расширив частичный класс сущностей Linq до SQL и добавив свойство автоконвертации: 

public partial class Foo
{
    public SqlGeography Location
    {
        get { return SqlGeography.STGeomFromWKB(LocationData, 4326); }
        set { LocationData = value.STAsBinary(); }
    }
}

Предполагается, что LocationData - это имя вычисляемого столбца varbinary; вы не включаете «настоящий» столбец Location в определение Linq to SQL, вы добавляете его специальным образом выше.

Обратите внимание, что вы не сможете сделать с этим столбцом ничего, кроме чтения и записи в него; если вы попытаетесь на самом деле запросить его (т.е. включить его в предикат Where), то вы просто получите похожий NotSupportedException.

...