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
|
// Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.
using System;
using System.Collections.Generic;
using System.Data.Spatial;
using System.Data.SqlClient;
using System.Data.SqlTypes;
using System.IO;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
namespace SampleEntityFrameworkProvider
{
internal sealed class SqlSpatialDataReader : DbSpatialDataReader
{
private readonly SqlDataReader reader;
static SqlSpatialDataReader()
{
}
public SqlSpatialDataReader(SqlDataReader underlyingReader)
{
this.reader = underlyingReader;
}
public override DbGeography GetGeography(int ordinal)
{
EnsureGeographyColumn(ordinal);
var geographyBytes = this.reader.GetSqlBytes(ordinal);
dynamic geography = Activator.CreateInstance(SqlTypes.SqlGeographyType);
geography.Read(new BinaryReader(geographyBytes.Stream));
return SpatialServices.Instance.GeographyFromProviderValue(geography);
}
public override DbGeometry GetGeometry(int ordinal)
{
EnsureGeometryColumn(ordinal);
var geometryBytes = this.reader.GetSqlBytes(ordinal);
dynamic geometry = Activator.CreateInstance(SqlTypes.SqlGeometryType);
geometry.Read(new BinaryReader(geometryBytes.Stream));
return SpatialServices.Instance.GeometryFromProviderValue(geometry);
}
private void EnsureGeographyColumn(int ordinal)
{
string fieldTypeName = this.reader.GetDataTypeName(ordinal);
if (!fieldTypeName.EndsWith("sys.geography", StringComparison.Ordinal)) // Use EndsWith so that we just see the schema and type name, not the database name.
{
throw new InvalidOperationException(
string.Format(
"Expected a geography value, found a value of type {0}.",
fieldTypeName));
}
}
private void EnsureGeometryColumn(int ordinal)
{
string fieldTypeName = this.reader.GetDataTypeName(ordinal);
if (!fieldTypeName.EndsWith("sys.geometry", StringComparison.Ordinal)) // Use EndsWith so that we just see the schema and type name, not the database name.
{
throw new InvalidOperationException(
string.Format(
"Expected a geometry value, found a value of type {0}.",
fieldTypeName));
}
}
}
}
|
