jOOQ - 1.0

package com.Jooqexample.jooq;

import static com.JooQDemo.jooq.sample.model.Tables.*;
import com.JooQDemo.jooq.sample.model.tables.records.BikeRecord;
import com.JooQDemo.jooq.sample.model.tables.records.CarsRecord;
import org.jooq.*;
import org.jooq.Record;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import java.sql.ResultSet;
import java.util.stream.Stream;

@SpringBootTest

class SpringBootJooqApplicationTests {

    @Autowired
    private DSLContext dsl;

    @Test
    void DisplayData() {
        CarsRecord Cars = dsl.selectFrom(CARS).fetchAny();
        System.out.println("Result are -- " + Cars);

        Result<Record> result0 = dsl.select().from(AIR_WAYS).fetch();
        System.out.println("Result are1 -- " + result0);

        Result<Record> result0 = dsl.select().from(CARS).stream();

        Result<Record> result1  = dsl.select().from(CARS).fetch();
        System.out.println("Result are1 -- " + result1);

        Result<BikeRecord> result = dsl.selectFrom(BIKE).fetch();
        System.out.println("Result are -- " + result);

        ResultSet rs1 = dsl.selectFrom(CARS).fetchResultSet();
        System.out.println("Result are -- " + rs1);

        Cursor<Record1<String>> rs2 = dsl.select(CARS.MODEL_NAME).from(CARS).fetchLazy();
        for (Record1<String> record : rs2){
            System.out.println("Result are fetchlazy -- " + record);
        }
        Stream<Record1<String>> rs3 = dsl.select(CARS.MODEL_NAME).from(CARS).fetchStream();

        rs3.forEach(record -> {
            System.out.println("Result are fetchStream -- " + record);
            // ...
        });

        CarsRecord Cars1 = dsl.selectFrom(CARS).where(CARS.MODEL_NAME.eq("Ertiga")).fetchOne();
        System.out.println("Result are -- " + Cars1);



    }
}


    

    void AddData() {
        int insertedrow = dsl.insertInto(CARS).values(2,"TATA","NEXON",2012,100000000).execute();
        System.out.println("Insert Operation Row Affected are -- " + insertedrow);

        int insertedrow_bike = dsl.insertInto(BIKE).values(1,"Bajaj","Avenger",2012,150000).execute();
        System.out.println("Insert Operation Row Affected are -- " + insertedrow_bike);

        int insertedrow_bike2 = dsl.insertInto(BIKE).values(2,"Duke","KTM",2016,150000).execute();
        System.out.println("Insert Operation Row Affected are -- " + insertedrow_bike2);



    }

  void DeleteData(){

        int deleterow = dsl.deleteFrom(CARS).where(CARS.ID.eq(2)).execute();
        System.out.println("Delete Operation Row Affected are -- " + deleterow);

        int deleterow_bike = dsl.deleteFrom(BIKE).where(BIKE.ID.eq(1)).execute();
        System.out.println("Delete Operation Row Affected are -- " + deleterow_bike);

    }

private void applyRuleFilter(HighlightDSLContext defaultDSLContext, Long aggregatedResultId, Long applicationId) {

        defaultDSLContext.update(AGGREGATED_CLOUD_TECHNOLOGY)
                .set(AGGREGATED_CLOUD_TECHNOLOGY.EXCLUSION, DSL.val(null,String.class))
                .set(AGGREGATED_CLOUD_TECHNOLOGY.MALUSRATIO, AGGREGATED_CLOUD_TECHNOLOGY.EXCLUDED_MALUSRATIO)
                .set(AGGREGATED_CLOUD_TECHNOLOGY.SCANINDICATOR, AGGREGATED_CLOUD_TECHNOLOGY.EXCLUDED_MALUSRATIO)
                .set(AGGREGATED_CLOUD_TECHNOLOGY.COUNTEDELEMENTS, AGGREGATED_CLOUD_TECHNOLOGY.EXCLUDED_COUNTEDELEMENTS)
                .where(AGGREGATED_CLOUD_TECHNOLOGY.AGGREGATED_RESULT_ID.eq(aggregatedResultId))
                .and(AGGREGATED_CLOUD_TECHNOLOGY.EXCLUSION.isNotNull())
                .execute();
}

void execute_batchUpdate() {

    Result<BikeRecord> existingProjects = DSLContext.selectFrom(BIKE).where(BIKE.ID.eq(1)); 

    DSLContext.batchUpdate(existingProjects.stream().collect(Collectors.toList())).execute();

}

 // Import the necessary jOOQ classes
import org.jooq.impl.DSL;
import org.jooq.*;
import org.jooq.Record;
import static org.jooq.impl.DSL.*;
   
public class JooqSample {

    public static void main(String[] args) {

        String url = "jdbc:mysql://localhost:3306/vehicle";
        String uname = "root";
        String password = "mysql";
        String query = "select * from cars";

        /////////// Creating the connection with database //////////
        try {

            DSLContext context = DSL.using(url, uname, password);

            fetchRecord(context, query);
           

        } catch (Exception e) {
            System.out.println("\n Exception" + e);
        }

    }        


    public static void fetchRecord(DSLContext context, String query) {
        try {

            
            Result<Record> result = context.fetch(query);
            System.out.println("Result are -- " + result);

        } catch (Exception e) {
            System.out.println("\n Exception " + e);
        }

    }

}

        public static void executeRecord(DSLContext context) {
        try {

            
            int rowCount = context.execute("insert into cars values(100,'Hyundai','verna',2016,1500000,3)");
            

            System.out.println("Number of row affected are -- " + rowCount);

        } catch (Exception e) {
            System.out.println("\n Exception " + e);
        }

    }

    public static void queryRecord(DSLContext context) {
        try {

            
            Query query = context.query("insert into cars values(100,'Hyundai','verna',2016,1500000)");
            

            System.out.println("Number of row affected are -- " + query);

        } catch (Exception e) {
            System.out.println("\n Exception " + e);
        }

    }

   public static void deleteRecord(DSLContext context) {
	
        try {

            // Build the query
            String new_query = getQuery();
            int rowCount = context.execute(new_query);
            // Loop through the results

            System.out.println("Number of row affected are -- " + rowCount);

        } catch (Exception e) {
            System.out.println("\n Exception " + e);
        }

    }

    void DisplayData() {
		String table = get_table();
		CarsRecord Cars = dsl.selectFrom(table).fetchAny();
		System.out.println("Result are -- " + Cars);

		Result<Record> result0 = dsl.select().from(AIR_WAYS).fetch();
		System.out.println("Result are1 -- " + result0);

		Result<Record> result0 = dsl.select().from(CARS).stream();

		Result<Record> result1  = dsl.select().from(CARS).fetch();
		System.out.println("Result are1 -- " + result1);

		Result<BikeRecord> result = dsl.selectFrom(BIKE).fetch();
		System.out.println("Result are -- " + result);

		ResultSet rs1 = dsl.selectFrom(CARS).fetchResultSet();
		System.out.println("Result are -- " + rs1);

		Cursor<Record1<String>> rs2 = dsl.select(CARS.MODEL_NAME).from(CARS).fetchLazy();
		for (Record1<String> record : rs2){
			System.out.println("Result are fetchlazy -- " + record);
		}
		Stream<Record1<String>> rs3 = dsl.select(CARS.MODEL_NAME).from(CARS).fetchStream();

		rs3.forEach(record -> {
			System.out.println("Result are fetchStream -- " + record);
			// ...
		});

		CarsRecord Cars1 = dsl.selectFrom(CARS).where(CARS.MODEL_NAME.eq("Ertiga")).fetchOne();
		System.out.println("Result are -- " + Cars1);


	}