[Schmitzm-commits] r1734 - trunk/schmitzm-core/src/main/java/de/schmitzm/postgres
scm-commit@wald.intevation.org
scm-commit at wald.intevation.org
Sun Sep 25 18:59:12 CEST 2011
Author: alfonx
Date: 2011-09-25 18:59:11 +0200 (Sun, 25 Sep 2011)
New Revision: 1734
Modified:
trunk/schmitzm-core/src/main/java/de/schmitzm/postgres/PGUtil.java
Log:
PG Indexes mit Fillfactor angabe erstellen
Modified: trunk/schmitzm-core/src/main/java/de/schmitzm/postgres/PGUtil.java
===================================================================
--- trunk/schmitzm-core/src/main/java/de/schmitzm/postgres/PGUtil.java 2011-09-25 11:10:28 UTC (rev 1733)
+++ trunk/schmitzm-core/src/main/java/de/schmitzm/postgres/PGUtil.java 2011-09-25 16:59:11 UTC (rev 1734)
@@ -13,15 +13,14 @@
import de.schmitzm.lang.LangUtil;
/**
- * Hilfsmethoden für PostgreSQL. Die Dependency soll nur {@link Connection}
- * sein. In Hibernate kann über #doWork eine {@link Connection} erhalten werden.
+ * Hilfsmethoden für PostgreSQL. Die Dependency soll nur {@link Connection} sein. In Hibernate kann über #doWork eine
+ * {@link Connection} erhalten werden.
*/
public class PGUtil {
static final Logger log = Logger.getLogger(PGUtil.class);
/**
- * PostgreSQL Privilegien die per Grant einer Tabelle zugeordnet werden
- * können.<br/>
+ * PostgreSQL Privilegien die per Grant einer Tabelle zugeordnet werden können.<br/>
*
* @see http://www.postgresql.org/docs/9.1/static/sql-grant.html
*/
@@ -89,8 +88,8 @@
}
/**
- * Querys the <code>geometry_columns</code> table is part of every POSTGIS
- * installation and must/should describe the geometry columns and tables.
+ * Querys the <code>geometry_columns</code> table is part of every POSTGIS installation and must/should describe the
+ * geometry columns and tables.
*/
static public String[] getColumnsDescribedInGeometryColumnsTable(Statement s) {
String[] columns = new String[0];
@@ -132,8 +131,8 @@
/**
* @param binding
* Eine "einfache" Javaklasse, die in PG abgebildet werden soll.
- * @return einen PG-spezifischen Datentypenamen für einen Javatyp zurück,
- * z.b. "double precision" für <code>Double.class</code>
+ * @return einen PG-spezifischen Datentypenamen für einen Javatyp zurück, z.b. "double precision" für
+ * <code>Double.class</code>
*/
public static String getColTypeName(Class<?> binding) {
@@ -164,8 +163,7 @@
}
/**
- * Liefert <code>true</code> wenn ein Schema mit dem Namen in der PG
- * Datenbank existiert.
+ * Liefert <code>true</code> wenn ein Schema mit dem Namen in der PG Datenbank existiert.
*/
public static boolean existsSchema(Connection c, String schemaname) throws SQLException {
String sql = "select 1 from pg_catalog.pg_namespace where nspname = '" + schemaname.toLowerCase() + "'";
@@ -179,8 +177,7 @@
}
/**
- * Liefert eine Liste der Rollen in denen der Übergebenen USER (Login role)
- * ist. <br/>
+ * Liefert eine Liste der Rollen in denen der Übergebenen USER (Login role) ist. <br/>
* Tested with PG 8.4
*/
public static List<String> listRolesForUser(Connection c, String username) throws SQLException {
@@ -217,8 +214,8 @@
}
/**
- * Liste aller Tabellennamen in diesem Schema, ohne die Schemaangabe im
- * Namen. (Also 'anreden' und nicht 'public.anreden') <br/>
+ * Liste aller Tabellennamen in diesem Schema, ohne die Schemaangabe im Namen. (Also 'anreden' und nicht
+ * 'public.anreden') <br/>
* Tested with PG 8.4
*
* @param schemaname
@@ -296,9 +293,7 @@
* @param name
* z.B.: keckformel wird dann zu keckformel()
* @param plCommands
- * z.B. NEW.kpk_kreis =
- * NEW.risiko_soz+NEW.risiko_emo+NEW.risiko_moti
- * +NEW.risiko_spr+NEW.risiko_wohl;
+ * z.B. NEW.kpk_kreis = NEW.risiko_soz+NEW.risiko_emo+NEW.risiko_moti +NEW.risiko_spr+NEW.risiko_wohl;
* @throws SQLException
*/
public static void createOrReplaceFunction(Connection c, String name, String plCommands) throws SQLException {
@@ -334,20 +329,18 @@
* @param idxNamePostfix
* e.g. 'idx1'
* @param unique
- * <code>true</code> if the columns are unique. A UNIQUE INDEX
- * will be created.
+ * <code>true</code> if the columns are unique. A UNIQUE INDEX will be created.
*/
public static void addIndex(Connection c, final String tableName, final String columns, String idxPostfix,
final boolean unique) throws SQLException {
- addIndex(c, tableName, columns, idxPostfix, unique, null, null, false);
+ addIndex(c, tableName, columns, idxPostfix, unique, null, null, false, 0.9);
}
/**
- * Liefert eine Liste aller Indexnamen die für eine Tabelle existieren. Der
- * Tabellenname wird mit <code>like</code> verglichen, darf also
- * <code>%</code> enthalten.<br/>
- * Achtung: Diese abfrage ist nicht Schema-Spezifisch. Eine schema. Angabe
- * vor dem tabellennamen wird automatisch entfernt.
+ * Liefert eine Liste aller Indexnamen die für eine Tabelle existieren. Der Tabellenname wird mit <code>like</code>
+ * verglichen, darf also <code>%</code> enthalten.<br/>
+ * Achtung: Diese abfrage ist nicht Schema-Spezifisch. Eine schema. Angabe vor dem tabellennamen wird automatisch
+ * entfernt.
*/
public static List<String> listIndexesForTable(Connection c, String tableName) throws SQLException {
Statement s = c.createStatement();
@@ -381,21 +374,20 @@
* @param idxNamePostfix
* e.g. 'idx1'
* @param unique
- * <code>true</code> if the columns are unique. A UNIQUE INDEX
- * will be created.
+ * <code>true</code> if the columns are unique. A UNIQUE INDEX will be created.
* @param tablespace
- * <code>null</code> oder der name des tablespace in dem der
- * Index liegen soll.
+ * <code>null</code> oder der name des tablespace in dem der Index liegen soll.
* @param type
- * <code>null</code> für DB default oder "hash" oder "btree" oder
- * "gin" etc...
+ * <code>null</code> für DB default oder "hash" oder "btree" oder "gin" etc...
* @param forceRecreationIfExistsAlready
- * wenn <code>true</code> dann werden der Index vorher gedroppt
- * falls er exisitert.
+ * wenn <code>true</code> dann werden der Index vorher gedroppt falls er exisitert.
+ * @param fillFactor
+ * Wert von >0. -> 1. Bei .5 wird für den Index doppelt so viel Platz reserviert wie aktuell benötig, um
+ * auf weiteres Wachstum der Tabelle ohne Indexfragmentierung reagieren zu können.
*/
public static void addIndex(Connection c, final String tableName, final String columns, String idxPostfix,
- final boolean unique, String tablespace, String type, boolean forceRecreationIfExistsAlready)
- throws SQLException {
+ final boolean unique, String tablespace, String type, boolean forceRecreationIfExistsAlready,
+ double fillFactor) throws SQLException {
String idxNameWithDot = tableName + "_" + idxPostfix;
final String idxName = idxNameWithDot.replace(".", "_");
@@ -443,9 +435,12 @@
Statement s = c.createStatement();
+ if (fillFactor <= 0. || fillFactor > 1.)
+ throw new IllegalArgumentException("fillFactor muss großer 0 und kleinergleich 1 sein.");
+
final String queryString = "CREATE " + (unique ? "UNIQUE " : "") + "INDEX " + idxName + " ON " + tableName
- + (type == null ? "" : " USING " + type) + " (" + columns + ") "
- + (tablespace == null ? "" : " TABLESPACE " + tablespace);
+ + (type == null ? "" : " USING " + type) + " (" + columns + ") " + "WITH (FILLFACTOR="
+ + (int) (fillFactor * 100) + (tablespace == null ? "" : " TABLESPACE " + tablespace);
try {
s.execute(queryString);
c.commit();
@@ -473,8 +468,8 @@
}
/**
- * Fügt einen Benutzer zu einer Rolle hinzu. Wenn der benutzer bereits in
- * der Rolle enthalten ist, wird keine Exception geschmisssen.
+ * Fügt einen Benutzer zu einer Rolle hinzu. Wenn der benutzer bereits in der Rolle enthalten ist, wird keine
+ * Exception geschmisssen.
*
* @throws SQLException
*/
@@ -483,9 +478,8 @@
}
/**
- * Der : (Doppelpunkt) hat in PSQL eine besondere Bedeutung. Er wind mit
- * dieser methode escaped. Diese Methode sollte mit
- * <code>like E'"+PGUtil.escape(...)+"'</code> verwendet werden.
+ * Der : (Doppelpunkt) hat in PSQL eine besondere Bedeutung. Er wind mit dieser methode escaped. Diese Methode
+ * sollte mit <code>like E'"+PGUtil.escape(...)+"'</code> verwendet werden.
*/
public static String escape(String key) {
key = key.replaceAll(":", "\\:");
@@ -498,11 +492,9 @@
* @param c
* DB-Verbindung
* @param dbName
- * Name der Datenbank fuer die die Sessions gezaehlt werden (kann
- * {@code null} sein)
+ * Name der Datenbank fuer die die Sessions gezaehlt werden (kann {@code null} sein)
* @param userName
- * Name des Users fuer den die Sessions gezaehlt werden (kann
- * {@code null} sein)
+ * Name des Users fuer den die Sessions gezaehlt werden (kann {@code null} sein)
*/
public static int getOpenSessionCount(Connection c, String dbName, String userName) throws SQLException {
return getOpenSessionCount(c, dbName, userName, null);
@@ -514,14 +506,11 @@
* @param c
* DB-Verbindung
* @param dbName
- * Name der Datenbank fuer die die Sessions gezaehlt werden (kann
- * {@code null} sein)
+ * Name der Datenbank fuer die die Sessions gezaehlt werden (kann {@code null} sein)
* @param userName
- * Name des Users fuer den die Sessions gezaehlt werden (kann
- * {@code null} sein)
+ * Name des Users fuer den die Sessions gezaehlt werden (kann {@code null} sein)
* @param queryLike
- * like-Beindung auf die Query die in der Session ausgeführt
- * wird, oder <code>null</code>
+ * like-Beindung auf die Query die in der Session ausgeführt wird, oder <code>null</code>
*/
public static int getOpenSessionCount(Connection c, String dbName, String userName, String queryLike)
throws SQLException {
More information about the Schmitzm-commits
mailing list