diff --git a/src/main/java/org/sgrewritten/stargate/Stargate.java b/src/main/java/org/sgrewritten/stargate/Stargate.java
index 17947ed8..dddf04d9 100644
--- a/src/main/java/org/sgrewritten/stargate/Stargate.java
+++ b/src/main/java/org/sgrewritten/stargate/Stargate.java
@@ -308,6 +308,7 @@ private void registerListeners() {
         pluginManager.registerEvents(new MoveEventListener(getRegistry()), this);
         pluginManager.registerEvents(new PlayerEventListener(this.getLanguageManager(), getRegistry(), this.getBungeeManager(), this.getBlockLoggerManager(), this.getStorageAPI()), this);
         pluginManager.registerEvents(new PluginEventListener(getEconomyManager(), getBlockLoggerManager()), this);
+        pluginManager.registerEvents(new WorldEventListener(this), this);
         if (NonLegacyClass.PLAYER_ADVANCEMENT_CRITERION_EVENT.isImplemented()) {
             pluginManager.registerEvents(new PlayerAdvancementListener(getRegistry()), this);
         }
diff --git a/src/main/java/org/sgrewritten/stargate/api/database/StorageAPI.java b/src/main/java/org/sgrewritten/stargate/api/database/StorageAPI.java
index 00bb64a4..b958d404 100644
--- a/src/main/java/org/sgrewritten/stargate/api/database/StorageAPI.java
+++ b/src/main/java/org/sgrewritten/stargate/api/database/StorageAPI.java
@@ -1,5 +1,6 @@
 package org.sgrewritten.stargate.api.database;
 
+import org.bukkit.World;
 import org.jetbrains.annotations.ApiStatus;
 import org.sgrewritten.stargate.api.StargateAPI;
 import org.sgrewritten.stargate.api.network.Network;
@@ -173,9 +174,10 @@ void removePortalPosition(RealPortal portal, StorageType portalType,
 
     /**
      * Update the network name in the database
-     * @param newName <p>The new name of the network</p>
+     *
+     * @param newName     <p>The new name of the network</p>
      * @param networkName <p>The previous name of the network</p>
-     * @param portalType <p>The storage type of the network</p>
+     * @param portalType  <p>The storage type of the network</p>
      * @throws StorageWriteException <p>If unable to modify the database</p>
      */
     @ApiStatus.Internal
@@ -183,8 +185,9 @@ void removePortalPosition(RealPortal portal, StorageType portalType,
 
     /**
      * Update the name of a portal
-     * @param newName <p>The name of the portal</p>
-     * @param portalId <p>A portal id representing this portal</p>
+     *
+     * @param newName    <p>The name of the portal</p>
+     * @param portalId   <p>A portal id representing this portal</p>
      * @param portalType <p>How the portal is stored</p>
      * @throws StorageWriteException <p>If unable to modify the database</p>
      */
@@ -193,7 +196,8 @@ void removePortalPosition(RealPortal portal, StorageType portalType,
 
     /**
      * Check if the networks exists in the database
-     * @param netName <p>Network name</p>
+     *
+     * @param netName    <p>Network name</p>
      * @param portalType <p>The storage type of the network</p>
      * @return <p>True if exists</p>
      * @throws StorageReadException <p>If unable to read the database</p>
@@ -204,4 +208,11 @@ void removePortalPosition(RealPortal portal, StorageType portalType,
      * @return <p>The gate formats of the portals scheduled to be cleared</p>
      */
     Set<String> getScheduledGatesClearing();
+
+    /**
+     * Load all portals in specified world
+     *
+     * @param world <p>A world</p>
+     */
+    void loadPortalsInWorld(World world, StorageType storageType, StargateAPI stargateAPI) throws StorageReadException, StorageWriteException;
 }
diff --git a/src/main/java/org/sgrewritten/stargate/api/network/NetworkManager.java b/src/main/java/org/sgrewritten/stargate/api/network/NetworkManager.java
index e91dcd4c..5ebdba1f 100644
--- a/src/main/java/org/sgrewritten/stargate/api/network/NetworkManager.java
+++ b/src/main/java/org/sgrewritten/stargate/api/network/NetworkManager.java
@@ -1,6 +1,7 @@
 package org.sgrewritten.stargate.api.network;
 
 import org.bukkit.OfflinePlayer;
+import org.bukkit.World;
 import org.jetbrains.annotations.NotNull;
 import org.sgrewritten.stargate.api.StargateAPI;
 import org.sgrewritten.stargate.api.network.portal.Portal;
@@ -113,4 +114,10 @@ public interface NetworkManager {
      * @param portal <p>Destroy portal</p>
      */
     void destroyPortal(RealPortal portal);
+
+    /**
+     * Load all portals in world
+     * @param world <p>The world to load all portals from</p>
+     */
+    void loadWorld(World world, StargateAPI stargateAPI);
 }
diff --git a/src/main/java/org/sgrewritten/stargate/api/network/RegistryAPI.java b/src/main/java/org/sgrewritten/stargate/api/network/RegistryAPI.java
index 3919c10d..fa3fbe0e 100644
--- a/src/main/java/org/sgrewritten/stargate/api/network/RegistryAPI.java
+++ b/src/main/java/org/sgrewritten/stargate/api/network/RegistryAPI.java
@@ -21,6 +21,7 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
+import java.util.stream.Stream;
 
 
 /**
@@ -261,4 +262,6 @@ public interface RegistryAPI {
      * @return <p>The portals in the chunk</p>
      */
     @NotNull Set<RealPortal> getPortalsInChunk(StargateChunk chunk);
+
+    Stream<Portal> getAllPortals();
 }
diff --git a/src/main/java/org/sgrewritten/stargate/database/SQLDatabase.java b/src/main/java/org/sgrewritten/stargate/database/SQLDatabase.java
index a6537c2f..5465d22e 100644
--- a/src/main/java/org/sgrewritten/stargate/database/SQLDatabase.java
+++ b/src/main/java/org/sgrewritten/stargate/database/SQLDatabase.java
@@ -1,6 +1,7 @@
 package org.sgrewritten.stargate.database;
 
 import org.bukkit.Bukkit;
+import org.bukkit.World;
 import org.sgrewritten.stargate.Stargate;
 import org.sgrewritten.stargate.api.StargateAPI;
 import org.sgrewritten.stargate.api.config.ConfigurationOption;
@@ -43,10 +44,7 @@
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
 import java.sql.SQLException;
-import java.util.ArrayList;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Set;
+import java.util.*;
 import java.util.logging.Level;
 
 import static javax.management.timer.Timer.ONE_WEEK;
@@ -203,52 +201,45 @@ public void removePortalFromStorage(Portal portal) throws StorageWriteException
      * @throws SQLException <p>If an SQL error occurs</p>
      */
     private void loadAllPortals(SQLDatabaseAPI database, StorageType portalType, StargateAPI stargateAPI) throws SQLException {
-        List<PortalData> portalDataList;
-        Set<String> worldsToRemove = new HashSet<>();
-        Set<String> gateFormatsToRemove = new HashSet<>();
+        PortalLoadData portalLoadData;
         try (Connection connection = database.getConnection()) {
             PreparedStatement statement = sqlQueryGenerator.generateGetAllPortalsStatement(connection, portalType);
 
             ResultSet resultSet = statement.executeQuery();
-            portalDataList = new ArrayList<>();
-
-            while (resultSet.next()) {
-                try {
-                    PortalData portalData = PortalStorageHelper.loadPortalData(resultSet, portalType);
-                    portalDataList.add(portalData);
-                } catch (PortalLoadException e) {
-                    switch (e.getFailureType()) {
-                        case WORLD -> worldsToRemove.add(resultSet.getString("world"));
-                        case GATE_FORMAT -> gateFormatsToRemove.add(resultSet.getString("gateFileName"));
-                    }
-                }
-            }
+            portalLoadData = loadPortalsInQuery(resultSet, portalType);
             statement.close();
         }
-        removeWorlds(worldsToRemove, portalType);
         String scheduledGateFormatClearing = propertiesDatabase.getProperty(StoredProperty.SCHEDULED_GATE_CLEARING);
         if (scheduledGateFormatClearing != null && Long.parseLong(scheduledGateFormatClearing) > System.currentTimeMillis()) {
-            removeGateFormats(gateFormatsToRemove, portalType);
+            removeGateFormats(portalLoadData.invalidGates, portalType);
         } else {
-            invalidGateFormats.addAll(gateFormatsToRemove);
+            invalidGateFormats.addAll(portalLoadData.invalidGates);
         }
 
-        for (PortalData portalData : portalDataList) {
+        for (PortalData portalData : portalLoadData.loadedPortals) {
             loadPortal(portalData, stargateAPI);
         }
     }
 
-    private void removeWorlds(Set<String> worldsToRemove, StorageType storageType) throws SQLException {
-        for (String world : worldsToRemove) {
-            try (Connection connection = database.getConnection()) {
-                try (PreparedStatement preparedStatement = sqlQueryGenerator.generateDeleteWorldStatement(connection, world, storageType)) {
-                    preparedStatement.execute();
+    private PortalLoadData loadPortalsInQuery(ResultSet resultSet, StorageType portalType) throws SQLException {
+        List<PortalData> portalDataList = new ArrayList<>();
+        Set<String> worldsToRemove = new HashSet<>();
+        Set<String> gateFormatsToRemove = new HashSet<>();
+        while (resultSet.next()) {
+            try {
+                PortalData portalData = PortalStorageHelper.loadPortalData(resultSet, portalType);
+                portalDataList.add(portalData);
+            } catch (PortalLoadException e) {
+                switch (e.getFailureType()) {
+                    case WORLD -> worldsToRemove.add(resultSet.getString("world"));
+                    case GATE_FORMAT -> gateFormatsToRemove.add(resultSet.getString("gateFileName"));
                 }
             }
         }
+        return new PortalLoadData(portalDataList, worldsToRemove, gateFormatsToRemove);
     }
 
-    private void removeGateFormats(Set<String> gateFormatsToRemove, StorageType storageType) throws SQLException {
+    private void removeGateFormats(Collection<String> gateFormatsToRemove, StorageType storageType) throws SQLException {
         try (Connection connection = database.getConnection()) {
             for (String gateFormat : gateFormatsToRemove) {
                 try (PreparedStatement preparedStatement = sqlQueryGenerator.generateRemoveGateStatement(connection, gateFormat, storageType)) {
@@ -656,4 +647,39 @@ public boolean netWorkExists(String netName, StorageType portalType) throws Stor
     public Set<String> getScheduledGatesClearing() {
         return this.invalidGateFormats;
     }
+
+    @Override
+    public void loadPortalsInWorld(World world, StorageType storageType, StargateAPI stargateAPI) throws StorageReadException, StorageWriteException {
+        PortalLoadData portalLoadData;
+        try (Connection connection = database.getConnection()) {
+            ResultSet resultSet = sqlQueryGenerator.generateLoadPortalsInWorldStatement(connection, world, storageType).executeQuery();
+            portalLoadData = loadPortalsInQuery(resultSet, storageType);
+        } catch (SQLException e) {
+            throw new StorageReadException(e);
+        }
+
+        String scheduledGateFormatClearing = propertiesDatabase.getProperty(StoredProperty.SCHEDULED_GATE_CLEARING);
+        if (scheduledGateFormatClearing != null && Long.parseLong(scheduledGateFormatClearing) > System.currentTimeMillis()) {
+            try {
+                removeGateFormats(portalLoadData.invalidGates, storageType);
+            } catch (SQLException e) {
+                throw new StorageWriteException(e);
+            }
+        } else {
+            invalidGateFormats.addAll(portalLoadData.invalidGates);
+        }
+
+        for (PortalData portalData : portalLoadData.loadedPortals) {
+            try {
+                loadPortal(portalData, stargateAPI);
+            } catch (SQLException e) {
+                throw new StorageReadException(e);
+            }
+        }
+    }
+
+    private record PortalLoadData(Collection<PortalData> loadedPortals, Collection<String> invalidWorlds,
+                                  Collection<String> invalidGates) {
+
+    }
 }
diff --git a/src/main/java/org/sgrewritten/stargate/database/SQLQuery.java b/src/main/java/org/sgrewritten/stargate/database/SQLQuery.java
index c35a1cb4..08681583 100644
--- a/src/main/java/org/sgrewritten/stargate/database/SQLQuery.java
+++ b/src/main/java/org/sgrewritten/stargate/database/SQLQuery.java
@@ -301,6 +301,11 @@ public enum SQLQuery {
      */
     DELETE_GATE_FORMAT,
 
+    /**
+     * Get all portals in world
+     */
+    GET_ALL_PORTALS_IN_WORLD,
+    GET_ALL_INTER_PORTALS_IN_WORLD,
     /**
      * Delete all inter server portals with the specified gate format and server
      */
diff --git a/src/main/java/org/sgrewritten/stargate/database/SQLQueryGenerator.java b/src/main/java/org/sgrewritten/stargate/database/SQLQueryGenerator.java
index f51af1c4..656fdf58 100644
--- a/src/main/java/org/sgrewritten/stargate/database/SQLQueryGenerator.java
+++ b/src/main/java/org/sgrewritten/stargate/database/SQLQueryGenerator.java
@@ -596,10 +596,10 @@ public PreparedStatement generateSetPortalPositionMeta(Connection connection, Re
     }
 
     /**
-     * @param connection <p>A sql connection to the database</p>
-     * @param portal <p>The portal owning the portal position</p>
+     * @param connection     <p>A sql connection to the database</p>
+     * @param portal         <p>The portal owning the portal position</p>
      * @param portalPosition <p>The portal position to get data on</p>
-     * @param portalType <p>How the portal is stored</p>
+     * @param portalType     <p>How the portal is stored</p>
      * @return <p>A prepared statement able to modify fetch data on the portal position</p>
      * @throws SQLException <p>If the syntax is incorrect or any other sql faults</p>
      */
@@ -621,11 +621,10 @@ public PreparedStatement generateGetPortalPositionStatement(Connection connectio
     }
 
     /**
-     *
-     * @param connection <p>A sql database connection</p>
-     * @param newName <p>The new name of the network</p>
+     * @param connection  <p>A sql database connection</p>
+     * @param newName     <p>The new name of the network</p>
      * @param networkName <p>The previous name of the network</p>
-     * @param portalType <p>How the portals in the network are being stored</p>
+     * @param portalType  <p>How the portals in the network are being stored</p>
      * @return <p>A prepared statement able to modify the network name of all portals with the specified network</p>
      * @throws SQLException <p>If the syntax is incorrect or any other sql faults</p>
      */
@@ -643,12 +642,11 @@ public PreparedStatement generateUpdateNetworkNameStatement(Connection connectio
     }
 
     /**
-     *
-     * @param connection <p>A sql database connection</p>
-     * @param newName <p>The new name of the portal to modify</p>
-     * @param portalName <p>The previous portal name</p>
+     * @param connection  <p>A sql database connection</p>
+     * @param newName     <p>The new name of the portal to modify</p>
+     * @param portalName  <p>The previous portal name</p>
      * @param networkName <p>The network name of the portal</p>
-     * @param portalType <p>How the portal is being stored</p>
+     * @param portalType  <p>How the portal is being stored</p>
      * @return <p>A prepared statement able to change the name of a portal</p>
      * @throws SQLException <p>If the syntax is incorrect or any other sql faults</p>
      */
@@ -667,9 +665,8 @@ public PreparedStatement generateUpdatePortalNameStatement(Connection connection
     }
 
     /**
-     *
      * @param connection <p>A sql connection to the database</p>
-     * @param netName <p>The name of the network to get all portals from</p>
+     * @param netName    <p>The name of the network to get all portals from</p>
      * @param portalType <p>how the portals in the network is being stored</p>
      * @return <p>A prepared statement able to fetch all portals in specified network</p>
      * @throws SQLException <p>If the syntax is incorrect or any other sql faults</p>
@@ -687,9 +684,8 @@ public PreparedStatement generateGetAllPortalsOfNetwork(Connection connection, S
     }
 
     /**
-     *
-     * @param connection <p>A sql connection to the database</p>
-     * @param world <p>The world uuid to remove all portals from</p>
+     * @param connection  <p>A sql connection to the database</p>
+     * @param world       <p>The world uuid to remove all portals from</p>
      * @param storageType <p>How the portals in the world is being stored</p>
      * @return <p>A prepared statement able to delete all data on portals in specified world</p>
      * @throws SQLException <p>If the syntax is incorrect or any other sql faults</p>
@@ -708,8 +704,8 @@ public PreparedStatement generateDeleteWorldStatement(Connection connection, Str
     }
 
     /**
-     * @param connection <p>A sql connection to the database</p>
-     * @param gateFormat <p>The file name of the gate format to remove all portals of</p>
+     * @param connection  <p>A sql connection to the database</p>
+     * @param gateFormat  <p>The file name of the gate format to remove all portals of</p>
      * @param storageType <p>How the portals are being stored</p>
      * @return <p>A prepared statement able to remove all portals of specified gate format</p>
      * @throws SQLException <p>If the syntax is incorrect or any other sql faults</p>
@@ -726,4 +722,16 @@ public PreparedStatement generateRemoveGateStatement(Connection connection, Stri
         }
         return statement;
     }
+
+    public PreparedStatement generateLoadPortalsInWorldStatement(Connection connection, World world, StorageType storageType) throws SQLException {
+        PreparedStatement statement;
+        if(storageType == StorageType.LOCAL){
+            statement = prepareQuery(connection, getQuery(SQLQuery.GET_ALL_PORTALS_IN_WORLD));
+        } else {
+            statement = prepareQuery(connection, getQuery(SQLQuery.GET_ALL_INTER_PORTALS_IN_WORLD));
+            statement.setString(2, Stargate.getServerUUID());
+        }
+        statement.setString(1, world.getUID().toString());
+        return statement;
+    }
 }
diff --git a/src/main/java/org/sgrewritten/stargate/listener/WorldEventListener.java b/src/main/java/org/sgrewritten/stargate/listener/WorldEventListener.java
new file mode 100644
index 00000000..c7c73031
--- /dev/null
+++ b/src/main/java/org/sgrewritten/stargate/listener/WorldEventListener.java
@@ -0,0 +1,30 @@
+package org.sgrewritten.stargate.listener;
+
+import org.bukkit.event.EventHandler;
+import org.bukkit.event.Listener;
+import org.bukkit.event.world.WorldLoadEvent;
+import org.bukkit.event.world.WorldUnloadEvent;
+import org.sgrewritten.stargate.api.StargateAPI;
+import org.sgrewritten.stargate.api.network.portal.RealPortal;
+
+public class WorldEventListener implements Listener {
+
+    private final StargateAPI stargateAPI;
+
+    public WorldEventListener(StargateAPI stargateAPI) {
+        this.stargateAPI = stargateAPI;
+    }
+
+    @EventHandler
+    void onWordUnload(WorldUnloadEvent event) {
+        stargateAPI.getRegistry().getAllPortals().filter(portal -> portal instanceof RealPortal)
+                .map(portal -> (RealPortal) portal)
+                .filter(realPortal -> realPortal.getExit().getWorld().equals(event.getWorld()))
+                .forEach(stargateAPI.getRegistry()::unregisterPortal);
+    }
+
+    @EventHandler
+    void onWorldLoad(WorldLoadEvent event) {
+        stargateAPI.getNetworkManager().loadWorld(event.getWorld(), stargateAPI);
+    }
+}
diff --git a/src/main/java/org/sgrewritten/stargate/network/StargateNetworkManager.java b/src/main/java/org/sgrewritten/stargate/network/StargateNetworkManager.java
index 4565746c..3831b966 100644
--- a/src/main/java/org/sgrewritten/stargate/network/StargateNetworkManager.java
+++ b/src/main/java/org/sgrewritten/stargate/network/StargateNetworkManager.java
@@ -2,6 +2,7 @@
 
 import org.bukkit.Bukkit;
 import org.bukkit.OfflinePlayer;
+import org.bukkit.World;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 import org.sgrewritten.stargate.Stargate;
@@ -13,9 +14,9 @@
 import org.sgrewritten.stargate.api.network.NetworkRegistry;
 import org.sgrewritten.stargate.api.network.RegistryAPI;
 import org.sgrewritten.stargate.api.network.portal.Portal;
+import org.sgrewritten.stargate.api.network.portal.RealPortal;
 import org.sgrewritten.stargate.api.network.portal.flag.PortalFlag;
 import org.sgrewritten.stargate.api.network.portal.flag.StargateFlag;
-import org.sgrewritten.stargate.api.network.portal.RealPortal;
 import org.sgrewritten.stargate.api.permission.PermissionManager;
 import org.sgrewritten.stargate.config.ConfigurationHelper;
 import org.sgrewritten.stargate.container.TwoTuple;
@@ -43,9 +44,8 @@ public class StargateNetworkManager implements NetworkManager {
     private final StorageAPI storageAPI;
 
     /**
-     *
      * @param registryAPI <p>A registry containing all portal information</p>
-     * @param storageAPI <p>A database interface able to give and modify information about portals</p>
+     * @param storageAPI  <p>A database interface able to give and modify information about portals</p>
      */
     public StargateNetworkManager(RegistryAPI registryAPI, StorageAPI storageAPI) {
         this.registry = registryAPI;
@@ -286,6 +286,23 @@ public void run() {
         portal.getNetwork().getPluginMessageSender().sendDeletePortal(portal);
     }
 
+    @Override
+    public void loadWorld(World world, StargateAPI stargateAPI) {
+        new StargateQueuedAsyncTask() {
+            @Override
+            public void run() {
+                try {
+                    storageAPI.loadPortalsInWorld(world, StorageType.LOCAL, stargateAPI);
+                    if (ConfigurationHelper.getBoolean(ConfigurationOption.USING_BUNGEE) && ConfigurationHelper.getBoolean(ConfigurationOption.USING_REMOTE_DATABASE)) {
+                        storageAPI.loadPortalsInWorld(world, StorageType.INTER_SERVER, stargateAPI);
+                    }
+                } catch (StorageReadException | StorageWriteException e) {
+                    Stargate.log(e);
+                }
+            }
+        }.runNow();
+    }
+
 
     /**
      * Gets a player's UUID from the player's name
diff --git a/src/main/java/org/sgrewritten/stargate/network/StargateNetworkRegistry.java b/src/main/java/org/sgrewritten/stargate/network/StargateNetworkRegistry.java
index 28cdada3..4dd46ba2 100644
--- a/src/main/java/org/sgrewritten/stargate/network/StargateNetworkRegistry.java
+++ b/src/main/java/org/sgrewritten/stargate/network/StargateNetworkRegistry.java
@@ -127,4 +127,5 @@ public void closeAllPortals() {
     public int size() {
         return networkMap.size();
     }
+
 }
diff --git a/src/main/java/org/sgrewritten/stargate/network/StargateRegistry.java b/src/main/java/org/sgrewritten/stargate/network/StargateRegistry.java
index 56509dfa..f2fb5eef 100644
--- a/src/main/java/org/sgrewritten/stargate/network/StargateRegistry.java
+++ b/src/main/java/org/sgrewritten/stargate/network/StargateRegistry.java
@@ -17,12 +17,7 @@
 import org.sgrewritten.stargate.api.network.Network;
 import org.sgrewritten.stargate.api.network.NetworkRegistry;
 import org.sgrewritten.stargate.api.network.RegistryAPI;
-import org.sgrewritten.stargate.api.network.portal.BlockLocation;
-import org.sgrewritten.stargate.api.network.portal.Portal;
-import org.sgrewritten.stargate.api.network.portal.PortalPosition;
-import org.sgrewritten.stargate.api.network.portal.PositionType;
-import org.sgrewritten.stargate.api.network.portal.RealPortal;
-import org.sgrewritten.stargate.api.network.portal.StargateChunk;
+import org.sgrewritten.stargate.api.network.portal.*;
 import org.sgrewritten.stargate.exception.UnimplementedFlagException;
 import org.sgrewritten.stargate.exception.database.StorageReadException;
 import org.sgrewritten.stargate.exception.database.StorageWriteException;
@@ -33,15 +28,9 @@
 import org.sgrewritten.stargate.util.ExceptionHelper;
 import org.sgrewritten.stargate.util.VectorUtils;
 
-import java.util.ArrayList;
-import java.util.EnumMap;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.UUID;
+import java.util.*;
 import java.util.logging.Level;
+import java.util.stream.Stream;
 
 /**
  * Registry of all portals and networks
@@ -314,7 +303,7 @@ public Map<BlockLocation, PortalPosition> getPortalPositionsOwnedByPlugin(Plugin
     public PortalPosition savePortalPosition(RealPortal portal, Location location, PositionType type, Plugin plugin) {
         BlockVector relativeVector = portal.getGate().getRelativeVector(location).toBlockVector();
         PortalPosition portalPosition = new PortalPosition(type, relativeVector, plugin.getName());
-        new StargateQueuedAsyncTask(){
+        new StargateQueuedAsyncTask() {
             @Override
             public void run() {
                 try {
@@ -418,4 +407,14 @@ private boolean shouldStop(int target, int currentPosition, int modifier) {
         }
     }
 
+
+    @Override
+    public Stream<Portal> getAllPortals() {
+        Stream<Network> localNetworks = getNetworkRegistry(StorageType.LOCAL).stream();
+        Stream<Network> interNetworks = getNetworkRegistry(StorageType.INTER_SERVER).stream();
+        Stream<Network> networks = Stream.concat(localNetworks, interNetworks);
+        return networks.map(Network::getAllPortals)
+                .flatMap(Collection::stream);
+    }
+
 }
diff --git a/src/main/resources/database/sqlite-queries/CREATE_TABLE_INTER_PORTAL.sql b/src/main/resources/database/sqlite-queries/CREATE_TABLE_INTER_PORTAL.sql
index e5e924ce..1dedd78e 100644
--- a/src/main/resources/database/sqlite-queries/CREATE_TABLE_INTER_PORTAL.sql
+++ b/src/main/resources/database/sqlite-queries/CREATE_TABLE_INTER_PORTAL.sql
@@ -3,7 +3,7 @@ CREATE TABLE IF NOT EXISTS {InterPortal}
    name NVARCHAR (180) NOT NULL,
    network NVARCHAR (180) NOT NULL,
    destination NVARCHAR (180),
-   world NVARCHAR (255) NOT NULL,
+   world NVARCHAR (36) NOT NULL,
    x INTEGER,
    y INTEGER,
    z INTEGER,
diff --git a/src/main/resources/database/sqlite-queries/CREATE_TABLE_PORTAL.sql b/src/main/resources/database/sqlite-queries/CREATE_TABLE_PORTAL.sql
index 2a785e7f..e2c96570 100644
--- a/src/main/resources/database/sqlite-queries/CREATE_TABLE_PORTAL.sql
+++ b/src/main/resources/database/sqlite-queries/CREATE_TABLE_PORTAL.sql
@@ -3,7 +3,7 @@ CREATE TABLE IF NOT EXISTS {Portal}
    name NVARCHAR (180) NOT NULL,
    network NVARCHAR (180) NOT NULL,
    destination NVARCHAR (180),
-   world NVARCHAR (255) NOT NULL,
+   world NVARCHAR (36) NOT NULL,
    x INTEGER,
    y INTEGER,
    z INTEGER,
diff --git a/src/main/resources/database/sqlite-queries/GET_ALL_INTER_PORTALS_IN_WORLD.sql b/src/main/resources/database/sqlite-queries/GET_ALL_INTER_PORTALS_IN_WORLD.sql
new file mode 100644
index 00000000..89ef0b2a
--- /dev/null
+++ b/src/main/resources/database/sqlite-queries/GET_ALL_INTER_PORTALS_IN_WORLD.sql
@@ -0,0 +1,2 @@
+SELECT * FROM {InterPortalView}
+    WHERE world = ? AND homeServerId = ?;
\ No newline at end of file
diff --git a/src/main/resources/database/sqlite-queries/GET_ALL_PORTALS_IN_WORLD.sql b/src/main/resources/database/sqlite-queries/GET_ALL_PORTALS_IN_WORLD.sql
new file mode 100644
index 00000000..79c4d617
--- /dev/null
+++ b/src/main/resources/database/sqlite-queries/GET_ALL_PORTALS_IN_WORLD.sql
@@ -0,0 +1,2 @@
+SELECT * FROM {PortalView}
+    WHERE world = ?;
\ No newline at end of file
diff --git a/src/test/java/org/sgrewritten/stargate/database/StorageMock.java b/src/test/java/org/sgrewritten/stargate/database/StorageMock.java
index 5f5ddf75..5a7ae3a5 100644
--- a/src/test/java/org/sgrewritten/stargate/database/StorageMock.java
+++ b/src/test/java/org/sgrewritten/stargate/database/StorageMock.java
@@ -1,5 +1,6 @@
 package org.sgrewritten.stargate.database;
 
+import org.bukkit.World;
 import org.sgrewritten.stargate.api.StargateAPI;
 import org.sgrewritten.stargate.api.database.StorageAPI;
 import org.sgrewritten.stargate.api.network.Network;
@@ -8,6 +9,8 @@
 import org.sgrewritten.stargate.api.network.portal.RealPortal;
 import org.sgrewritten.stargate.container.ThreeTuple;
 import org.sgrewritten.stargate.exception.UnimplementedFlagException;
+import org.sgrewritten.stargate.exception.database.StorageReadException;
+import org.sgrewritten.stargate.exception.database.StorageWriteException;
 import org.sgrewritten.stargate.exception.name.InvalidNameException;
 import org.sgrewritten.stargate.exception.name.NameLengthException;
 import org.sgrewritten.stargate.network.NetworkType;
@@ -134,4 +137,9 @@ public Set<String> getScheduledGatesClearing() {
         return new HashSet<>();
     }
 
+    @Override
+    public void loadPortalsInWorld(World world, StorageType storageType, StargateAPI stargateAPI) throws StorageReadException, StorageWriteException {
+
+    }
+
 }