तरल पदार्थ में जावा कोड परिवर्तन

Question

जावा कोड परिवर्तन सेट बनाने के लिए तरल पदार्थ में कोई तरीका है (यानी जावा क्लास प्रदान करें, जो एक जेडीबीसी कनेक्शन प्राप्त करेगा और डेटाबेस में कुछ बदलाव करेगा)?

(मैं जानता हूँ कि flyway ऐसी सुविधा है)

Answer 1

हाँ, वहाँ इस तरह के सुविधा है। आप बना सकते हैं एक customChange:

<customChange class="my.java.Class"> 
     <param name="id" value="2" /> 
    </customChange> 

वर्ग liquibase.change.custom.CustomTaskChange इंटरफ़ेस लागू करता है चाहिए।

@Override 
public void execute(final Database arg0) throws CustomChangeException { 
    JdbcConnection dbConn = (JdbcConnection) arg0.getConnection(); 
    try { 
     ... do funny stuff ... 
    } catch (Exception e) { 
     // swallow the exception ! 
    } 
} 

Answer 2

एक पूरा उदाहरण देखने की तरह इस

एक वर्ग है कि CustomTaskChange या CustomSqlChange लागू करता है पैदा करेगा।

package com.example; 

import liquibase.change.custom.CustomTaskChange; 
import liquibase.database.Database; 
import liquibase.database.jvm.JdbcConnection; 
import liquibase.exception.CustomChangeException; 
import liquibase.exception.SetupException; 
import liquibase.exception.ValidationErrors; 
import liquibase.logging.LogFactory; 
import liquibase.resource.ResourceAccessor; 

import java.io.BufferedReader; 
import java.io.IOException; 
import java.io.InputStreamReader; 
import java.sql.PreparedStatement; 
import java.sql.ResultSet; 

public class DataLoaderTask implements CustomTaskChange { 

    //to hold the parameter value 
    private String file; 


    private ResourceAccessor resourceAccessor; 


    public String getFile() { 
     return file; 
    } 

    public void setFile(String file) { 
     this.file = file; 
    } 


    @Override 
    public void execute(Database database) throws CustomChangeException { 
     JdbcConnection databaseConnection = (JdbcConnection) database.getConnection(); 
     try { 

      //Opening my data file 
      BufferedReader in = new BufferedReader(
        new InputStreamReader(resourceAccessor.getResourceAsStream(file))); 

      //Ignore header 
      String str = in.readLine(); 

      while ((str = in.readLine()) != null && !str.trim().equals("")) { 
       LogFactory.getLogger().info("Processing line "+ str); 
       //Do whatever is necessary 
      } 
      in.close(); 
     } catch (Exception e) { 
      throw new CustomChangeException(e); 
     } 
    } 

    @Override 
    public String getConfirmationMessage() { 
     return null; 
    } 

    @Override 
    public void setUp() throws SetupException { 

    } 

    @Override 
    public void setFileOpener(ResourceAccessor resourceAccessor) { 
     this.resourceAccessor = resourceAccessor; 
    } 

    @Override 
    public ValidationErrors validate(Database database) { 
     return null; 
    } 

} 

changeset एक्सएमएल में आप मुझे डेटा फ़ाइल के लिए

<changeSet id="1" author="murali" runAlways="false" failOnError="true" > 
     <customChange class="com.example.DataLoaderTask"> 
      <param name="file" value="/com/example/data/user.csv" /> 
     </customChange> 
</changeSet> 

नीचे के रूप में वर्ग इस्तेमाल कर सकते हैं src/मुख्य/संसाधन/com/उदाहरण/डेटा निर्देशिका में है

उम्मीद है कि यह