[server] On mah way (lots of restructuring, some early db classes, sql dump of current schema)

1 files changed, 34 insertions, 0 deletions

diff --git a/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/database/mappers/DbOrganization.java b/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/database/mappers/DbOrganization.java
new file mode 100644
index 00000000..cc401af9
--- /dev/null
+++ b/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/database/mappers/DbOrganization.java
@@ -0,0 +1,34 @@
+package org.openslx.bwlp.sat.database.mappers;
+
+import java.sql.SQLException;
+import java.util.List;
+
+import org.apache.log4j.Logger;
+import org.openslx.bwlp.sat.database.Database;
+import org.openslx.bwlp.sat.database.MysqlConnection;
+import org.openslx.bwlp.sat.database.MysqlStatement;
+import org.openslx.bwlp.thrift.iface.Organization;
+
+public class DbOrganization {
+
+	private static final Logger LOGGER = Logger.getLogger(DbOrganization.class);
+
+	public static boolean storeOrganizations(List<Organization> organizations) {
+		try (MysqlConnection connection = Database.getConnection()) {
+			MysqlStatement stmt = connection.prepareStatement("INSERT INTO organization"
+					+ " (organizationid, displayname, canlogin) VALUES (:id, :name, 0)"
+					+ " ON DUPLICATE KEY UPDATE displayname = VALUES(displayname)");
+			for (Organization organization : organizations) {
+				stmt.setString("id", organization.organizationId);
+				stmt.setString("name", organization.displayName);
+				stmt.executeUpdate();
+			}
+			connection.commit();
+			return true;
+		} catch (SQLException e) {
+			LOGGER.error("Query failed in DbOrganization.storeOrganization()", e);
+			return false;
+		}
+	}
+
+}