Database conversion - JDBC (Java Database Connectivity) Source Code in Java

Special : Web Developer's Collection CD-ROM
50,000+ Web Templates, Logos, Cliparts, Scripts. Order Now!

Add to Favorites Make Home Page

2030 Online

Language Categories

Source Codes Home
Project Ideas New!
Interview Questions
FAQs Home
ASP Home: ASP Source Codes; ASP Script Directory New!; ASP .Net Script Directory New!; ASP Interview Questions; ASP FAQs; ASP How Tos
C Home: C Source Codes; C Script Directory New!; C Interview Questions; C FAQs; C How Tos
C++ Home: C++ Source Codes; C++ Script Directory New!; C++ Interview Questions; C++ FAQs; C++ How Tos
Java Home: Java Source Codes; Java Directory New!; Java Interview Questions; Java FAQs; Java How Tos
JavaScript Home: JavaScript Directory New!; JavaScript Source Codes; JavaScript FAQs; JavaScript How Tos
COBOL Home: COBOL Source Codes; COBOL FAQs; COBOL How Tos
Pascal Home: Pascal Source Codes; Pascal FAQs; Pascal How Tos
PHP Script Directory New!
Python Script Directory New!
Perl & CGI Script Directory New!
Flash Script Directory New!
CFML Script Directory New!
Remotely Hosted Scripts New!
Tools & Utilities Directory New!
XML Script Directory New!
Best Programmers: Amit Mathur; Vishal Bhardwaj; Deepesh Jain
Vyom NetWork

Our Services

Get 9,000 Interview Questions & Answers in an eBook.

9500+ Pages
9000 Question & Answers
All Tech. Categories

14 MB Content

Get it now !!

Home » Java Home » JDBC (Java Database Connectivity) Home » Database conversion

A D V E R T I S E M E N T

Title	Database conversion
Author	M.Ravi Shankar
Author Email	shankarm_1983 [at] yahoo.co.in
Description	A Simple Database Conversion Program.
Category	Java » JDBC (Java Database Connectivity)
Hits	389697
Code	Select and Copy the Code
import java.io.; import java.util.; import java.awt.; import javax.swing.; import java.awt.event.; import java.sql.; import javax.swing.filechooser.; import javax.swing.table.; import javax.swing.event.; import java.sql.DatabaseMetaData.; import java.lang.String.; import java.util.Map.; class FieldInfo { public String Name; public String Type; public int Size; public int Precision; public int Scale; public boolean Primary; public boolean Unique; public boolean AllowNull; public String toString() { return "[ " + Name + ", " + Type + ", " + Size + ", " + Precision + ", " + Scale + ", " + Primary + ", " + Unique + ", " + AllowNull + " ]"; } } public class DataMigration { String s2[][]; int col,p,j1; /String strTypeName[] = { "GUID", "BIT", "BYTE", "LONGBINARY", "VARBINARY", "BINARY", "LONGCHAR", "CHAR", "CURRENCY", "INTEGER", "COUNTER", "SMALLINT", "REAL", "DOUBLE", "DATETIME", "VARCHAR" }; private static String strSQLServerType[] = { "UNIQUEIDENTIFIER", "BIT", "TINYINT", "VARBINARY", "VARBINARY", "VARBINARY", "VARBINARY", "CHAR", "MONEY", "INT", "INT", "SMALLINT", "REAL", "DECIMAL", "SMALLDATETIME", "VARCHAR" }; private static String strOracleType[] = { "UROWID", "CHAR", "NUMBER", "BLOB", "BLOB", "BLOB", "LONG", "CHAR", "NUMBER", "NUMBER", "NUMBER", "NUMBER", "NUMBER", "NUMBER", "DATE", "VARCHAR2" };/ LinkedList _fieldList = null; public LinkedList getFieldInfoList(String strTable, Connection conn,String strDestDSN,String strDestUser, String strDestPwd) { _fieldList = new LinkedList(); try { DatabaseMetaData dbmd = conn.getMetaData(); ResultSet rsIndex = dbmd.getIndexInfo(null, null, strTable, true, false); ArrayList arrIndexColumn = new ArrayList(); ArrayList arrIndexName = new ArrayList(); while( rsIndex.next() ) { String str = rsIndex.getString("COLUMN_NAME"); if( str == null ) str = ""; arrIndexColumn.add(str); str = rsIndex.getString("INDEX_NAME"); if( str == null ) str = ""; arrIndexName.add(str); } rsIndex.close(); Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery("SELECT * FROM " + strTable); ResultSetMetaData rsmd = rs.getMetaData(); col = rsmd.getColumnCount(); String s1[] =new String[col]; String s2[][]=new String[col][col]; int j=0,n=1,ij=0,l1=1; while(rs.next()) { for(p=0;p<col;p++) { s2[j][p]=rs.getString(n); n++; } n=1; j++; } for(int i = 1; i< col; i++) { FieldInfo info = new FieldInfo(); info.Name=rsmd.getColumnName(i); info.Type=rsmd.getColumnTypeName(i); info.Size=rsmd.getColumnDisplaySize(i); info.Precision = rsmd.getPrecision(i); info.Scale = rsmd.getScale(i); info.Primary = false; info.Unique = false; info.AllowNull = (rsmd.isNullable(i) == ResultSetMetaData.columnNullable); for(int k = 0; k < arrIndexColumn.size(); k++) { String s = arrIndexColumn.get(k).toString(); if( s.equals(info.Name) ) { info.Unique = true; break; } } _fieldList.add(info); } String ss="insert into "+ strTable +" values (?,?,?)"; Connection connDest = DriverManager.getConnection("jdbc:odbc:" + strDestDSN, strDestUser, strDestPwd); PreparedStatement p = connDest.prepareStatement(ss); for(int p1=0;p1<3;p1++) { p.setString(1,s2[p1][0]); p.setString(2,s2[p1][1]); p.setString(3,s2[p1][2]); if( p.executeUpdate()==0){System.out.println("Wrong");} } } catch(Exception ex) { System.out.println(ex.toString()); _fieldList.clear(); } System.out.println("ravi"); return _fieldList; } public String getFieldDesc(FieldInfo fi, String strToDB) { String str = ""; try { String s2 = new String(fi.Name); s2 = s2.replace(' ', '_'); str = s2 + " "; String s = fi.Type.trim().toUpperCase(); if( s.equals("GUID") ) { if( strToDB.equals("SQLServer") ) str += " UNIQUEIDENTIFIER "; else str += " UROWID "; } else if( s.equals("BIT") ) { if( strToDB.equals("SQLServer") ) str += " BIT "; else str += " CHAR(1) "; } else if( s.equals("BYTE") ) { if( strToDB.equals("SQLServer") ) str += " TINYINT "; else str += " NUMBER "; } else if( s.equals("LONGBINARY") ) { fi.Size = (fi.Size < 0 \|\| fi.Size > 1000) ? 1000 : fi.Size; if( strToDB.equals("SQLServer") ) str += " VARBINARY(" + fi.Size + ") "; else str += " BLOB(" + fi.Size + ") "; } else if( s.equals("VARBINARY") ) { fi.Size = (fi.Size < 0 \|\| fi.Size > 1000) ? 1000 : fi.Size; if( strToDB.equals("SQLServer") ) str += " VARBINARY(" + fi.Size + ") "; else str += " BLOB(" + fi.Size + ") "; } else if( s.equals("BINARY") ) { fi.Size = (fi.Size < 0 \|\| fi.Size > 1000) ? 1000 : fi.Size; if( strToDB.equals("SQLServer") ) str += " VARBINARY(" + fi.Size + ") "; else str += " BLOB(" + fi.Size + ")"; } else if( s.equals("LONGCHAR") ) { fi.Size = (fi.Size < 0 \|\| fi.Size > 1000) ? 1000 : fi.Size; if( strToDB.equals("SQLServer") ) str += " VARBINARY(" + fi.Size + ") "; else str += " LONG(" + fi.Size + ")"; } else if( s.equals("CHAR") ) { if( strToDB.equals("SQLServer") ) str += " CHAR(1) "; else str += " CHAR(1) "; } else if( s.equals("CURRENCY") ) { if( strToDB.equals("SQLServer") ) str += " CURRENCY "; else str += " NUMBER "; } else if( s.equals("INTEGER") ) { if( strToDB.equals("SQLServer") ) str += " INT "; else str += " NUMBER(10) "; } else if( s.equals("COUNTER") ) { if( strToDB.equals("SQLServer") ) str += " INT "; else str += " NUMBER(10) "; } else if( s.equals("SMALLINT") ) { if( strToDB.equals("SQLServer") ) str += " INT "; else str += " NUMBER(5) "; } else if( s.equals("REAL") ) { if( strToDB.equals("SQLServer") ) str += " REAL "; else str += " NUMBER "; } else if( s.equals("DOUBLE") ) { if( strToDB.equals("SQLServer") ) str += " DECIMAL "; else str += " NUMBER "; } else if( s.equals("DATETIME") ) { if( strToDB.equals("SQLServer") ) str += " SMALLDATETIME "; else str += " DATE "; } else if( s.equals("VARCHAR") ) { if( strToDB.equals("SQLServer") ) str += " VARCHAR(" + fi.Size + ") "; else str += " VARCHAR2(" + fi.Size + ") "; } else return ""; if( fi.Unique ) s += " " + "UNIQUE "; if( fi.AllowNull ) s += " " + "NOT NULL "; } catch(Exception ex) { } return str; } public String getSQL(String strTable, String strToDB) { //String strNewTable = strTable.replace(' ', '_'); //System.out.println(strNewTable); String strSQL = "CREATE TABLE " + strTable + " ("; for(int i = 0; i < _fieldList.size(); i++) { String s = getFieldDesc((FieldInfo)_fieldList.get(i), strToDB); if( i == 0 ) strSQL = strSQL + s; else strSQL = strSQL + ", " + s; } strSQL = strSQL + ")"; return strSQL; } public void migrateStructureAndData(String []strSrcTable, String strSrcDSN, String strSrcUser, String strSrcPwd, String strDestDSN, String strDestUser, String strDestPwd, String strToDB, boolean bStructureOnly) throws Exception { try { ResultSet rsSource = null; Statement stmtSrc = null, stmtDest = null; Connection connSrc = null, connDest = null; Class.forName("sun.jdbc.odbc.JdbcOdbcDriver"); connSrc = DriverManager.getConnection("jdbc:odbc:" + strSrcDSN, strSrcUser, strSrcPwd); String strDestTable[] = new String[strSrcTable.length]; for(int i = 0; i < strSrcTable.length; i++) { getFieldInfoList(strSrcTable[i], connSrc,strDestDSN, strDestUser, strDestPwd); strDestTable[i] = getSQL(strSrcTable[i], strToDB); System.out.println(strDestTable[i]); } connDest = DriverManager.getConnection("jdbc:odbc:" + strDestDSN, strDestUser, strDestPwd); stmtDest = connDest.createStatement(); for( int i = 0; i < strDestTable.length; i++) { try { stmtDest.execute(strDestTable[i]); /if( bStructureOnly == false ) { String strInsert = "INSERT INTO " + strSrcTable[i]+"("+s1[1]+","+s1[2]+","+s1[3]+","+s1[4]+","+s1[5]+")"+ " VALUES ("+1+","+"ravi"+","+"21"+","+"12000"+","+"1234"+")"; //rsSource = stmt.executeQuery("SELECT FROM " +strSrcTable[i]); stmtDest.execute(strInsert); }/ } catch(Exception ex) { /String s = ex.toString().toLowerCase(); if( s.indexOf("there is already an object") >= 0 ) System.out.println("'" + strSrcTable[i] + "' already exists"); else System.out.println(ex);*/ } } //connSrc.close(); //connDest.close(); } catch(Exception ex) { throw ex; } } public static void main(String []args) { DataMigration dm = new DataMigration(); String []s = { "authors1","authors2","authors3"}; try { dm.migrateStructureAndData(s, "sql", "sa", "", "con1", "", "", "", false); } catch(Exception ex) { System.out.println(ex); } } }

Related Source Codes

Script Name Author

Sending mail Using JavaMail to Yahoo and Gmail accounts sai prasad

Simple Program in Java to Implement Multithreading Satish.K

Simple Calculator in Java Using Remote Method Invocation Satish.K

Guest Book Application Using Servlets Satish.K

String Manipulation Using Stringification Satish.K

String Manipulation Using Stringification Satish.K

Moving Ball Application Using Java Beans Satish.K

Rapid Roll game subrahmanyeswararao

student mgm arpan

Sourav Datta

Download Manager Sagar

Address Book in Java Rahul Chouhan

address book using java database connectivity(jdbc-msaccess) shekhar bansal

sun Steganography B.Rajavel

Connecting Java with MS-Access - Inserting data in Aseem

A D V E R T I S E M E N T

Google Groups Subscribe to SourceCodesWorld - Techies Talk

Email:

Free eBook - Interview Questions: Get over 1,000 Interview Questions in an eBook for free when you join JobsAssist. Just click on the button below to join JobsAssist and you will immediately receive the Free eBook with thousands of Interview Questions in an ebook when you join.

Free Tutorials - HTML, Java, SQL, PHP, ASP, Perl, SQL Tutorials
Discuss Programming Problems and Freshers Jobs related issues here.
Discuss Final Year Project Ideas here.