Home > database >  How KETTLE batch create storage table structure
How KETTLE batch create storage table structure

Time:10-04

Saw a online before about using a process to complete for the entire database migration of the Kettle post http://ainidehsj.iteye.com/blog/1735434
But according to the steps in creating table structure as a problem,

Kettel log an error is as follows:


This is put in storage table structure of Java code:
Public Boolean the processRow (StepMetaInterface smi, StepDataInterface sdi) throws KettleException
{
//First, get a row from the default input hop
//
Object [] r=getRow ();

Org. Pentaho. Di. Core. Database. DatabaseMeta dbmeta=null;

Java. Util. List List=getTrans (). The getRepository () readDatabases ();//3. X repository for all the database connection information with getDatabases ();

If (a list!=null & amp; & ! List. IsEmpty ())
{
for(int i=0; i{
Dbmeta=(. Org. Pentaho. Di core. Database. DatabaseMeta) list. Get (I);
System. The out. Println (" + + + + + + + + + + + + + + + ");
System. The out. Println (dbmeta);
//below is the database connection object library, you can according to need to modify the
If (" ORAC10G - TEST ". EqualsIgnoreCase (dbmeta. The getName ()))
{
break;
}
}
}

If (dbmeta!=null)
{
Org. Pentaho. Di. Core. The database. The database db=new org. Pentaho. Di. Core. The database. The database (dbmeta);

Try
{
The connect ();

String tablename=getVariable (" tablename ");

LogBasic (" began to create a table: "+ tablename);

If (tablename!=null & amp; & Tablename. The trim (). The length () & gt; 0)
{
String SQL=db. GetDDL (tablename, data. InputRowMeta);//${TABLENAME}

Db. ExecStatement (SQL. Replace (";" , ""));

LogBasic (SQL);
}
}
The catch (Exception e)
{
LogError (" abnormal "create tables, e);

} the finally {
The disconnect ();
}
}
return false;
}


The process of the job and trans in the link above,

Pray god help see where the problem is???????

CodePudding user response:

How to solve of, tell me

CodePudding user response:

Why use kettle? Now a lot of technology can replace, data migration, can export, import, real-time, oracle can senior copy, mysql binlog

CodePudding user response:

The solution is, please?

CodePudding user response:

The building Lord genuflect is begged share solutions

CodePudding user response:

The solution to! Too not authentic,,,

CodePudding user response:

Ah, that is the problem recently, sad dead

CodePudding user response:

The source table data is empty when out this problem

CodePudding user response:

I am also create table structure error could you tell me how to solve the great god

CodePudding user response:

The problem you solved? Should be do not achieve the metadata table
 Object [] r=getRow (); 
//org. Pentaho. Di. Core. Database. DatabaseMeta dbmeta=null;
Org. Pentaho. Di. Core. Database. DatabaseMeta dbmeta=getTransMeta () findDatabase (" mysql_test ");
Java. Util. List List=getTrans (). The getRepository () readDatabases ();

If (a list!=null & amp; & ! List. IsEmpty ())
{
for(int i=0; i{
Dbmeta=(. Org. Pentaho. Di core. Database. DatabaseMeta) list. Get (I);
If (" mysql - jeesite ". EqualsIgnoreCase (dbmeta. The getName ()))
{
break;
}
}
}

CodePudding user response:

Set up a repository can implement a success, I don't know why the local run is thrown exception
  • Related