DbSatellite.java

Go to the documentation of this file.

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.logging.log4j.LogManager;
import org.apache.logging.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 = LogManager.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 ) );
            byte[] certBytes = rs.getBytes( "certsha256" );
            ByteBuffer cert = null;
            if ( certBytes != null ) {
               cert = ByteBuffer.wrap( certBytes );
            }
            list.add( new Satellite( al, rs.getString( "satellitename" ), cert ) );
         }
         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;
   }
}