January 2010 - Mapstoragemanager-commits - mailman.cloud.codelutin.com

r20 - trunk/src/main/java/org/nuiton/mapstoragemanager/plugins
by dlanglais＠users.nuiton.org 26 Jan '10

26 Jan '10

Author: dlanglais Date: 2010-01-26 22:16:50 +0100 (Tue, 26 Jan 2010) New Revision: 20 Added: trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/nvBigTable.java Log: Cr?\195?\169ation d'une "vraie" interface BigTable. L'actuelle interface BigTable.java servant ?\195?\160 tester des plugins simples... -> In a future not very far away, nvBigTable will be "BigTable", and our current BigTable won't survive... ^^ Added: trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/nvBigTable.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/nvBigTable.java (rev 0) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/nvBigTable.java 2010-01-26 21:16:50 UTC (rev 20) @@ -0,0 +1,137 @@ + +import java.util.Map; +import java.util.Set; + +/* + * To change this template, choose Tools | Templates + * and open the template in the editor. + */ + +/** + * The interface for all the BigTable implementations. + * @author Dorian Langlais + */ +public interface nvBigTable { + + /** + * Connects to the database. + * @param host the server + * @param port the port + * @param base the base name + * @param username the user login + * @param passwd the user password + * @return return true if connexion is established, else return false. + */ + boolean connect( + String host, int port, String base, String username,String passwd); + + /****************** + * Tables * + ******************/ + + /** + * Selects the table. + * @param table the table to select + */ + void selectTable(String table); + + /** + * Create a new table in the base. + * @param table the name of the new table + */ + void createTable(String table); + + /** + * Delete a table in the base. + * @param table the table of the table to delete + */ + void deleteTable(String table); + + /** + * Get the tables' name which are in the base. + * @return Return a set containing the tables' name + */ + Set<String> getTablesNames(); + + + /******************* + * Columns * + *******************/ + + /** + * Create a new column in a table. + * Add a column column in the table table + * @param table the table name + * @param column the column name + */ + void createColumn(String table, String column); + + /** + * Delete a column in a table. + * Delete the column column in the table table + * @param table the table name + * @param column the column name + */ + void deleteColumn(String table, String column); + + /** + * Get the columns' name. + * @return Return a set containing the columns' name. + */ + Set<String> getColumnsNames(); + + /*************** + * Cell * + ***************/ + + /** + * Put a new content in the table. + * Put a new content in the column column of the table + * table with the key key. + * @param table the table name + * @param column the column name + * @param key the key + * @param content the content to add + */ + void put(String table, String column, String key, String content); + + /** + * Get a content in the table. + * Get a content in the table table from the column column + * where the key is key. + * -> get the last value (with the greater timestamp). + * @param table the table name. + * @param column the column name. + * @param key the key + * @return the content + */ + String get(String table, String column, String key); + + /** + * Get a content in the table. + * Get a content in the table table from the column column + * where the key is key. + * -> get the content with the version version. + * @param table the table name. + * @param column the column name. + * @param key the key + * @param version + * @return the content + */ + String get(String table, String column, String key, int version); + + /** + * Get the row identified by the key key from the table table + * @param table the table name + * @param key the key + * @return a Map with key is column's name and value is content's value. + */ + Map<String, String> getRow(String table, String key); + + /** + * Get the keys from a table. + * @param table the table + * @return return a Set containing the keys a the table table. + */ + Set<String> getKeys(String table); +}

1 0

r19 - in trunk: . src/main/java/org/nuiton/mapstoragemanager/plugins
by dlanglais＠users.nuiton.org 26 Jan '10

26 Jan '10

Author: dlanglais Date: 2010-01-26 20:47:36 +0100 (Tue, 26 Jan 2010) New Revision: 19 Added: trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/HBase.java Modified: trunk/pom.xml Log: R?\195?\169insertion du plugin HBase, n?\195?\169anmoins, je l'ai exclu du pom.xml Tant que l'on a pas r?\195?\169solu le probl?\195?\168me de plugin maven HBase (trouver un repository maven qui contient le plugin...) il serait plus "maven/devel friendly" de le cantonner l?\195?\160. Modified: trunk/pom.xml =================================================================== --- trunk/pom.xml 2010-01-26 17:30:00 UTC (rev 18) +++ trunk/pom.xml 2010-01-26 19:47:36 UTC (rev 19) @@ -84,10 +84,29 @@ </properties> <build> + <resources> + <resource> + <directory>src/main/java/org/nuiton/mapstoragemanager/plugins</directory> + <excludes> + <exclude>HBase.java</exclude> + </excludes> + </resource> + </resources> + <plugins> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-compiler-plugin</artifactId> + <configuration> + <excludes> + <exclude>org/nuiton/mapstoragemanager/plugins/HBase.java</exclude> + </excludes> + </configuration> + </plugin> + <plugin> <groupId>org.nuiton.jaxx</groupId> <artifactId>maven-jaxx-plugin</artifactId> Added: trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/HBase.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/HBase.java (rev 0) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/HBase.java 2010-01-26 19:47:36 UTC (rev 19) @@ -0,0 +1,167 @@ +import java.io.IOException; +import java.util.ArrayList; +import java.util.HashSet; +import java.util.Set; +import org.nuiton.mapstoragemanager.plugins.BigTable; + +import org.apache.hadoop.hbase.HBaseConfiguration; +import org.apache.hadoop.hbase.client.Get; +import org.apache.hadoop.hbase.client.HTable; +import org.apache.hadoop.hbase.client.Put; +import org.apache.hadoop.hbase.client.Result; +import org.apache.hadoop.hbase.client.ResultScanner; +import org.apache.hadoop.hbase.client.Scan; +import org.apache.hadoop.hbase.util.Bytes; + + +public class HBase implements BigTable { + + private HBaseConfiguration config; + private HTable table; + private String familyName = "mylittlecolumnfamily"; + private String rowName = "myLittleRow"; + private String tableName = "mylittletable"; + + public HBase(){ + // You need a configuration object to tell the client where to connect. + // When you create a HBaseConfiguration, it reads in whatever you've set + // into your hbase-site.xml and in hbase-default.xml, as long as these can + // be found on the CLASSPATH + org.apache.hadoop.conf.Configuration conf = new org.apache.hadoop.conf.Configuration(); + config = new HBaseConfiguration(conf); + System.out.println("test"); + selectTable(tableName); + put("test", "val"); + put("test", "val2"); + put("test2", "val3"); + } + + @Override + public void put(String key, String value) { + + // To add to a row, use Put. A Put constructor takes the name of the row + // you want to insert into as a byte array. In HBase, the Bytes class has + // utility for converting all kinds of java types to byte arrays. In the + // below, we are converting the String "myLittleRow" into a byte array to + // use as a row key for our update. Once you have a Put instance, you can + // adorn it by setting the names of columns you want to update on the row, + // the timestamp to use in your update, etc.If no timestamp, the server + // applies current time to the edits. + Put p = new Put(Bytes.toBytes(rowName)); + + // To set the value you'd like to update in the row 'myRow', specify the + // column family, column qualifier, and value of the table cell you'd like + // to update. The column family must already exist in your table schema. + // The qualifier can be anything. All must be specified as byte arrays as + // hbase is all about byte arrays. Lets pretend the table + // 'myLittleHBaseTable' was created with a family 'myLittleFamily'. + p.add(Bytes.toBytes(familyName), Bytes.toBytes(key), + Bytes.toBytes(value)); + + // Once you've adorned your Put instance with all the updates you want to + // make, to commit it do the following (The HTable#put method takes the + // Put instance you've been building and pushes the changes you made into + // hbase) + + /*try { + table.put(p); + } catch (IOException e1) { + // TODO Auto-generated catch block + e1.printStackTrace(); + } +*/ + } + + @Override + public String get(String key) { + + // Now, to retrieve the data we just wrote. The values that come back are + // Result instances. Generally, a Result is an object that will package up + // the hbase return into the form you find most palatable. + Get g = new Get(Bytes.toBytes(rowName)); + Result r; + byte [] value = null; +// try { +// r = table.get(g); +// value = r.getValue(Bytes.toBytes(familyName), +// Bytes.toBytes(key)); +// } catch (IOException e) { +// e.printStackTrace(); +// } + + // If we convert the value bytes, we should get back 'Some Value', the + // value we inserted at this location. + String valueStr = Bytes.toString(value); + + return "valeur"; + //return valueStr; + } + + @Override + public Set<String> getKeys() { + + Set<String> keySet = new HashSet<String>(); + + // Sometimes, you won't know the row you're looking for. In this case, you + // use a Scanner. This will give you cursor-like interface to the contents + // of the table. To set up a Scanner, do like you did above making a Put + // and a Get, create a Scan. Adorn it with column names, etc. + Scan s = new Scan(); + //s.addColumn(Bytes.toBytes(familyName), Bytes.toBytes("test")); + ResultScanner scanner = null; + try { + scanner = table.getScanner(s); + } catch (IOException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + try { + // Scanners return Result instances. + // Now, for the actual iteration. One way is to use a while loop like so: + try { + for (Result rr = scanner.next(); rr != null; rr = scanner.next()) { + // print out the row we found and the columns we were looking for + System.out.println("Found row: " + rr); + keySet.add(rr.toString()); + } + + } catch (IOException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + + // The other approach is to use a foreach loop. Scanners are iterable! + // for (Result rr : scanner) { + // System.out.println("Found row: " + rr); + // } + } finally { + // Make sure you close your scanners when you are done! + // Thats why we have it inside a try/finally clause + scanner.close(); + } + + return keySet; + } + + public void selectTable(String tableName){ + // This instantiates an HTable object that connects you to + // the "myLittleHBaseTable" table. + try { + table = new HTable(config, tableName); + } catch (IOException e) { + e.printStackTrace(); + } + } + + @Override + public void connect(String host, String base, String username, + String password) { + // TODO Auto-generated method stub + + } + + public static void main(String[] args) { + HBase h = new HBase(); + } + +}

1 0

r18 - trunk
by fdesbois＠users.nuiton.org 26 Jan '10

26 Jan '10

Author: fdesbois Date: 2010-01-26 18:30:00 +0100 (Tue, 26 Jan 2010) New Revision: 18 Modified: trunk/pom.xml Log: Add Junit dependency for tests Modified: trunk/pom.xml =================================================================== --- trunk/pom.xml 2010-01-26 16:41:42 UTC (rev 17) +++ trunk/pom.xml 2010-01-26 17:30:00 UTC (rev 18) @@ -45,7 +45,13 @@ <artifactId>jaxx-widgets</artifactId> <version>${jaxx.version}</version> </dependency> - +  + <dependency> + <groupId>junit</groupId> + <artifactId>junit</artifactId> + <version>4.7</version> + <scope>test</scope> + </dependency> </dependencies>

1 0

r17 - trunk/src/main/java/org/nuiton/mapstoragemanager/core
by gcrieloue＠users.nuiton.org 26 Jan '10

26 Jan '10

Author: gcrieloue Date: 2010-01-26 17:41:42 +0100 (Tue, 26 Jan 2010) New Revision: 17 Added: trunk/src/main/java/org/nuiton/mapstoragemanager/core/BigTableLoader.java trunk/src/main/java/org/nuiton/mapstoragemanager/core/TestServiceLoader.java Log: Ajout d'une classe BigTableLoader destin?\195?\169e ?\195?\160 remplacer les classes Core et PluginLoader. En effet, BigTableLoader utilise ServiceLoader qui permet de simplifier grandement les choses. Added: trunk/src/main/java/org/nuiton/mapstoragemanager/core/BigTableLoader.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/core/BigTableLoader.java (rev 0) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/core/BigTableLoader.java 2010-01-26 16:41:42 UTC (rev 17) @@ -0,0 +1,83 @@ +package org.nuiton.mapstoragemanager.core; + +import java.io.File; +import java.net.MalformedURLException; +import java.net.URL; +import java.net.URLClassLoader; +import java.util.ServiceLoader; + +import org.nuiton.mapstoragemanager.plugins.BigTable; + +/** + * + * @author Crieloue Gilles + * + */ +public class BigTableLoader extends URLClassLoader{ + + /** + * The BigTable Set Loader. + */ + private ServiceLoader<BigTable> bigTableSetLoader; + + /** + * Class constructor. + * @param pluginsFolderPath the plugins folder path + * @param classLoader the parent classloader + * @throws MalformedURLException if the plugin folder is not found + */ + public BigTableLoader(final String pluginsFolderPath, + final ClassLoader classLoader) throws MalformedURLException { + + super(new URL[]{new File(pluginsFolderPath).toURI().toURL()}, + classLoader); + + for (File file : new File(pluginsFolderPath).listFiles()) { + if (file.getAbsolutePath().endsWith(".jar")) { + try { + this.addURL(file.toURI().toURL()); + } catch (MalformedURLException e) { + e.printStackTrace(); + } + } + } + + bigTableSetLoader = ServiceLoader.load(BigTable.class, this); + } + + /** + * Returns a string displaying all the available BigTable implementations. + * @return a string displaying all the available BigTable implementations + */ + public final String getBigTable() { + + String s = "Available Plugins :\n"; + + s += "\t* "; + if (!bigTableSetLoader.iterator().hasNext()) { + s += "No plugin."; + } + else { + for (BigTable bt : bigTableSetLoader) { + s += bt.getClass().getName(); + bt.put("key", "value"); + if (bt.get("key").equals("value")) { + s += " (working)" + "\n"; + } + else { + s += " (not working)" + "\n"; + } + } + } + return s; + } + + /** + * Returns the BigTable Set Loader. + * @return the BigTable Set Loader + */ + public final ServiceLoader<BigTable> getBigTableSetLoader() { + return bigTableSetLoader; + } + +} Added: trunk/src/main/java/org/nuiton/mapstoragemanager/core/TestServiceLoader.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/core/TestServiceLoader.java (rev 0) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/core/TestServiceLoader.java 2010-01-26 16:41:42 UTC (rev 17) @@ -0,0 +1,20 @@ +package org.nuiton.mapstoragemanager.core; + +import java.net.MalformedURLException; + +public class TestServiceLoader { + public TestServiceLoader(){ + try { + BigTableLoader p = new BigTableLoader("plugins", this.getClass().getClassLoader()); + System.out.println(p.getBigTable()); + } catch (MalformedURLException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + } + + public static void main(String[] args) { + + TestServiceLoader t = new TestServiceLoader(); + } +}

1 0

r16 - trunk/src/main/java/org/nuiton/mapstoragemanager/plugins
by dlanglais＠users.nuiton.org 26 Jan '10

26 Jan '10

Author: dlanglais Date: 2010-01-26 16:58:26 +0100 (Tue, 26 Jan 2010) New Revision: 16 Removed: trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/HBase.java Modified: trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/ Log: suppression du plugin HBase (pour revenir plus fort ^^). Property changes on: trunk/src/main/java/org/nuiton/mapstoragemanager/plugins ___________________________________________________________________ Added: svn:ignore + HBase.java Deleted: trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/HBase.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/HBase.java 2010-01-26 13:47:13 UTC (rev 15) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/HBase.java 2010-01-26 15:58:26 UTC (rev 16) @@ -1,167 +0,0 @@ -import java.io.IOException; -import java.util.ArrayList; -import java.util.HashSet; -import java.util.Set; -import org.nuiton.mapstoragemanager.plugins.BigTable; - -import org.apache.hadoop.hbase.HBaseConfiguration; -import org.apache.hadoop.hbase.client.Get; -import org.apache.hadoop.hbase.client.HTable; -import org.apache.hadoop.hbase.client.Put; -import org.apache.hadoop.hbase.client.Result; -import org.apache.hadoop.hbase.client.ResultScanner; -import org.apache.hadoop.hbase.client.Scan; -import org.apache.hadoop.hbase.util.Bytes; - - -public class HBase implements BigTable { - - private HBaseConfiguration config; - private HTable table; - private String familyName = "mylittlecolumnfamily"; - private String rowName = "myLittleRow"; - private String tableName = "mylittletable"; - - public HBase(){ - // You need a configuration object to tell the client where to connect. - // When you create a HBaseConfiguration, it reads in whatever you've set - // into your hbase-site.xml and in hbase-default.xml, as long as these can - // be found on the CLASSPATH - org.apache.hadoop.conf.Configuration conf = new org.apache.hadoop.conf.Configuration(); - config = new HBaseConfiguration(conf); - System.out.println("test"); - selectTable(tableName); - put("test", "val"); - put("test", "val2"); - put("test2", "val3"); - } - - @Override - public void put(String key, String value) { - - // To add to a row, use Put. A Put constructor takes the name of the row - // you want to insert into as a byte array. In HBase, the Bytes class has - // utility for converting all kinds of java types to byte arrays. In the - // below, we are converting the String "myLittleRow" into a byte array to - // use as a row key for our update. Once you have a Put instance, you can - // adorn it by setting the names of columns you want to update on the row, - // the timestamp to use in your update, etc.If no timestamp, the server - // applies current time to the edits. - Put p = new Put(Bytes.toBytes(rowName)); - - // To set the value you'd like to update in the row 'myRow', specify the - // column family, column qualifier, and value of the table cell you'd like - // to update. The column family must already exist in your table schema. - // The qualifier can be anything. All must be specified as byte arrays as - // hbase is all about byte arrays. Lets pretend the table - // 'myLittleHBaseTable' was created with a family 'myLittleFamily'. - p.add(Bytes.toBytes(familyName), Bytes.toBytes(key), - Bytes.toBytes(value)); - - // Once you've adorned your Put instance with all the updates you want to - // make, to commit it do the following (The HTable#put method takes the - // Put instance you've been building and pushes the changes you made into - // hbase) - - /*try { - table.put(p); - } catch (IOException e1) { - // TODO Auto-generated catch block - e1.printStackTrace(); - } -*/ - } - - @Override - public String get(String key) { - - // Now, to retrieve the data we just wrote. The values that come back are - // Result instances. Generally, a Result is an object that will package up - // the hbase return into the form you find most palatable. - Get g = new Get(Bytes.toBytes(rowName)); - Result r; - byte [] value = null; -// try { -// r = table.get(g); -// value = r.getValue(Bytes.toBytes(familyName), -// Bytes.toBytes(key)); -// } catch (IOException e) { -// e.printStackTrace(); -// } - - // If we convert the value bytes, we should get back 'Some Value', the - // value we inserted at this location. - String valueStr = Bytes.toString(value); - - return "valeur"; - //return valueStr; - } - - @Override - public Set<String> getKeys() { - - Set<String> keySet = new HashSet<String>(); - - // Sometimes, you won't know the row you're looking for. In this case, you - // use a Scanner. This will give you cursor-like interface to the contents - // of the table. To set up a Scanner, do like you did above making a Put - // and a Get, create a Scan. Adorn it with column names, etc. - Scan s = new Scan(); - //s.addColumn(Bytes.toBytes(familyName), Bytes.toBytes("test")); - ResultScanner scanner = null; - try { - scanner = table.getScanner(s); - } catch (IOException e) { - // TODO Auto-generated catch block - e.printStackTrace(); - } - try { - // Scanners return Result instances. - // Now, for the actual iteration. One way is to use a while loop like so: - try { - for (Result rr = scanner.next(); rr != null; rr = scanner.next()) { - // print out the row we found and the columns we were looking for - System.out.println("Found row: " + rr); - keySet.add(rr.toString()); - } - - } catch (IOException e) { - // TODO Auto-generated catch block - e.printStackTrace(); - } - - // The other approach is to use a foreach loop. Scanners are iterable! - // for (Result rr : scanner) { - // System.out.println("Found row: " + rr); - // } - } finally { - // Make sure you close your scanners when you are done! - // Thats why we have it inside a try/finally clause - scanner.close(); - } - - return keySet; - } - - public void selectTable(String tableName){ - // This instantiates an HTable object that connects you to - // the "myLittleHBaseTable" table. - try { - table = new HTable(config, tableName); - } catch (IOException e) { - e.printStackTrace(); - } - } - - @Override - public void connect(String host, String base, String username, - String password) { - // TODO Auto-generated method stub - - } - - public static void main(String[] args) { - HBase h = new HBase(); - } - -}

1 0

r15 - trunk/src/main/java/org/nuiton/mapstoragemanager/plugins
by gcrieloue＠users.nuiton.org 26 Jan '10

26 Jan '10

Author: gcrieloue Date: 2010-01-26 14:47:13 +0100 (Tue, 26 Jan 2010) New Revision: 15 Added: trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/HBase.java trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/OurHashMap.java Log: Ajout des sources des plugins Added: trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/HBase.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/HBase.java (rev 0) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/HBase.java 2010-01-26 13:47:13 UTC (rev 15) @@ -0,0 +1,167 @@ +import java.io.IOException; +import java.util.ArrayList; +import java.util.HashSet; +import java.util.Set; +import org.nuiton.mapstoragemanager.plugins.BigTable; + +import org.apache.hadoop.hbase.HBaseConfiguration; +import org.apache.hadoop.hbase.client.Get; +import org.apache.hadoop.hbase.client.HTable; +import org.apache.hadoop.hbase.client.Put; +import org.apache.hadoop.hbase.client.Result; +import org.apache.hadoop.hbase.client.ResultScanner; +import org.apache.hadoop.hbase.client.Scan; +import org.apache.hadoop.hbase.util.Bytes; + + +public class HBase implements BigTable { + + private HBaseConfiguration config; + private HTable table; + private String familyName = "mylittlecolumnfamily"; + private String rowName = "myLittleRow"; + private String tableName = "mylittletable"; + + public HBase(){ + // You need a configuration object to tell the client where to connect. + // When you create a HBaseConfiguration, it reads in whatever you've set + // into your hbase-site.xml and in hbase-default.xml, as long as these can + // be found on the CLASSPATH + org.apache.hadoop.conf.Configuration conf = new org.apache.hadoop.conf.Configuration(); + config = new HBaseConfiguration(conf); + System.out.println("test"); + selectTable(tableName); + put("test", "val"); + put("test", "val2"); + put("test2", "val3"); + } + + @Override + public void put(String key, String value) { + + // To add to a row, use Put. A Put constructor takes the name of the row + // you want to insert into as a byte array. In HBase, the Bytes class has + // utility for converting all kinds of java types to byte arrays. In the + // below, we are converting the String "myLittleRow" into a byte array to + // use as a row key for our update. Once you have a Put instance, you can + // adorn it by setting the names of columns you want to update on the row, + // the timestamp to use in your update, etc.If no timestamp, the server + // applies current time to the edits. + Put p = new Put(Bytes.toBytes(rowName)); + + // To set the value you'd like to update in the row 'myRow', specify the + // column family, column qualifier, and value of the table cell you'd like + // to update. The column family must already exist in your table schema. + // The qualifier can be anything. All must be specified as byte arrays as + // hbase is all about byte arrays. Lets pretend the table + // 'myLittleHBaseTable' was created with a family 'myLittleFamily'. + p.add(Bytes.toBytes(familyName), Bytes.toBytes(key), + Bytes.toBytes(value)); + + // Once you've adorned your Put instance with all the updates you want to + // make, to commit it do the following (The HTable#put method takes the + // Put instance you've been building and pushes the changes you made into + // hbase) + + /*try { + table.put(p); + } catch (IOException e1) { + // TODO Auto-generated catch block + e1.printStackTrace(); + } +*/ + } + + @Override + public String get(String key) { + + // Now, to retrieve the data we just wrote. The values that come back are + // Result instances. Generally, a Result is an object that will package up + // the hbase return into the form you find most palatable. + Get g = new Get(Bytes.toBytes(rowName)); + Result r; + byte [] value = null; +// try { +// r = table.get(g); +// value = r.getValue(Bytes.toBytes(familyName), +// Bytes.toBytes(key)); +// } catch (IOException e) { +// e.printStackTrace(); +// } + + // If we convert the value bytes, we should get back 'Some Value', the + // value we inserted at this location. + String valueStr = Bytes.toString(value); + + return "valeur"; + //return valueStr; + } + + @Override + public Set<String> getKeys() { + + Set<String> keySet = new HashSet<String>(); + + // Sometimes, you won't know the row you're looking for. In this case, you + // use a Scanner. This will give you cursor-like interface to the contents + // of the table. To set up a Scanner, do like you did above making a Put + // and a Get, create a Scan. Adorn it with column names, etc. + Scan s = new Scan(); + //s.addColumn(Bytes.toBytes(familyName), Bytes.toBytes("test")); + ResultScanner scanner = null; + try { + scanner = table.getScanner(s); + } catch (IOException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + try { + // Scanners return Result instances. + // Now, for the actual iteration. One way is to use a while loop like so: + try { + for (Result rr = scanner.next(); rr != null; rr = scanner.next()) { + // print out the row we found and the columns we were looking for + System.out.println("Found row: " + rr); + keySet.add(rr.toString()); + } + + } catch (IOException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + + // The other approach is to use a foreach loop. Scanners are iterable! + // for (Result rr : scanner) { + // System.out.println("Found row: " + rr); + // } + } finally { + // Make sure you close your scanners when you are done! + // Thats why we have it inside a try/finally clause + scanner.close(); + } + + return keySet; + } + + public void selectTable(String tableName){ + // This instantiates an HTable object that connects you to + // the "myLittleHBaseTable" table. + try { + table = new HTable(config, tableName); + } catch (IOException e) { + e.printStackTrace(); + } + } + + @Override + public void connect(String host, String base, String username, + String password) { + // TODO Auto-generated method stub + + } + + public static void main(String[] args) { + HBase h = new HBase(); + } + +} Added: trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/OurHashMap.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/OurHashMap.java (rev 0) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/OurHashMap.java 2010-01-26 13:47:13 UTC (rev 15) @@ -0,0 +1,35 @@ +package org.nuiton.mapstoragemanager.plugins; + +import java.util.HashMap; +import java.util.Set; + +import org.nuiton.mapstoragemanager.plugins.BigTable; + +public class OurHashMap implements BigTable{ + + HashMap<String,String> map = new HashMap<String, String>(); + + public String get(String key) { + return map.get(key); + } + + public Set<String> getKeys() { + return map.keySet(); + } + + public void put(String key, String value) { + map.put(key, value); + } + + public void connect(String host, String base, String username, + String password) { + // TODO Auto-generated method stub + + } + + public void selectTable(String table) { + // TODO Auto-generated method stub + + } + +}

1 0

r14 - in trunk/src/main: java/org/nuiton/mapstoragemanager/ui java/org/nuiton/mapstoragemanager/ui/gui resources/i18n
by dlanglais＠users.nuiton.org 26 Jan '10

26 Jan '10

Author: dlanglais Date: 2010-01-26 14:39:59 +0100 (Tue, 26 Jan 2010) New Revision: 14 Removed: trunk/src/main/java/org/nuiton/mapstoragemanager/ui/connexionBar.jaxx trunk/src/main/java/org/nuiton/mapstoragemanager/ui/menu.jaxx trunk/src/main/java/org/nuiton/mapstoragemanager/ui/tableview.jaxx trunk/src/main/java/org/nuiton/mapstoragemanager/ui/tree.jaxx Modified: trunk/src/main/java/org/nuiton/mapstoragemanager/ui/MainUI.jaxx trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationEngine.java trunk/src/main/resources/i18n/mapstoragemanager-en_GB.properties trunk/src/main/resources/i18n/mapstoragemanager-fr_FR.properties Log: Tony Chemit n'avait pas commit, so j'ai refait les modifs (en plus ?\195?\167a m'a permit de mieux comprendre ce que l'on a fait). J'ai supprim?\195?\169 les fichiers .jaxx "useless". Modified: trunk/src/main/java/org/nuiton/mapstoragemanager/ui/MainUI.jaxx =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/ui/MainUI.jaxx 2010-01-26 08:59:42 UTC (rev 13) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/ui/MainUI.jaxx 2010-01-26 13:39:59 UTC (rev 14) @@ -5,22 +5,81 @@ maximumSize="{new Dimension(constants.MAXIMUM_SIZE_WIDTH,constants.MAXIMUM_SIZE_HEIGHT)}" resizable='true'> + <script><![CDATA[ +import org.nuiton.mapstoragemanager.ui.gui.ApplicationConstants; +import org.nuiton.mapstoragemanager.ui.gui.ApplicationEngine; +ApplicationEngine engine = new ApplicationEngine(); +ApplicationConstants constants = new ApplicationConstants(); +]]> + </script> +  <style source='MainUI.css'/>  -<gui.ApplicationConstants id='constants'/> -<gui.ApplicationEngine id='engine'/>  - <menu/> + <JMenuBar> + <JMenu text="File"> + <JMenuItem text="Connect" onActionPerformed='engine.doSomething()'/> + <JMenuItem text="Disconnect" onActionPerformed='engine.doSomething()'/> + <JSeparator/> + <JMenuItem text="Quit" onActionPerformed='engine.close()'/> + </JMenu> + <JMenu text="Edit"> + <JMenuItem text="Preferences" onActionPerformed='engine.doSomething()'/> + </JMenu> + <JMenu text="Help"> + <JMenuItem text="About Us" onActionPerformed='engine.showGreeting()'/> + </JMenu> + </JMenuBar> <java.awt.BorderLayout id='BorderLayout'/> - <JPanel layout='{BorderLayout}'> - <connexionBar constraints='BorderLayout.NORTH'/> + <JPanel layout='{BorderLayout}'> + <JToolBar constraints='BorderLayout.NORTH' opaque='true'> + +  + +  + + <JLabel text='name base :' styleClass='boldUnderline' /> + <JAXXComboBox> + <item value='{null}' label='Select a base name' /> + <item value='HBase'/> + <item value='Cassandra'/> + <item value='Other'/> + </JAXXComboBox> + <JLabel text='login :' styleClass='boldUnderline' /> + <JTextField/> + <JLabel text='password :' styleClass='boldUnderline' /> + <JPasswordField/> + <JButton text='OK'/> + </JToolBar> <JSplitPane constraints='BorderLayout.CENTER' dividerLocation='200' > - <tree/> - <tableview/> + <JScrollPane> + <JPanel> +  + <JAXXTree id='baseSchema' showsRootHandles='true' onValueChanged='engine.doSomething()' > + <item value='No base schema' /> + </JAXXTree> + </JPanel> + </JScrollPane> + <JScrollPane> + +  + +  + + <VBox horizontalAlignment='center'> + <JPanel> + </JPanel> + <JLabel text="TABLE NAME : TODO"/> + </VBox> + + </JScrollPane> </JSplitPane> </JPanel> </Application> Deleted: trunk/src/main/java/org/nuiton/mapstoragemanager/ui/connexionBar.jaxx =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/ui/connexionBar.jaxx 2010-01-26 08:59:42 UTC (rev 13) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/ui/connexionBar.jaxx 2010-01-26 13:39:59 UTC (rev 14) @@ -1,19 +0,0 @@ -<JToolBar opaque='true'> - - - - - - <JLabel text='name base :' styleClass='boldUnderline' /> - <JComboBox> - <item value='{null}' label='Select a base name' /> - <item value='HBase'/> - <item value='Cassandra'/> - <item value='Other'/> - </JComboBox> - <JLabel text='login :' styleClass='boldUnderline' /> - <JTextField/> - <JLabel text='password :' styleClass='boldUnderline' /> - <JPasswordField/> - <JButton text='OK'/> -</JToolBar> \ No newline at end of file Modified: trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationEngine.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationEngine.java 2010-01-26 08:59:42 UTC (rev 13) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationEngine.java 2010-01-26 13:39:59 UTC (rev 14) @@ -13,7 +13,7 @@ * Show the developers. * // TO MODIFY */ - protected final void showGreeting() { + public final void showGreeting() { JOptionPane.showMessageDialog(null, this, "Developers:\n" + "===========\n" @@ -28,12 +28,12 @@ /** * Method to close the application. */ - protected final void close() { + public final void close() { System.exit(0); } /** * do nothing (for instance). */ - protected void doSomething() { } + public void doSomething() { } } Deleted: trunk/src/main/java/org/nuiton/mapstoragemanager/ui/menu.jaxx =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/ui/menu.jaxx 2010-01-26 08:59:42 UTC (rev 13) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/ui/menu.jaxx 2010-01-26 13:39:59 UTC (rev 14) @@ -1,19 +0,0 @@ -<JMenuBar> - - -<gui.ApplicationEngine id='engine'/> - - - <JMenu text="File"> - <JMenuItem text="Connect" onActionPerformed='engine.doSomething()'/> - <JMenuItem text="Disconnect" onActionPerformed='engine.doSomething()'/> - <JSeparator/> - <JMenuItem text="Quit" onActionPerformed='engine.close()'/> - </JMenu> - <JMenu text="Edit"> - <JMenuItem text="Preferences" onActionPerformed='engine.doSomething()'/> - </JMenu> - <JMenu text="Help"> - <JMenuItem text="About Us" onActionPerformed='engine.showGreeting()'/> - </JMenu> -</JMenuBar> \ No newline at end of file Deleted: trunk/src/main/java/org/nuiton/mapstoragemanager/ui/tableview.jaxx =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/ui/tableview.jaxx 2010-01-26 08:59:42 UTC (rev 13) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/ui/tableview.jaxx 2010-01-26 13:39:59 UTC (rev 14) @@ -1,13 +0,0 @@ -<JScrollPane> - - - - - - <VBox horizontalAlignment='center'> - <JPanel> - </JPanel> - <JLabel text="TABLE NAME : TODO"/> - </VBox> - -</JScrollPane> \ No newline at end of file Deleted: trunk/src/main/java/org/nuiton/mapstoragemanager/ui/tree.jaxx =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/ui/tree.jaxx 2010-01-26 08:59:42 UTC (rev 13) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/ui/tree.jaxx 2010-01-26 13:39:59 UTC (rev 14) @@ -1,20 +0,0 @@ -<JScrollPane> - - -<gui.ApplicationEngine id='engine'/> - - - <JPanel> - -  - - - <JTree id='baseSchema' showsRootHandles='true' onValueChanged='engine.doSomething()' > - - <item value='No base schema' /> - </JTree> - </JPanel> -</JScrollPane> \ No newline at end of file Modified: trunk/src/main/resources/i18n/mapstoragemanager-en_GB.properties =================================================================== --- trunk/src/main/resources/i18n/mapstoragemanager-en_GB.properties 2010-01-26 08:59:42 UTC (rev 13) +++ trunk/src/main/resources/i18n/mapstoragemanager-en_GB.properties 2010-01-26 13:39:59 UTC (rev 14) @@ -1 +1,15 @@ -mapstoragemanager.hello=hello +About\ Us= +Connect= +Disconnect= +Edit= +File= +Hello= +Help= +OK= +Preferences= +Quit= +TABLE\ NAME\ \:\ TODO= +login\ \:= +mapstoragemanager.hello=hello +name\ base\ \:= +password\ \:= Modified: trunk/src/main/resources/i18n/mapstoragemanager-fr_FR.properties =================================================================== --- trunk/src/main/resources/i18n/mapstoragemanager-fr_FR.properties 2010-01-26 08:59:42 UTC (rev 13) +++ trunk/src/main/resources/i18n/mapstoragemanager-fr_FR.properties 2010-01-26 13:39:59 UTC (rev 14) @@ -1 +1,15 @@ -mapstoragemanager.hello=bonjour +About\ Us= +Connect= +Disconnect= +Edit= +File= +Hello= +Help= +OK= +Preferences= +Quit= +TABLE\ NAME\ \:\ TODO= +login\ \:= +mapstoragemanager.hello=bonjour +name\ base\ \:= +password\ \:=

1 0

r13 - in trunk/src/main/java/org/nuiton/mapstoragemanager: core plugins ui/gui
by dlanglais＠users.nuiton.org 26 Jan '10

26 Jan '10

Author: dlanglais Date: 2010-01-26 09:59:42 +0100 (Tue, 26 Jan 2010) New Revision: 13 Modified: trunk/src/main/java/org/nuiton/mapstoragemanager/core/Core.java trunk/src/main/java/org/nuiton/mapstoragemanager/core/MainTestCore.java trunk/src/main/java/org/nuiton/mapstoragemanager/core/PluginLoader.java trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/BigTable.java trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationConstants.java trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationEngine.java Log: Correction d'erreur checkstyle. Modified: trunk/src/main/java/org/nuiton/mapstoragemanager/core/Core.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/core/Core.java 2010-01-23 14:27:12 UTC (rev 12) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/core/Core.java 2010-01-26 08:59:42 UTC (rev 13) @@ -8,8 +8,15 @@ import org.nuiton.mapstoragemanager.plugins.BigTable; +/** + * Class Core. + * This class permit to manage plugins. + * @author E054030D + * + */ public class Core { - /** + + /** * A map "name of the plugin" - "plugin instance". */ private HashMap < String, BigTable > bases = Modified: trunk/src/main/java/org/nuiton/mapstoragemanager/core/MainTestCore.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/core/MainTestCore.java 2010-01-23 14:27:12 UTC (rev 12) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/core/MainTestCore.java 2010-01-26 08:59:42 UTC (rev 13) @@ -4,11 +4,11 @@ public class MainTestCore { - /** * test for plugins loading and basic functions. + * @param args args */ - public static void main(String[] args) { + public static void main(final String[] args) { Core core = new Core(); Modified: trunk/src/main/java/org/nuiton/mapstoragemanager/core/PluginLoader.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/core/PluginLoader.java 2010-01-23 14:27:12 UTC (rev 12) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/core/PluginLoader.java 2010-01-26 08:59:42 UTC (rev 13) @@ -146,8 +146,6 @@ classes.add(tmpClass); } } - - } /** Modified: trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/BigTable.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/BigTable.java 2010-01-23 14:27:12 UTC (rev 12) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/BigTable.java 2010-01-26 08:59:42 UTC (rev 13) @@ -17,13 +17,13 @@ * @param password the user password */ void connect(String host, String base, String username, String password); - + /** * Selects the table. * @param table the table name */ void selectTable(String table); - + /** * Get the value matching a key. * @param key the key Modified: trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationConstants.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationConstants.java 2010-01-23 14:27:12 UTC (rev 12) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationConstants.java 2010-01-26 08:59:42 UTC (rev 13) @@ -1,17 +1,37 @@ package org.nuiton.mapstoragemanager.ui.gui; +/** + * Application's constants. + * To configure the swing view. + * @author E054030D + * + */ public class ApplicationConstants { - public final static int DEFAULT_WIDTH = 1024; - public final static int DEFAULT_HEIGHT = 800; - - public final static int MINIMUM_SIZE_WIDTH = 600; - public final static int MINIMUM_SIZE_HEIGHT = 480; - - public final static int MAXIMUM_SIZE_WIDTH = 1920; - public final static int MAXIMUM_SIZE_HEIGHT = 1080; - - - - + /** + * default width, when the application start. + */ + public static final int DEFAULT_WIDTH = 1024; + /** + * default height, when the application start. + */ + public static final int DEFAULT_HEIGHT = 800; + + /** + * Minimum width. + */ + public static final int MINIMUM_SIZE_WIDTH = 600; + /** + * Minimum height. + */ + public static final int MINIMUM_SIZE_HEIGHT = 480; + + /** + * Maximum width. + */ + public static final int MAXIMUM_SIZE_WIDTH = 1920; + /** + * Maximum height. + */ + public static final int MAXIMUM_SIZE_HEIGHT = 1080; } Modified: trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationEngine.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationEngine.java 2010-01-23 14:27:12 UTC (rev 12) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationEngine.java 2010-01-26 08:59:42 UTC (rev 13) @@ -2,23 +2,38 @@ import javax.swing.JOptionPane; +/** + * Engine Class with methods for application user interface. + * @author E054030D + * + */ public class ApplicationEngine { - protected void showGreeting() { - JOptionPane.showMessageDialog(null, this, - "Developers:\n"+ - "===========\n"+ - "Crieloue Gilles\n"+ - "Fages Amaury\n"+ - "Langlais Dorian"+ - "\nForent\n"+ - "===========\n"+ - "Master ALMA", 0); - } + /** + * Show the developers. + * // TO MODIFY + */ + protected final void showGreeting() { + JOptionPane.showMessageDialog(null, this, + "Developers:\n" + + "===========\n" + + "Crieloue Gilles\n" + + "Fages Amaury\n" + + "Langlais Dorian" + + "\nForent\n" + + "===========\n" + + "Master ALMA", 0); + } - protected void close() { - System.exit(0); - } + /** + * Method to close the application. + */ + protected final void close() { + System.exit(0); + } - protected void doSomething(){} + /** + * do nothing (for instance). + */ + protected void doSomething() { } }

1 0

r12 - in trunk/src/main/java/org/nuiton/mapstoragemanager: . core plugins
by gcrieloue＠users.nuiton.org 23 Jan '10

23 Jan '10

Author: gcrieloue Date: 2010-01-23 15:27:12 +0100 (Sat, 23 Jan 2010) New Revision: 12 Added: trunk/src/main/java/org/nuiton/mapstoragemanager/core/ trunk/src/main/java/org/nuiton/mapstoragemanager/core/Core.java trunk/src/main/java/org/nuiton/mapstoragemanager/core/MainTestCore.java trunk/src/main/java/org/nuiton/mapstoragemanager/core/Messages.java trunk/src/main/java/org/nuiton/mapstoragemanager/core/PluginLoader.java trunk/src/main/java/org/nuiton/mapstoragemanager/core/messages.properties trunk/src/main/java/org/nuiton/mapstoragemanager/core/package-info.java trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/ trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/BigTable.java trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/package-info.java Log: ajouts de l'architecture ?\195?\160 plugins (echec lors du commit pr?\195?\169c?\195?\169dent) Added: trunk/src/main/java/org/nuiton/mapstoragemanager/core/Core.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/core/Core.java (rev 0) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/core/Core.java 2010-01-23 14:27:12 UTC (rev 12) @@ -0,0 +1,92 @@ +package org.nuiton.mapstoragemanager.core; + +import java.io.File; +import java.io.IOException; +import java.net.URL; +import java.util.ArrayList; +import java.util.HashMap; + +import org.nuiton.mapstoragemanager.plugins.BigTable; + +public class Core { + /** + * A map "name of the plugin" - "plugin instance". + */ + private HashMap < String, BigTable > bases = + new HashMap < String, BigTable > (); + + /** + * The plugin loader. + */ + private PluginLoader pluginLoader = null; + + /** + * Class constructor. + */ + public Core() { + try { + File directory = new File( + Messages.getString("Config.url")); + pluginLoader = new PluginLoader( + new URL[]{directory.toURI().toURL()}, + this.getClass().getClassLoader()); + } catch (Exception e1) { + e1.printStackTrace(); + } + try { + loadAvailableBases(); + } catch (IOException e) { + e.printStackTrace(); + } + } + + /** + * Loads all the plugins (IBigTable implementations). + * @throws IOException if the classes are not loaded correctly + */ + private void loadAvailableBases() throws IOException { + for (Class < ? > tmpClass : pluginLoader.getPluginsClasses()) { + for (Class < ? > i : tmpClass.getInterfaces()) { + /* + * If the class implements the IBigTable + * interface, an instance is created + * and added to the list + */ + if (i.getName().equals("plugins.IBigTable")) { + try { + bases.put(tmpClass.getName(), + (BigTable) tmpClass.newInstance()); + } catch (InstantiationException e) { + e.printStackTrace(); + } catch (IllegalAccessException e) { + e.printStackTrace(); + } + } + } + } + } + + /** + * Returns an ArrayList of all the plugins instances. + * @return an ArrayList of all the plugins instances + */ + public final ArrayList < BigTable > getAvailableBases() { + ArrayList < BigTable > bigTables = new ArrayList < BigTable > (); + for (BigTable bigTable : bases.values()) { + bigTables.add(bigTable); + } + return bigTables; + } + + /** + * Returns an ArrayList of all the plugins class names. + * @return an ArrayList of all the plugins class names + */ + public final ArrayList < String > listPlugins() { + ArrayList < String > s = new ArrayList<String>(); + for (String plugin : this.bases.keySet()) { + s.add(plugin); + } + return s; + } +} Added: trunk/src/main/java/org/nuiton/mapstoragemanager/core/MainTestCore.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/core/MainTestCore.java (rev 0) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/core/MainTestCore.java 2010-01-23 14:27:12 UTC (rev 12) @@ -0,0 +1,29 @@ +package org.nuiton.mapstoragemanager.core; + +import org.nuiton.mapstoragemanager.plugins.BigTable; + +public class MainTestCore { + + + /** + * test for plugins loading and basic functions. + */ + public static void main(String[] args) { + + Core core = new Core(); + + System.out.println("Plugins disponibles"); + for (String base : core.listPlugins()) { + System.out.println("* " + base); + } + + /* Test du plugins */ + + for (BigTable bigTable : core.getAvailableBases()) { + bigTable.put("clé", "valeur"); + System.out.println(bigTable.get("clé")); + } + + } + +} Added: trunk/src/main/java/org/nuiton/mapstoragemanager/core/Messages.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/core/Messages.java (rev 0) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/core/Messages.java 2010-01-23 14:27:12 UTC (rev 12) @@ -0,0 +1,42 @@ +package org.nuiton.mapstoragemanager.core; + +import java.util.MissingResourceException; +import java.util.ResourceBundle; + +/** + * Get strings from an external file. + * @author Crieloue Gilles + * + */ +public final class Messages { + + /** + * bundle name. + */ + private static final String BUNDLE_NAME = "core.messages"; //$NON-NLS-1$ + + /** + * ressource bundle. + */ + private static final ResourceBundle RESOURCE_BUNDLE = ResourceBundle + .getBundle(BUNDLE_NAME); + + /** + * Constructor. + */ + private Messages() { + } + + /** + * Returns a result according to a key. + * @param key the key + * @return the matching result + */ + public static String getString(final String key) { + try { + return RESOURCE_BUNDLE.getString(key); + } catch (MissingResourceException e) { + return '!' + key + '!'; + } + } +} Added: trunk/src/main/java/org/nuiton/mapstoragemanager/core/PluginLoader.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/core/PluginLoader.java (rev 0) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/core/PluginLoader.java 2010-01-23 14:27:12 UTC (rev 12) @@ -0,0 +1,161 @@ +package org.nuiton.mapstoragemanager.core; + +import java.io.File; + +import java.io.IOException; +import java.net.MalformedURLException; +import java.net.URL; +import java.net.URLClassLoader; +import java.util.ArrayList; +import java.util.Enumeration; +import java.util.jar.JarEntry; +import java.util.jar.JarFile; +import java.util.logging.Logger; + +/** + * This class loads the plugins. + * @author Crieloue Gilles + * + */ +public class PluginLoader extends URLClassLoader { + + /** + * A logger. + */ + private Logger logger = Logger.getLogger(this.getClass().getName()); + + /** + * The plugin classes. + */ + private ArrayList < Class < ? > > classes = + new ArrayList < Class < ? > > (); + + /** + * Class constructor. + * @param urls for the class loader + * @param classLoader the parent ClassLoader + * @throws Exception if the directory URL doesn't exist + */ + public PluginLoader(final URL[] urls, final ClassLoader classLoader) + throws Exception { + super(urls, classLoader); + + File directory = new File(urls[0].getFile()); + if (!directory.exists()) { + throw new Exception("No directory " + urls[0]); + } + + // adds all the directory jars to the ClassLoader + for (File file : directory.listFiles()) { + if (file.getAbsolutePath().endsWith(".jar")) { + try { + this.addURL(file.toURI().toURL()); + } catch (MalformedURLException e) { + e.printStackTrace(); + } + } + } + + + File libs = new File("plugins/libs"); + if (!libs.exists()) { + throw new Exception("No directory " + libs.getAbsolutePath()); + } + + // adds all the libs jars to the ClassLoader + for (File file : libs.listFiles()) { + if (file.getAbsolutePath().endsWith(".jar")) { + try { + logger.info("== LIB " + file.getAbsolutePath() + "..."); + this.addURL(file.toURI().toURL()); + } catch (MalformedURLException e) { + e.printStackTrace(); + } + } + } + + // loads the jars classes + for (File file : directory.listFiles()) { + if (file.getAbsolutePath().endsWith(".jar")) { + logger.info("== JAR " + file.getAbsolutePath() + "..."); + loadJarClasses(file.getAbsolutePath()); + } + } + } + + /** + * Loads all the classes of a jar. + * (adds the path to the classLoader + * and adds the class to the classes list) + * @param jarPath the jar path + */ + private void loadJarClasses(final String jarPath) { + + File file = new File(jarPath); + logger.info("Loading " + jarPath + "..."); + + JarFile jar = null; + try { + jar = new JarFile(file.getAbsolutePath()); + } catch (IOException e) { + e.printStackTrace(); + } + +// Enumeration < JarEntry > entries2 = jar.entries(); +// while (entries2.hasMoreElements()) { +// JarEntry entry = entries2.nextElement(); +// if (entry.getName().startsWith("libs/")) { +// try { +// String fileName = entry.getName(); +// String entryURL = "jar:jar:file:" +// + jarPath + "!/" + fileName + "!/"; +// logger.info("== LIB " + fileName +// + " (" + entryURL + ") ..."); +// this.addURL(new URL(entryURL)); +// } catch (MalformedURLException e) { +// e.printStackTrace(); +// } +// } +// } + + Enumeration < JarEntry > entries = jar.entries(); + + // adds the classes from the jar to the classes list + while (entries.hasMoreElements()) { + Class < ? > tmpClass = null; + JarEntry entry = entries.nextElement(); + String fileName = entry.toString(); + String extension = ".class"; + + if (fileName.endsWith(extension)) { + logger.info("Loading " + fileName + "..."); + + // formating file name + fileName = fileName.substring(0, fileName.length() + - extension.length()); + fileName = fileName.replaceAll("/", "."); + + // loading class + try { + tmpClass = this.loadClass(fileName); + //Class.forName(fileName, true, this); + } catch (ClassNotFoundException e) { + e.printStackTrace(); + } + + classes.add(tmpClass); + } + } + + + } + + /** + * Returns the plugin classes. + * @return the plugin classes + */ + public final ArrayList < Class < ? > > getPluginsClasses() { + return classes; + } + +} Added: trunk/src/main/java/org/nuiton/mapstoragemanager/core/messages.properties =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/core/messages.properties (rev 0) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/core/messages.properties 2010-01-23 14:27:12 UTC (rev 12) @@ -0,0 +1 @@ +Config.url=plugins/ Added: trunk/src/main/java/org/nuiton/mapstoragemanager/core/package-info.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/core/package-info.java (rev 0) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/core/package-info.java 2010-01-23 14:27:12 UTC (rev 12) @@ -0,0 +1,5 @@ +/** + * The core architecture. + * It deals with plugins discovery, loading, and such. + */ +package org.nuiton.mapstoragemanager.core; Added: trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/BigTable.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/BigTable.java (rev 0) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/BigTable.java 2010-01-23 14:27:12 UTC (rev 12) @@ -0,0 +1,47 @@ +package org.nuiton.mapstoragemanager.plugins; + +import java.util.Set; + +/** + * The interface for all the BigTable implementations. + * @author Crieloue Gilles + * + */ +public interface BigTable { + + /** + * Connects to the database. + * @param host the server + * @param base the base name + * @param username the user login + * @param password the user password + */ + void connect(String host, String base, String username, String password); + + /** + * Selects the table. + * @param table the table name + */ + void selectTable(String table); + + /** + * Get the value matching a key. + * @param key the key + * @return the value + */ + String get(String key); + + /** + * put a value matching the key. + * @param key the key + * @param value the value + */ + void put(String key, String value); + + /** + * Returns the keys set. + * @return the keys set + */ + Set < String > getKeys(); + +} Added: trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/package-info.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/package-info.java (rev 0) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/plugins/package-info.java 2010-01-23 14:27:12 UTC (rev 12) @@ -0,0 +1,5 @@ +/** + * The plugins interfaces. + */ +package org.nuiton.mapstoragemanager.plugins; +

1 0

r11 - trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui
by gcrieloue＠users.nuiton.org 23 Jan '10

23 Jan '10

Author: gcrieloue Date: 2010-01-23 15:23:20 +0100 (Sat, 23 Jan 2010) New Revision: 11 Modified: trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationConstants.java trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationEngine.java Log: Ajout des packages de l'architecture ?\195?\160 plugins Modified: trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationConstants.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationConstants.java 2010-01-23 00:06:05 UTC (rev 10) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationConstants.java 2010-01-23 14:23:20 UTC (rev 11) @@ -1,3 +1,5 @@ +package org.nuiton.mapstoragemanager.ui.gui; + public class ApplicationConstants { public final static int DEFAULT_WIDTH = 1024; Modified: trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationEngine.java =================================================================== --- trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationEngine.java 2010-01-23 00:06:05 UTC (rev 10) +++ trunk/src/main/java/org/nuiton/mapstoragemanager/ui/gui/ApplicationEngine.java 2010-01-23 14:23:20 UTC (rev 11) @@ -1,3 +1,5 @@ +package org.nuiton.mapstoragemanager.ui.gui; + import javax.swing.JOptionPane; public class ApplicationEngine {

1 0