1 files changed, 62 insertions, 0 deletions
diff --git a/src/main/java/org/openslx/imagemaster/db/mappers/DbSatellite.java b/src/main/java/org/openslx/imagemaster/db/mappers/DbSatellite.java
new file mode 100644
index 0000000..811ac67
--- /dev/null
+++ b/src/main/java/org/openslx/imagemaster/db/mappers/DbSatellite.java
@@ -0,0 +1,62 @@
+package org.openslx.imagemaster.db.mappers;
+
+import java.nio.ByteBuffer;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+
+import org.apache.log4j.Logger;
+import org.openslx.bwlp.thrift.iface.Satellite;
+import org.openslx.bwlp.thrift.iface.UserInfo;
+import org.openslx.imagemaster.db.Database;
+import org.openslx.imagemaster.db.MysqlConnection;
+import org.openslx.imagemaster.db.MysqlStatement;
+import org.openslx.imagemaster.db.models.LocalSatellite;
+import org.openslx.util.Json;
+
+public class DbSatellite
+{
+
+	private static final Logger LOGGER = Logger.getLogger( DbSatellite.class );
+
+	public static LocalSatellite get( int satelliteId )
+	{
+		return null;
+	}
+
+	public static List<Satellite> getSatellites( UserInfo ui ) throws SQLException
+	{
+		if ( ui == null )
+			return null;
+		return getSatellites( ui.organizationId );
+	}
+
+	public static List<Satellite> getSatellites( String organizationId ) throws SQLException
+	{
+		if ( organizationId == null )
+			return null;
+		try ( MysqlConnection connection = Database.getConnection() ) {
+			MysqlStatement stmt = connection.prepareStatement( "SELECT satellitename, addresses, certsha256"
+					+ " FROM satellite WHERE organizationid = :organizationid" );
+			stmt.setString( "organizationid", organizationId );
+			ResultSet rs = stmt.executeQuery();
+			List<Satellite> list = new ArrayList<>();
+			while ( rs.next() ) {
+				List<String> al = Arrays.asList( Json.deserialize( rs.getString( "addresses" ), String[].class ) );
+				list.add( new Satellite( al, rs.getString( "satellitename" ), ByteBuffer.wrap( rs.getBytes( "certsha256" ) ) ) );
+			}
+			return list;
+		} catch ( SQLException e ) {
+			LOGGER.error( "Query failed in DbSatellite.getSatellites()", e );
+			throw e;
+		}
+	}
+
+	public static LocalSatellite get( String organizationId, String displayName )
+	{
+		// TODO Auto-generated method stub
+		return null;
+	}
+}