Skip to main content

Couchdb Explorer parte 3

Crear la clase Sesion.java
Donde administraremos las conexiones a las bases de datos
Donde administraremos las conexiones a las bases de datos
/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/
package org.avbravo.couchdb;
/**
*
* @author avbravo
*/
import com.fourspaces.couchdb.Database;
import com.fourspaces.couchdb.Document;
import com.fourspaces.couchdb.Session;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
import javax.swing.JOptionPane;
import org.openide.awt.StatusDisplayer;
/**
*
* @author avbravo
*/
public class Sesion {
private
private
private
private
static
static
static
static
String ipCouchdb = "localhost";
int puertoCouchdb = 5984;
String userCouchdb;
String passwordCouchdb;
private static String prefijo;
private static String formatoFecha;
public static Session dbSession;
public static Database db;
public static Document doc;
static Connection conn;
static Statement stmt;
static ResultSet rs;
static ResultSetMetaData mdata;
static DatabaseMetaData dmd;
int num_columnas;
static List<String> ListaTablas = new ArrayList<String>();
static List<String> ListaMensajes = new ArrayList<String>();
public static List<String> getListaMensajes() {
return ListaMensajes;
}
public static void setListaMensajes(List<String> ListaMensajes) {
Sesion.ListaMensajes = ListaMensajes;
}
public static String getFormatoFecha() {
return formatoFecha;
}
public static void setFormatoFecha(String formatoFecha) {
Sesion.formatoFecha = formatoFecha;
}
public static String getPrefijo() {
return prefijo;
}
public static void setPrefijo(String prefijo) {
Sesion.prefijo = prefijo;
}
public static List<String> getListaTablas() {
return ListaTablas;
}
public static void setListaTablas(List<String> ListaTablas) {
Sesion.ListaTablas = ListaTablas;
}
public String getIpCouchdb() {
return ipCouchdb;
}
public void setIpCouchdb(String ipCouchdb) {
this.ipCouchdb = ipCouchdb;
}
public String getPasswordCouchdb() {
return passwordCouchdb;
}
public void setPasswordCouchdb(String passwordCouchdb) {
this.passwordCouchdb = passwordCouchdb;
}
public int getPuertoCouchdb() {
return puertoCouchdb;
}
public void setPuertoCouchdb(int puertoCouchdb) {
this.puertoCouchdb = puertoCouchdb;
}
public String getUserCouchdb() {
return userCouchdb;
}
public void setUserCouchdb(String userCouchdb) {
this.userCouchdb = userCouchdb;
}
public static DatabaseMetaData getDmd() {
return dmd;
}
public static void setDmd(DatabaseMetaData dmd) {
Sesion.dmd = dmd;
}
/*
* Agrega una tabla a la lista
*/
public void AgregarTablaLista(String tabla){
try{
this.ListaTablas.add(tabla);
} catch (Exception ex) {
JOptionPane.showMessageDialog(null, "AgregarTablaLista()\nMensaje: " +
ex.getMessage(), "Error", JOptionPane.ERROR_MESSAGE);
}
}
/*
*inicio
*/
public boolean ConectarCouchDB() {
try {
dbSession = new Session(ipCouchdb, puertoCouchdb);
String host = dbSession.getHost();
//
// dbSession
List<String> databasesCouchdb = dbSession.getDatabaseNames();
StatusDisplayer.getDefault().setStatusText("host..." + dbSession.getHost());
if (dbSession == null) {
return false;
}
return true;
} catch (Exception ex) {
JOptionPane.showMessageDialog(null, "ConectarCouchDB()\nMensaje: " +
ex.getMessage(), "Error", JOptionPane.ERROR_MESSAGE);
this.ListaMensajes.add("ConectarCouchDB) " +
ex.getLocalizedMessage().toString());
StatusDisplayer.getDefault().setStatusText("ConectarCouchDB. Error " +
ex.getMessage().toString());
}
return false;
}
public boolean CrearBaseDatos(String dbname) {
try {
db = dbSession.createDatabase(dbname);
if (db == null) {
return false;
}
return true;
} catch (Exception ex) {
// JOptionPane.showMessageDialog(null, "CrearBaseDatos()\nMensaje: " +
ex.getMessage(), "Error", JOptionPane.ERROR_MESSAGE);
this.ListaMensajes.add("CrearBaseDatos(String dbname) " +
ex.getLocalizedMessage().toString());
StatusDisplayer.getDefault().setStatusText("CrearBaseDatos(String dbname).
Error " + ex.getMessage().toString());
}
return false;
}
public boolean AbrirBaseDatos(String dbname) {
try {
db = dbSession.getDatabase(dbname);
if (db == null) {
return false;
}
return true;
} catch (Exception ex) {
// JOptionPane.showMessageDialog(null, "AbrirBaseDatos()\nMensaje: " +
ex.getMessage(), "Error", JOptionPane.ERROR_MESSAGE);
this.ListaMensajes.add("AbrirBaseDatos(String dbname) " +
ex.getLocalizedMessage().toString());
StatusDisplayer.getDefault().setStatusText("AbrirBaseDatos(String dbname).
Error " + ex.getMessage().toString());
}
return false;
}
public void AgregarDocumentos() {
try {
doc = new Document();
doc.setId("myid");
doc.put("nombre", "valor");
db.saveDocument(doc);
} catch (Exception ex) {
this.ListaMensajes.add("AgregarDocumentos " + ex.getLocalizedMessage().toString());
StatusDisplayer.getDefault().setStatusText("AgregarDocumentos(). Error " +
ex.getMessage().toString());
}
}
public String FechaToString(Date date) {
try {
if (date == null) {
return "";
}
Calendar cal = Calendar.getInstance();
cal.setTime(date);
int day = cal.get(Calendar.DATE);
int month = cal.get(Calendar.MONTH) + 1;
int year = cal.get(Calendar.YEAR);
String sfecha;
String sdia, smonth, syear;
if (day < 10) {
sdia = "0" + String.valueOf(day);
} else {
sdia = String.valueOf(day);
}
if (month < 10) {
smonth = String.valueOf(month);
} else {
smonth = String.valueOf(month);
}
syear = String.valueOf(year);
formatoFecha = formatoFecha.trim();
if (formatoFecha.equals("dd/MM/aaaa")) {
return sdia + "/" + month + "/" + syear;
}
if (formatoFecha.equals("MM/dd/aaaa")) {
return smonth + "/" + sdia + "/" + syear;
}
if (formatoFecha.equals("aaaa/MM/dd")) {
return syear + "/" + smonth + "/" + sdia;
}
if (formatoFecha.equals("dd/aaaa/MM")) {
return sdia + "/" + syear + "/" + month;
}
if (formatoFecha.equals("MM/aaaa/dd")) {
return smonth + "/" + syear + "/" + sdia;
}
if (formatoFecha.equals("aaaa/dd/MM")) {
return syear + "/" + sdia + "/" + smonth;
}
} catch (Exception ex) {
// JOptionPane.showMessageDialog(null, "FechaToString()\nMensaje: " +
ex.getMessage(), "Error", JOptionPane.ERROR_MESSAGE);
StatusDisplayer.getDefault().setStatusText("FechaToString(). Error " +
ex.getMessage().toString());
this.ListaMensajes.add("FechaToString() "
+ex.getLocalizedMessage().toString());
}
return "";
}
public void procesarTabla(String tabla) {
try {
String name_couchdb = prefijo + tabla;
if (ConectarCouchDB() == true) {
if (CrearBaseDatos(name_couchdb) == true) {
if (AbrirBaseDatos(name_couchdb) == true) {
this.ListaMensajes.add("Migrando
: " + tabla + " a " + name_couchdb);
stmt = conn.createStatement();
rs = stmt.executeQuery("select * from " + tabla);
mdata = rs.getMetaData(); //metadata
num_columnas = mdata.getColumnCount(); //numero columnas
migrar();
}
stmt.close();
rs.close();
// conn.close();
}
}
} catch (Exception ex) {
StatusDisplayer.getDefault().setStatusText("procesarTabla(). Error " +
ex.getMessage().toString());
this.ListaMensajes.add("procesarTabla() "
+ex.getLocalizedMessage().toString());
}
}
private void migrar() {
try {
while (rs.next()) {
Document doc = new Document();
for (int i = 1; i <= num_columnas; i++) {
// Recorro las columnas
if (mdata.getColumnTypeName(i).equals("date")) {
String fecha = FechaToString(rs.getDate(i));
doc.put(mdata.getColumnLabel(i), fecha);
} else {
doc.put(mdata.getColumnLabel(i), rs.getString(i));
}
}
db.saveDocument(doc);
}
} catch (Exception ex) {
StatusDisplayer.getDefault().setStatusText("migrar(). Error " +
ex.getMessage().toString());
this.ListaMensajes.add("migrar() " +ex.getLocalizedMessage().toString());
}
}
}


CREAR LA CLASE DBGraphScene

package org.avbravo.couchdb;
import java.awt.Image;
import java.awt.Point;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import javax.swing.JOptionPane;
import org.netbeans.api.visual.vmd.VMDGraphScene;
import org.netbeans.api.visual.vmd.VMDNodeWidget;
import org.netbeans.api.visual.vmd.VMDPinWidget;
import org.openide.util.ImageUtilities;
/**
*
* @author avbravo
*/
public class DBGraphScene extends VMDGraphScene {
private static final Image IMAGE_LIST =
ImageUtilities.loadImage("org/avbravo/couchdb/resources/list_16.png"); // NOI18N
private static final Image IMAGE_ITEM =
ImageUtilities.loadImage("org/avbravo/couchdb/resources/item_16.png"); // NOI18N
private static int edgeID = 1;
Sesion sesion = new Sesion();
public DBGraphScene(Connection connection) {
try {
createSceneFromConnection(connection);
} catch (SQLException e) {
e.printStackTrace();
JOptionPane.showMessageDialog(null, "DBGraphScene()" + e.getLocalizedMessage().toString());
}
}
private void createSceneFromConnection(Connection jdbcConnection) throws SQLException {
try {
ArrayList<String> tables = new ArrayList<String>();
DatabaseMetaData databaseMetaData = jdbcConnection.getMetaData();
String[] names = {"TABLE"};
ResultSet resultSet = databaseMetaData.getTables(null, "%", "%", names);
while (resultSet.next()) {
String table = resultSet.getString("TABLE_NAME");
sesion.AgregarTablaLista(table);
tables.add(table);
createNode(this, (int) (Math.random() * 800), (int) (Math.random() * 800), IMAGE_LIST, table,
"Table", null);
// ResultSet columns = jdbcConnection.getMetaData().getColumns(null, null, table.toUpperCase(),
"%");
//Quitar el metodo toUpper() para evitar que no reconozca tablas con
//nombres en minuscula
ResultSet columns = jdbcConnection.getMetaData().getColumns(null, null, table, "%");
while (columns.next()) {
String columnName = columns.getString("COLUMN_NAME");
createPin(this, table, table + ":" + columnName, IMAGE_ITEM, columnName, columnName);
}
}
for (String string : tables) {
ResultSet resultSet1 = databaseMetaData.getExportedKeys(null, null, string);
while (resultSet1.next()) {
String pkTable = resultSet1.getString("PKTABLE_NAME");
String pkColumn = resultSet1.getString("PKCOLUMN_NAME");
String fkTable = resultSet1.getString("FKTABLE_NAME");
String fkColumn = resultSet1.getString("FKCOLUMN_NAME");
/*
*Para mostrar las relaciones de las tablas
* quitar el comentario de esta linea
* pendiente verificar el comportamiento con postgresql
*/
createEdge(this, fkTable + ":" + fkColumn, pkTable + ":" + pkColumn);
}
}
this.moveTo(null);
} catch (Exception ex) {
JOptionPane.showMessageDialog(null, "createSceneFromConnection<()" +
ex.getLocalizedMessage().toString());
}
}
private static String createNode(VMDGraphScene scene, int x, int y, Image image, String name, String type,
java.util.List<Image> glyphs) {
String node = name;
try {
VMDNodeWidget widget = (VMDNodeWidget) scene.addNode(node);
widget.setPreferredLocation(new Point(x, y));
widget.setNodeProperties(image, name, type, glyphs);
} catch (Exception ex) {
JOptionPane.showMessageDialog(null, "createNode()" + ex.getLocalizedMessage().toString());
}
return node;
}
private static void createPin(VMDGraphScene scene, String nodeID, String pinID, Image image, String
name, String type) {
((VMDPinWidget) scene.addPin(nodeID, pinID)).setProperties(name, null);
}
private static void createEdge(VMDGraphScene scene, String sourcePinID, String targetPinID) {
try {
String edge = "edge" + DBGraphScene.edgeID++;
scene.addEdge(edge);
scene.setEdgeSource(edge, sourcePinID);
scene.setEdgeTarget(edge, targetPinID);
} catch (Exception ex) {
JOptionPane.showMessageDialog(null, "createEdge()" + ex.getLocalizedMessage().toString());
}
}
private void moveTo(Point point) {
try {
int index = 0;
for (String node : getNodes()) {
getSceneAnimator().animatePreferredLocation(findWidget(node), point != null ? point : new Point(+
+index * 100, index * 100));
}
} catch (Exception ex) {
JOptionPane.showMessageDialog(null, "moveTo()" + ex.getLocalizedMessage().toString());
}
}
}


CREAR EL PAQUETE org.avbravo.couchdb.resources
Crear el paquete y guardar las imágenes allí.

Agregar imágenes









Comments

Popular posts from this blog

FileUpload con Primefaces

FileUpload con Primefaces

Si queremos subir imagenes a nuestra aplicación usaremos el componente FileUpload Debemos realizar los siguientes pasos:
Agregar al archivo web.xml

   <filter>        <filter-name>PrimeFaces FileUpload Filter</filter-name>        <filter-class>            org.primefaces.webapp.filter.FileUploadFilter        </filter-class>    </filter>    <filter-mapping>        <filter-name>PrimeFaces FileUpload Filter</filter-name>        <servlet-name>Faces Servlet</servlet-name>    </filter-mapping>



Crear dentro de resources el directorio donde deseamos almacenar las imagenes En este ejemplo: resources/fotos/clinicas y agregue una imagen llamada fotos.png que se usará como imagen inicial.



En JSFUtil u otro @Named Beans que usemos agregamos tres métodos uno para obtener el path de la aplicación web , otro para obtener el path relativo a /fotos/clinicas y el otro para copiar los archivos. /*

Tutorial básico de aplicaciones Web con NetBeans parte 1

NetBeans ofrece un excelente soporte para el desarrollo de aplicaciones Web, en esta ocasión lo haremos utilizando el Framework Java Server Faces 2.0.
En el Menu Seleccionamos Nuevo->Proyecto y luego en Categorias Java Web y en tipo de Proyectos Web  Application

indicamos el nombre del proyecto



Seleccinamos el servidor Web, usamos GlassFish ya que este soporta EJB3.0 y JSF 2.0

Framework Java Server Faces

El IDE genera el esquelto del proyecto
Web Pages   almacenamos las paginas .html, xhtml, jsf, los archivos de recursos, los scripts .js, imagenes Source Packages    Son las clases Java  Test Packages    Son las clases que usamos para los Test

Libraries     Tenemos las bibliotecas de Java y GlassFish necesarias para ejecutar la aplicación Web. Test Libraries     Están las bibliotecas usadas para los test 
Configuration Files    Archivos de configuración de la aplicación.

Ejecutamos la aplicación 

Esperamos que se inicie GlassFish y se cargue la aplicación
Este se ejecutara en nuestro servidor local y…

NetBeans 8.0.1 en Español

NetBeans 8.0.1 disponible en español
http://bits.netbeans.org/netbeans/8.0.1/community/
Esta disponible NetBeans 8.0.1 en varios idiomas .


Puedes descargar la nueva versión y utilizar las nuevas características