package java_thread;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class ThreadPoolTest {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		ExecutorService threadPool = Executors.newFixedThreadPool(3);
//		ExecutorService threadPool = Executors.newCachedThreadPool();
//		ExecutorService threadPool = Executors.newSingleThreadExecutor();
		for(int i=1;i<=10;i++){
			final int task = i;
			threadPool.execute(new Runnable(){
				@Override
				public void run() {
					for(int j=1;j<=4;j++){
						try {
							Thread.sleep(20);
						} catch (InterruptedException e) {
							// TODO Auto-generated catch block
							e.printStackTrace();
						}
						System.out.println(Thread.currentThread().getName() + " is looping of " + j + " for  task of " + task);
					}
				}
			});
		}
		System.out.println("all of 10 tasks have committed! ");
		//threadPool.shutdownNow();
		
//		Executors.newScheduledThreadPool(3).scheduleAtFixedRate(
//				new Runnable(){
//					@Override
//				public void run() {
//					System.out.println("bombing!");
//					
//				}},
//				6,
//				2,
//				TimeUnit.SECONDS);
	}

}

ExecutorService threadPool = Executors.newCachedThreadPool();

ExecutorService threadPool = Executors.newSingleThreadExecutor();

package java_thread;
//=================================================
// File Name       :	Runnable_demo2
//------------------------------------------------------------------------------
// Author          :	Common


class MyThread_2 implements Runnable{
	private int ticket = 5;	
	
	@Override
	public void run() {								//覆写Thread类中的run()方法
		// TODO 自动生成的方法存根
		for (int i=0;i<10;i++){
			synchronized (this) {					//设置需要同步的操作
				if(ticket>0){
					try{
						Thread.sleep(300);
					}catch(InterruptedException e){
						e.printStackTrace();
					}
					System.out.println("卖票：ticket="+ticket--);
				}
			}
//			this.sale();												//调用同步方法
		}
	}
	
//	public synchronized void sale(){			//声明同步方法
//		if(ticket>0){
//			try{
//				Thread.sleep(300);
//			}catch(InterruptedException e){
//				e.printStackTrace();
//			}
//			System.out.println("卖票：ticket="+ticket--);
//		}
//	}
	
}



//主类
//Function        : 	Thread_demo2
public class Runnable_demo2 {

	public static void main(String[] args) {
		// TODO 自动生成的方法存根
		MyThread_2 mt = new MyThread_2();	//实例化Runnable子类对象
		Thread t1 = new Thread(mt);							//实例化Thread类对象
		Thread t2 = new Thread(mt);							//实例化Thread类对象
		Thread t3 = new Thread(mt);							//实例化Thread类对象
		t1.start();																	//启动线程
		t2.start();																	//启动线程
		t3.start();																	//启动线程
	}

}

docker run -d -p 18123:8123 -p 19000:9000 --name some-clickhouse-server --ulimit nofile=262144:262144 clickhouse/clickhouse-server:23.8

CREATE TABLE default.my_first_table
(
    user_id UInt32,
    message String,
    timestamp DateTime,
    metric Float32
)
ENGINE = MergeTree()
PRIMARY KEY (user_id, timestamp);

INSERT INTO default.my_first_table (user_id, message, timestamp, metric) VALUES
    (101, 'Hello, ClickHouse!',                                 now(),       -1.0    ),
    (102, 'Insert a lot of rows per batch',                     yesterday(), 1.41421 ),
    (102, 'Sort your data based on your commonly-used queries', today(),     2.718   ),
    (101, 'Granules are the smallest chunks of data read',      now() + 5,   3.14159 )

go get github.com/ClickHouse/clickhouse-go

import "database/sql"
import _ "github.com/ClickHouse/clickhouse-go"

sql: unknown driver "clickhouse" (forgotten import?)

source := "tcp://localhost:19000?username=default&password=&database=default&block_size=4096"
db, err := sql.Open("clickhouse", source)
if err != nil {
	fmt.Println(err)
}
defer func() {
	_ = db.Close()
}()

query := `
	CREATE TABLE default.my_first_table
	(
		user_id UInt32,
		message String,
		timestamp DateTime,
		metric Float32
	)
	ENGINE = MergeTree()
	PRIMARY KEY (user_id, timestamp)
 `
_, err = db.Exec(query)
if err != nil {
	fmt.Println(err)
}

var arr [][]any
arr = append(arr, []any{101, "Hello, ClickHouse!", time.Now(), -1.0})
arr = append(arr, []any{102, "Insert a lot of rows per batch", time.Now().Add(-1), 1.41421})
arr = append(arr, []any{102, "Sort your data based on your commonly-used queries", time.Now().Add(1), 2.718})
arr = append(arr, []any{101, "Granules are the smallest chunks of data read", time.Now().Add(5), 3.14159})
tx, err := db.Begin()
if err != nil {
	log.Fatal(err)
}
query := `INSERT INTO default.my_first_table (user_id, message, timestamp, metric) VALUES (?, ?, ?, ?)`
stmt, err := tx.Prepare(query)
if err != nil {
	log.Fatal(err)
}
for _, data := range arr {
	_, err = stmt.Exec(data...)
	if err != nil {
		fmt.Println(err)
	}
}
_ = tx.Commit()

// 读取数据
type Data struct {
	UserId    int64     `db:"user_id"`
	Message   string    `db:"message"`
	Timestamp time.Time `db:"timestamp"`
	Metric    float64   `db:"metric"`
}

query := "SELECT * FROM default.my_first_table"
rows, err := db.Query(query)
if err != nil {
	fmt.Println(err)
}
var result []Data
for rows.Next() {
	var data Data
	err = rows.Scan(&data.UserId, &data.Message, &data.Timestamp, &data.Metric)
	if err != nil {
		fmt.Println(err)
	}
	result = append(result, data)
}
fmt.Println(result)

[{101 Hello, ClickHouse! 2024-05-25 15:54:00 +0000 UTC -1} {101 Granules are the smallest chunks of data read 2024-05-25 15:54:00 +0000 UTC 3.14159} {102 Insert a lot of rows per batch 2024-05-25 15:54:00 +0000 UTC 1.41421} {102 Sort your data based on your commonly-used queries 2024-05-25 15:54:00 +0000 UTC 2.718}]

Caused by: com.amazonaws.services.s3.model.AmazonS3Exception: Please reduce your request rate.

enctype="multipart/form-data"
和
<tr>
　　|附件:|<input type="file" name="attach"/>
</tr>

<!-- 将静态文件指定到某个特殊的文件夹中统一处理 -->
<mvc:resources location="/resources/" mapping="/resources/**"></mvc:resources>

<%@ page language="java" contentType="text/html; charset=UTF-8"
    pageEncoding="UTF-8"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>用户登录</title>
</head>
<body>
<form action="user/login" method="post">
	用户名:<input type="text" name="username"/><br/>
	用户密码:<input type="password" name="password"/><br/>
	<input type="submit" value="用户登录"/>
</form>
</body>
</html>

set;

set hive.execution.engine;