1 files changed, 108 insertions, 0 deletions
diff --git a/src/main/java/org/openslx/imagemaster/db/mappers/DbOsVirt.java b/src/main/java/org/openslx/imagemaster/db/mappers/DbOsVirt.java
new file mode 100644
index 0000000..ee8a39a
--- /dev/null
+++ b/src/main/java/org/openslx/imagemaster/db/mappers/DbOsVirt.java
@@ -0,0 +1,108 @@
+package org.openslx.imagemaster.db.mappers;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.log4j.Logger;
+import org.openslx.bwlp.thrift.iface.OperatingSystem;
+import org.openslx.bwlp.thrift.iface.Virtualizer;
+import org.openslx.imagemaster.db.Database;
+import org.openslx.imagemaster.db.MysqlConnection;
+import org.openslx.imagemaster.db.MysqlStatement;
+import org.openslx.imagemaster.util.Util;
+
+public class DbOsVirt
+{
+
+	private static final Logger LOGGER = Logger.getLogger( DbOsVirt.class );
+
+	public static List<OperatingSystem> getOsList() throws SQLException
+	{
+		try ( MysqlConnection connection = Database.getConnection() ) {
+			// Query OSs
+			MysqlStatement stmt = connection.prepareStatement( "SELECT"
+					+ " osid, displayname, architecture, maxmem, maxcpu" + " FROM operatingsystem" );
+			ResultSet rs = stmt.executeQuery();
+			List<OperatingSystem> list = new ArrayList<>();
+			Map<Integer, Map<String, String>> osVirtMappings = getOsVirtMappings( connection );
+			while ( rs.next() ) {
+				int osId = rs.getInt( "osid" );
+				list.add( new OperatingSystem( osId, rs.getString( "displayname" ), osVirtMappings.get( osId ),
+						rs.getString( "architecture" ), rs.getInt( "maxmem" ), rs.getInt( "maxcpu" ) ) );
+			}
+			return list;
+		} catch ( SQLException e ) {
+			LOGGER.error( "Query failed in DbOsVirt.getOsList()", e );
+			throw e;
+		}
+	}
+
+	private static Map<Integer, Map<String, String>> getOsVirtMappings( MysqlConnection connection )
+			throws SQLException
+	{
+		MysqlStatement stmt = connection.prepareStatement( "SELECT osid, virtid, virtoskeyword FROM os_x_virt" );
+		ResultSet rs = stmt.executeQuery();
+		Map<Integer, Map<String, String>> map = new HashMap<>();
+		while ( rs.next() ) {
+			Integer osId = rs.getInt( "osid" );
+			Map<String, String> osMap = map.get( osId );
+			if ( osMap == null ) {
+				osMap = new HashMap<>();
+				map.put( osId, osMap );
+			}
+			osMap.put( rs.getString( "virtid" ), rs.getString( "virtoskeyword" ) );
+		}
+		return map;
+	}
+
+	public static List<Virtualizer> getVirtualizerList() throws SQLException
+	{
+		try ( MysqlConnection connection = Database.getConnection() ) {
+			MysqlStatement stmt = connection.prepareStatement( "SELECT virtid, virtname" + " FROM virtualizer" );
+			ResultSet rs = stmt.executeQuery();
+			List<Virtualizer> list = new ArrayList<>();
+			while ( rs.next() ) {
+				list.add( new Virtualizer( rs.getString( "virtid" ), rs.getString( "virtname" ) ) );
+			}
+			return list;
+		} catch ( SQLException e ) {
+			LOGGER.error( "Query failed in DbOsVirt.getVirtualizerList()", e );
+			throw e;
+		}
+	}
+
+	public static boolean osExists( int osId )
+	{
+		if ( osId <= 0 )
+			return false;
+		try ( MysqlConnection connection = Database.getConnection() ) {
+			MysqlStatement stmt = connection.prepareStatement( "SELECT osid FROM operatingsystem WHERE osid = :osid" );
+			stmt.setInt( "osid", osId );
+			ResultSet rs = stmt.executeQuery();
+			return rs.next();
+		} catch ( SQLException e ) {
+			LOGGER.error( "Query failed in DbOsVirt.exists()", e );
+			return false;
+		}
+	}
+
+	public static boolean virtExists( String virtId )
+	{
+		if ( Util.isEmpty( virtId ) )
+			return false;
+		try ( MysqlConnection connection = Database.getConnection() ) {
+			MysqlStatement stmt = connection.prepareStatement( "SELECT virtid FROM virtualizer WHERE virtid = :virtid" );
+			stmt.setString( "virtid", virtId );
+			ResultSet rs = stmt.executeQuery();
+			return rs.next();
+		} catch ( SQLException e ) {
+			LOGGER.error( "Query failed in DbOsVirt.virtExists()", e );
+			return false;
+		}
+	}
+
+}