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);
        }

    }