How to reopen a broken connection when using a PostgreSQL database

C#
using System;
using DevExpress.Xpo;
using DevExpress.Xpo.DB;

namespace B190497 {
    class Program {
        static void Main(string[] args) {
            SafePostgreSqlConnectionProvider.Register();
            SafePostgreSqlConnectionProvider dataStore = new SafePostgreSqlConnectionProvider(
                "user id=postgres;password=admin;server=donchakDBFarm;database=XpoUnitTests;port=5434",
                AutoCreateOption.DatabaseAndSchema
            );
            IDataLayer dal = new SimpleDataLayer(dataStore);
            int id = CreateData(dal);
            Console.WriteLine("restart the database, and press any key to continue ..");
            Console.ReadKey();
            new Session(dal).GetObjectByKey<Person>(id);
            ((IDisposable)dataStore).Dispose();
            dal.Dispose();
            Console.WriteLine("done\npress any key to exit ..");
            Console.ReadKey();
        }
        static int CreateData(IDataLayer dal) {
            using (UnitOfWork uow = new UnitOfWork()) {
                Person result = uow.FindObject<Person>(null);
                if (result == null) {
                    result = new Person(uow);
                    result.Name = "Uriah";
                }
                uow.CommitChanges();
                return result.Oid;
            }
        }
    }
    public class Person : XPObject {
        public Person(Session session) : base(session) { }
        string fName;
        public string Name {
            get { return fName; }
            set { SetPropertyValue<string>("Name", ref fName, value); }
        }
    }
}

Visual Basic
Imports System
Imports DevExpress.Xpo
Imports DevExpress.Xpo.DB

Namespace B190497
    Friend Class Program
        Shared Sub Main(ByVal args() As String)
            SafePostgreSqlConnectionProvider.Register()
            Dim dataStore As New SafePostgreSqlConnectionProvider("user id=postgres;password=admin;server=donchakDBFarm;database=XpoUnitTests;port=5434", AutoCreateOption.DatabaseAndSchema)
            Dim dal As IDataLayer = New SimpleDataLayer(dataStore)
            Dim id As Integer = CreateData(dal)
            Console.WriteLine("restart the database, and press any key to continue ..")
            Console.ReadKey()
            CType(New Session(dal), Session).GetObjectByKey(Of Person)(id)
            DirectCast(dataStore, IDisposable).Dispose()
            dal.Dispose()
            Console.WriteLine("done" & ControlChars.Lf & "press any key to exit ..")
            Console.ReadKey()
        End Sub
        Private Shared Function CreateData(ByVal dal As IDataLayer) As Integer
            Using uow As New UnitOfWork()
                Dim result As Person = uow.FindObject(Of Person)(Nothing)
                If result Is Nothing Then
                    result = New Person(uow)
                    result.Name = "Uriah"
                End If
                uow.CommitChanges()
                Return result.Oid
            End Using
        End Function
    End Class
    Public Class Person
        Inherits XPObject

        Public Sub New(ByVal session As Session)
            MyBase.New(session)
        End Sub
        Private fName As String
        Public Property Name() As String
            Get
                Return fName
            End Get
            Set(ByVal value As String)
                SetPropertyValue(Of String)("Name", fName, value)
            End Set
        End Property
    End Class
End Namespace

C#
using System;
using System.Data;
using DevExpress.Xpo.DB;
using DevExpress.Xpo.DB.Exceptions;
using System.Reflection;
using System.Globalization;
using DevExpress.Xpo.Helpers;
using Npgsql;

namespace B190497 {
    public class SafePostgreSqlConnectionProvider : IDataStore, IDisposable, ICommandChannel {
        PostgreSqlConnectionProvider InnerDataStore;
        IDbConnection Connection;
        string ConnectionString;
        AutoCreateOption AutoCreateOption;

        public static void Register() {
            DataStoreBase.RegisterDataStoreProvider(PostgreSqlConnectionProvider.XpoProviderTypeString,
                new DevExpress.Xpo.DB.Helpers.DataStoreCreationFromStringDelegate(CreateProviderFromString));
        }
        public static IDataStore CreateProviderFromString(string connectionString, AutoCreateOption autoCreateOption,
            out IDisposable[] objectsToDisposeOnDisconnect) {
            SafePostgreSqlConnectionProvider rv = new SafePostgreSqlConnectionProvider(connectionString, autoCreateOption);
            objectsToDisposeOnDisconnect = new IDisposable[] { rv };
            return rv;
        }
        public SafePostgreSqlConnectionProvider(string connectionString, AutoCreateOption autoCreateOption) {
            this.ConnectionString = connectionString;
            this.AutoCreateOption = autoCreateOption;
            DoReconnect();
        }

        ~SafePostgreSqlConnectionProvider() {
            Dispose(false);
        }

        void DoReconnect() {
            DoDispose(false);
            Connection = PostgreSqlConnectionProvider.CreateConnection(ConnectionString);
            InnerDataStore = new PostgreSqlConnectionProvider(Connection, AutoCreateOption);
        }

        void DoDispose(bool closeConnection) {
            if (Connection != null) {
                if (closeConnection) {
                    Connection.Close();
                    Connection.Dispose();
                }
                Connection = null;
            }
        }

        protected virtual void Dispose(bool disposing) {
            if (disposing)
                DoDispose(true);
        }

        void HandleNullReferenceException(Exception ex) {
            if (ex == null) return;
            if (ex is NullReferenceException && InnerDataStore.Connection.State == ConnectionState.Open) {
                DoReconnect();
                return;
            }
            NpgsqlException npgex = ex as NpgsqlException;
            if (npgex != null && npgex.Errors != null && InnerDataStore.Connection.State == ConnectionState.Open) {
                foreach (NpgsqlError error in npgex.Errors) {
                    if (error.Message.Contains("broken")) {
                        DoReconnect();
                        return;
                    }
                }
            }
            throw ex;
        }


        AutoCreateOption IDataStore.AutoCreateOption {
            get { return InnerDataStore.AutoCreateOption; }
        }

        ModificationResult IDataStore.ModifyData(params ModificationStatement[] dmlStatements) {
            try {
                return InnerDataStore.ModifyData(dmlStatements);
            } catch (SqlExecutionErrorException ex) {
                HandleNullReferenceException(ex.InnerException);
            }
            return InnerDataStore.ModifyData(dmlStatements);
        }

        SelectedData IDataStore.SelectData(params SelectStatement[] selects) {
            try {
                return InnerDataStore.SelectData(selects);
            } catch (NullReferenceException ex) {
                HandleNullReferenceException(ex.InnerException);
            }
            return InnerDataStore.SelectData(selects);
        }

        UpdateSchemaResult IDataStore.UpdateSchema(bool dontCreateIfFirstTableNotExist, params DBTable[] tables) {
            try {
                return InnerDataStore.UpdateSchema(dontCreateIfFirstTableNotExist, tables);
            } catch (SqlExecutionErrorException ex) {
                HandleNullReferenceException(ex.InnerException);
            }
            return InnerDataStore.UpdateSchema(dontCreateIfFirstTableNotExist, tables);
        }

        void IDisposable.Dispose() {
            Dispose(true);
            GC.SuppressFinalize(this);
        }
        //T270757
        public object Do(string command, object args) {
            return ((ICommandChannel)InnerDataStore).Do(command, args);
        }
    }
}

Visual Basic
Imports System
Imports System.Data
Imports DevExpress.Xpo.DB
Imports DevExpress.Xpo.DB.Exceptions
Imports System.Reflection
Imports System.Globalization
Imports DevExpress.Xpo.Helpers
Imports Npgsql

Namespace B190497
    Public Class SafePostgreSqlConnectionProvider
        Implements IDataStore, IDisposable, ICommandChannel

        Private InnerDataStore As PostgreSqlConnectionProvider
        Private Connection As IDbConnection
        Private ConnectionString As String
        Private AutoCreateOption As AutoCreateOption

        Public Shared Sub Register()
            DataStoreBase.RegisterDataStoreProvider(PostgreSqlConnectionProvider.XpoProviderTypeString, New DevExpress.Xpo.DB.Helpers.DataStoreCreationFromStringDelegate(AddressOf CreateProviderFromString))
        End Sub
        Public Shared Function CreateProviderFromString(ByVal connectionString As String, ByVal autoCreateOption As AutoCreateOption, <System.Runtime.InteropServices.Out()> ByRef objectsToDisposeOnDisconnect() As IDisposable) As IDataStore
            Dim rv As New SafePostgreSqlConnectionProvider(connectionString, autoCreateOption)
            objectsToDisposeOnDisconnect = New IDisposable() { rv }
            Return rv
        End Function
        Public Sub New(ByVal connectionString As String, ByVal autoCreateOption As AutoCreateOption)
            Me.ConnectionString = connectionString
            Me.AutoCreateOption = autoCreateOption
            DoReconnect()
        End Sub

        Protected Overrides Sub Finalize()
            Dispose(False)
        End Sub

        Private Sub DoReconnect()
            DoDispose(False)
            Connection = PostgreSqlConnectionProvider.CreateConnection(ConnectionString)
            InnerDataStore = New PostgreSqlConnectionProvider(Connection, AutoCreateOption)
        End Sub

        Private Sub DoDispose(ByVal closeConnection As Boolean)
            If Connection IsNot Nothing Then
                If closeConnection Then
                    Connection.Close()
                    Connection.Dispose()
                End If
                Connection = Nothing
            End If
        End Sub

        Protected Overridable Sub Dispose(ByVal disposing As Boolean)
            If disposing Then
                DoDispose(True)
            End If
        End Sub

        Private Sub HandleNullReferenceException(ByVal ex As Exception)
            If ex Is Nothing Then
                Return
            End If
            If TypeOf ex Is NullReferenceException AndAlso InnerDataStore.Connection.State = ConnectionState.Open Then
                DoReconnect()
                Return
            End If
            Dim npgex As NpgsqlException = TryCast(ex, NpgsqlException)
            If npgex IsNot Nothing AndAlso npgex.Errors IsNot Nothing AndAlso InnerDataStore.Connection.State = ConnectionState.Open Then
                For Each [error] As NpgsqlError In npgex.Errors
                    If [error].Message.Contains("broken") Then
                        DoReconnect()
                        Return
                    End If
                Next [error]
            End If
            Throw ex
        End Sub


        Private ReadOnly Property IDataStore_AutoCreateOption() As AutoCreateOption Implements IDataStore.AutoCreateOption
            Get
                Return InnerDataStore.AutoCreateOption
            End Get
        End Property

        Private Function IDataStore_ModifyData(ParamArray ByVal dmlStatements() As ModificationStatement) As ModificationResult Implements IDataStore.ModifyData
            Try
                Return InnerDataStore.ModifyData(dmlStatements)
            Catch ex As SqlExecutionErrorException
                HandleNullReferenceException(ex.InnerException)
            End Try
            Return InnerDataStore.ModifyData(dmlStatements)
        End Function

        Private Function IDataStore_SelectData(ParamArray ByVal selects() As SelectStatement) As SelectedData Implements IDataStore.SelectData
            Try
                Return InnerDataStore.SelectData(selects)
            Catch ex As NullReferenceException
                HandleNullReferenceException(ex.InnerException)
            End Try
            Return InnerDataStore.SelectData(selects)
        End Function

        Private Function IDataStore_UpdateSchema(ByVal dontCreateIfFirstTableNotExist As Boolean, ParamArray ByVal tables() As DBTable) As UpdateSchemaResult Implements IDataStore.UpdateSchema
            Try
                Return InnerDataStore.UpdateSchema(dontCreateIfFirstTableNotExist, tables)
            Catch ex As SqlExecutionErrorException
                HandleNullReferenceException(ex.InnerException)
            End Try
            Return InnerDataStore.UpdateSchema(dontCreateIfFirstTableNotExist, tables)
        End Function

        Private Sub IDisposable_Dispose() Implements IDisposable.Dispose
            Dispose(True)
            GC.SuppressFinalize(Me)
        End Sub
        'T270757
        Public Function [Do](ByVal command As String, ByVal args As Object) As Object Implements ICommandChannel.Do
            Return DirectCast(InnerDataStore, ICommandChannel).Do(command, args)
        End Function
    End Class
End Namespace