package com.test.thread;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.test.entity.Biao;
import com.test.jdbc.BaseDao;

public class TestThread implements Runnable {
	List<Biao> lists = new ArrayList<Biao>(0);
	private String name;
	BaseDao jdbc = new BaseDao("oracle.jdbc.driver.OracleDriver","jdbc:oracle:thin:@127.0.0.1:1521:orcl","jll","jll");
	BaseDao jdbc2 = new BaseDao("oracle.jdbc.driver.OracleDriver","jdbc:oracle:thin:@127.0.0.1:1521:orcl","ll","ll");
	public TestThread(String name){
		//this.start();jdbc:oracle:thin:@127.0.0.1:1521:orcl
		//this.setName(name);
		this.name=name;
		System.out.println(this.name+" is running.....");
		String sql = "select id,name,state,count from aa order by id";
		lists = jdbc.queryAll(Biao.class, sql, new Object[]{});
		System.out.println("select is success....");
	}
	
	public synchronized void run() {
			addSql();
	
		/*try {
			sleep(5000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}*/
	}
	public void addSql(){
			String sql="insert into bb values(?,?,?,?)";
			if(lists!=null&&lists.size()>0){
					for(Biao b:lists){
							int count;
							try {
								count = jdbc2.insertSql(sql, new Object[]{b.getId(),b.getName(),b.getState(),b.getCount()});
								if(count>0){
									System.out.println("insert success");
								}
							} catch (SQLException e) {
								 sql= "select id,name,state,count from bb where id=?";
									ResultSet rs = jdbc2.getResult(sql, new Object[]{b.getId()});
									if(rs!=null){
										sql="update bb set state=?,count=count+1 where id=?";
										int count2;
										try {
											count2 = jdbc2.insertSql(sql, new Object[]{8,b.getId()});
											if(count2>0){
												System.out.println("mod success");
											}
										} catch (SQLException e1) {
											// TODO Auto-generated catch block
											e1.printStackTrace();
										}
									}
							}	
					}	
			}	
	}
}