kotlin复制代码
val request:Request=Request.Builder()
	.post(RequestBody.create(MediaType.parse("application/json;charset=utf8"),
        "body参数")).build()

kotlin复制代码import okhttp3.MediaType.Companion.toMediaType
import okhttp3.RequestBody.Companion.toRequestBody
import okhttp3.RequestBody.Companion.asRequestBody

//String转RequestBody String、ByteArray、ByteString都可以用toRequestBody()
val stringBody ="body参数".toRequestBody("application/json;charset=utf-8".toMediaType())
val request = Request
              .Builder()
              .post(stringBody)
              .build()
                
//File转RequestBody
val file=File("")
val fileBody=file.asRequestBody("text/x-markdown; charset=utf-8".toMediaType())
val request = MultipartBody.Builder()
                    .addFormDataPart("file", file.name,fileBody)
                    .build()

java复制代码
import okhttp3.MediaType.Companion.*;
import okhttp3.RequestBody.Companion.*;

//String转RequestBody String、ByteArray、ByteString都可以用toRequestBody()
 MediaType mediaType=MediaType.Companion.parse("application/json;charset=utf-8");
 RequestBody stringBody=RequestBody.Companion.create("body参数",mediaType);
 Request request=new Request
                .Builder()
                .post(stringBody)
                .build();
                
//File转RequestBody
MediaType mediaType=MediaType.Companion.parse("text/x-markdown; charset=utf-8");
File file=new File("");
RequestBody fileBody=RequestBody.Companion.create(file,mediaType);
Request request=new MultipartBody.Builder()
                .addFormDataPart("file", file.getName(),fileBody)
                .build();

sql复制代码DROP TABLE IF EXISTS test_data;
CREATE TABLE test_data (
    trans_id INT,
    product TEXT
);
INSERT INTO test_data VALUES (1, 'beer');
INSERT INTO test_data VALUES (1, 'diapers');
INSERT INTO test_data VALUES (1, 'chips');
INSERT INTO test_data VALUES (2, 'beer');
INSERT INTO test_data VALUES (2, 'diapers');
INSERT INTO test_data VALUES (3, 'beer');
INSERT INTO test_data VALUES (3, 'diapers');
INSERT INTO test_data VALUES (4, 'beer');
INSERT INTO test_data VALUES (4, 'chips');
INSERT INTO test_data VALUES (5, 'beer');
INSERT INTO test_data VALUES (6, 'beer');
INSERT INTO test_data VALUES (6, 'diapers');
INSERT INTO test_data VALUES (6, 'chips');
INSERT INTO test_data VALUES (7, 'beer');
INSERT INTO test_data VALUES (7, 'diapers');

bash复制代码docker pull madlib/postgres_9.6:latest

bash复制代码cd /home/git-repo/github && git clone git@github.com:apache/madlib.git

bash复制代码docker run -d -it --name madlib -v /home/git-repo/github/madlib:/incubator-madlib/ madlib/postgres_9.6

bash复制代码docker exec -it madlib bash
mkdir /incubator-madlib/build-docker
cd /incubator-madlib/build-docker
cmake ..
make
make doc
make install

bash复制代码src/bin/madpack -p postgres -c postgres/postgres@localhost:5432/postgres install

bash复制代码# Run install check, on all modules:
src/bin/madpack -p postgres -c postgres/postgres@localhost:5432/postgres install-check

# Run install check, on a specific module, say svm:
src/bin/madpack -p postgres -c postgres/postgres@localhost:5432/postgres install-check -t svm

# Run dev check, on all modules (more comprehensive than install check):
src/bin/madpack -p postgres -c postgres/postgres@localhost:5432/postgres dev-check

# Run dev check, on a specific module, say svm:
src/bin/madpack -p postgres -c postgres/postgres@localhost:5432/postgres dev-check -t svm

# 如果需要,重新安装 Reinstall MADlib:
src/bin/madpack -p postgres -c postgres/postgres@localhost:5432/postgres reinstall

bash复制代码docker kill madlib
docker rm madlib

bash复制代码docker ps -a
docker commit <container id> my/madlib_pg9.6_dev

bash复制代码docker run -d -it -p 5432:5432 --name madlib_dev -v /home/my/git-repo/github/madlib:/incubator-madlib/ madlib/postgres_9.6

bash复制代码docker exec -it madlib_dev bash
cd  /incubator-madlib/build-docker
src/bin/madpack -p postgres -c postgres/postgres@localhost:5432/postgres install
src/bin/madpack -p postgres -c postgres/postgres@localhost:5432/postgres install-check

sql复制代码SELECT * FROM madlib.assoc_rules( .25,            -- 支持度
                                  .5,             -- 置信度
                                  'trans_id',     -- Transaction id 字段
                                  'product',      -- Product 字段
                                  'test_data',    -- 输入数据
                                  NULL,           -- 输出模式
                                  TRUE            -- 详细输出
                                );

sql复制代码SELECT * FROM assoc_rules
ORDER BY support DESC, confidence DESC;

复制代码docker pull mysql:5.7

bash复制代码docker images
REPOSITORY                        TAG                 IMAGE ID            CREATED             SIZE
docker.io/mysql                   5.7                 db39680b63ac        2 days ago          437 MB

bash复制代码docker run -p 3306:3306 --name mymysql -v $PWD/conf:/etc/mysql/conf.d -v $PWD/logs:/logs -v $PWD/data:/var/lib/mysql -e MYSQL_ROOT_PASSWORD=123456 -d mysql:5.7

bash复制代码[root@VM_0_10_centos ~]# docker ps
CONTAINER ID        IMAGE               COMMAND                  CREATED             STATUS              PORTS                               NAMES
d1e682cfdf76        mysql:5.7           "docker-entrypoint..."   14 seconds ago      Up 13 seconds       0.0.0.0:3306->3306/tcp, 33060/tcp   mymysql

bash复制代码sudo docker exec -it mymysql bash
mysql -u root -p

sql复制代码CREATE USER 'zuozewei'@'%' IDENTIFIED WITH mysql_native_password BY 'zuozewei';
GRANT ALL PRIVILEGES ON *.* TO 'zuozewei'@'%';

bash复制代码#pip3 install 包名 -i 源的url 临时换源
#清华大学源：https://pypi.tuna.tsinghua.edu.cn/simple/

# 强大的数据结构库，用于数据分析，时间序列和统计等
pip3 install pandas -i https://pypi.tuna.tsinghua.edu.cn/simple/ 

# python的orm程序
pip3 install SQLAlchemy -i https://pypi.tuna.tsinghua.edu.cn/simple/ 

# Apriori算法的高效纯Python实现
pip3 install efficient-apriori -i https://pypi.tuna.tsinghua.edu.cn/simple/ 

# MySQL驱动
pip3 install mysql-connector -i https://pypi.tuna.tsinghua.edu.cn/simple/

python复制代码from efficient_apriori import apriori
import sqlalchemy as sql
import pandas as pd

'''
数据加载
'''

# 创建数据库连接
engine = sql.create_engine('mysql+mysqlconnector://zuozewei:zuozewei@server_ip/SQLApriori')
# 查询数据
query = 'SELECT * FROM test_data'
# 加载到 data 中
data = pd.read_sql_query(query, engine)

'''
数据预处理
'''

# 得到一维数组 orders_series，并且将 Transaction 作为 index, value 为 Item 取值
orders_series = data.set_index('trans_id')['product']
# 将数据集进行格式转换
transactions = []
temp_index = 0
for i, v in orders_series.items():
	if i != temp_index:
		temp_set = set()
		temp_index = i
		temp_set.add(v)
		transactions.append(temp_set)
	else:
		temp_set.add(v)

'''
数据分析
'''

# 挖掘频繁项集和频繁规则
itemsets, rules = apriori(transactions, min_support=0.25,  min_confidence=0.5)

print('频繁项集：', itemsets)
print('关联规则：', rules)

rust复制代码频繁项集： {
1: {('beer',): 7, ('chips',): 3, ('diapers',): 5}, 
2: {('beer', 'chips'): 3, ('beer', 'diapers'): 5, ('chips', 'diapers'): 2}, 
3: {('beer', 'chips', 'diapers'): 2}
}

关联规则： [
{chips} -> {beer}, 
{diapers} -> {beer}, 
{beer} -> {diapers}, 
{chips} -> {diapers}, 
{chips, diapers} -> {beer}, 
{beer, chips} -> {diapers}, 
{chips} -> {beer, diapers}
]

python复制代码import functools
class Solution:
    def solve(self , nums ):
        # write code here
        strs = map(str, nums)
         #根据拼接后的结果判断谁应该放在前面
        def cmp(a, b):
            if a + b == b + a:
                return 0
            elif a + b > b + a:
                return 1
            else:
                return -1

        strs = sorted(strs, key=functools.cmp_to_key(cmp), reverse=True)
        return ''.join(strs) if strs[0]!='0' else '0'

csharp复制代码    public static void main(String[] args) throws ExecutionException, InterruptedException {
        DefaultEventLoop eventExecutors = new DefaultEventLoop();
        DefaultPromise<Integer> promise = new DefaultPromise<>(eventExecutors);

        eventExecutors.execute(()->{
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() +", set success: " + 10);
            promise.setSuccess(10);
        });

        System.out.println(Thread.currentThread().getName() +", start...");
        //未产生结果，不阻塞，返回null
        System.out.println(Thread.currentThread().getName() +", " + promise.getNow());
        //阻塞等待结果
        System.out.println(Thread.currentThread().getName() +", " + promise.get());
    }

less复制代码main, start...
main, null
defaultEventLoop-1-1, set success: 10
main, 10

arduino复制代码    public static void main(String[] args) throws ExecutionException, InterruptedException {
        DefaultEventLoop eventExecutors = new DefaultEventLoop();
        DefaultPromise<Integer> promise = new DefaultPromise<>(eventExecutors);

        eventExecutors.execute(()->{
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() +", set success: " + 10);
            promise.setSuccess(10);
        });

        System.out.println(Thread.currentThread().getName() +", start...");

        //添加异步监听，当有结果时调用getNow获取结果
        promise.addListener(future->{
            System.out.println(Thread.currentThread().getName() +", " + future.getNow());
        });
    }

arduino复制代码main, start...
defaultEventLoop-1-1, set success: 10
defaultEventLoop-1-1, 10

scss复制代码    public static void main(String[] args) throws ExecutionException, InterruptedException {
        DefaultEventLoop eventExecutors = new DefaultEventLoop();
        DefaultPromise<Integer> promise = new DefaultPromise<>(eventExecutors);

        eventExecutors.execute(()->{
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() +", set failure");
            promise.setFailure(new RuntimeException());
        });

        System.out.println(Thread.currentThread().getName() +", start...");
        //未产生结果，不阻塞，返回null
        System.out.println(Thread.currentThread().getName() +", " + promise.getNow());
        //阻塞等待结果
        System.out.println(Thread.currentThread().getName() +", " + promise.get());
        //System.out.println(Thread.currentThread().getName() +", " + promise.get());
    }

less复制代码main, start...
main, null
defaultEventLoop-1-1, set failure
Exception in thread "main" java.util.concurrent.ExecutionException: java.lang.RuntimeException
	at io.netty.util.concurrent.DefaultPromise.get(DefaultPromise.java:349)
	at com.cloud.bssp.netty.promise.Test3.main(Test3.java:34)
Caused by: java.lang.RuntimeException
	at com.cloud.bssp.netty.promise.Test3.lambda$main$0(Test3.java:27)
	at io.netty.channel.DefaultEventLoop.run(DefaultEventLoop.java:54)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.lang.Thread.run(Thread.java:748)

scss复制代码    public static void main(String[] args) throws ExecutionException, InterruptedException {
        DefaultEventLoop eventExecutors = new DefaultEventLoop();
        DefaultPromise<Integer> promise = new DefaultPromise<>(eventExecutors);

        eventExecutors.execute(()->{
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() +", set failure");
            promise.setFailure(new RuntimeException());
        });

        System.out.println(Thread.currentThread().getName() +", start...");
        //未产生结果，不阻塞，返回null
        System.out.println(Thread.currentThread().getName() +", " + promise.getNow());
        //阻塞等待结果
        promise.await();
        //isSuccess判断任务是否成功
        System.out.println(Thread.currentThread().getName() +", " + promise.isSuccess());
    }

csharp复制代码main, start...
main, null
defaultEventLoop-1-1, set failure
main, false

scss复制代码    public static void main(String[] args) {
        DefaultEventLoop eventExecutors = new DefaultEventLoop();
        DefaultPromise<Integer> promise = new DefaultPromise<>(eventExecutors);

        eventExecutors.execute(() -> {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() + ", set failure");
            promise.setFailure(new RuntimeException());
        });

        System.out.println(Thread.currentThread().getName() + ", start...");

        //添加异步监听，当有结果时调用getNow获取结果
        promise.addListener(future -> {
            if (!promise.isSuccess()) {
                //失败查看结果
                System.out.println(Thread.currentThread().getName() + ", " + promise.cause());
            }
            System.out.println(Thread.currentThread().getName() + ", " + future.getNow());
        });
    }

csharp复制代码main, start...
defaultEventLoop-1-1, set failure
defaultEventLoop-1-1, java.lang.RuntimeException
defaultEventLoop-1-1, null

csharp复制代码    public static void main(String[] args) {
        DefaultEventLoop eventExecutors = new DefaultEventLoop();
        DefaultPromise<Integer> promise = new DefaultPromise<>(eventExecutors);

        eventExecutors.submit(()->{
            System.out.println("1");
            try {
                promise.await();
                // 注意不能仅捕获 InterruptedException 异常
                // 否则 死锁检查抛出的 BlockingOperationException 会继续向上传播
                // 而提交的任务会被包装为 PromiseTask，它的 run 方法中会 catch 所有异常然后设置为 Promise 的失败结果而不会抛出
            } catch (Exception e) {
                e.printStackTrace();
            }
            System.out.println("2");
        });
        eventExecutors.submit(()->{
            System.out.println("3");
            try {
                promise.await();
            } catch (Exception e) {
                e.printStackTrace();
            }
            System.out.println("4");
        });
    }

less复制代码1
2
3
4
io.netty.util.concurrent.BlockingOperationException: DefaultPromise@6a77ffc2(incomplete)
	at io.netty.util.concurrent.DefaultPromise.checkDeadLock(DefaultPromise.java:461)
	at io.netty.util.concurrent.DefaultPromise.await(DefaultPromise.java:246)
	at com.cloud.bssp.netty.promise.Test6.lambda$main$0(Test6.java:21)
	at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98)
	at io.netty.util.concurrent.PromiseTask.run(PromiseTask.java:106)
	at io.netty.channel.DefaultEventLoop.run(DefaultEventLoop.java:54)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.lang.Thread.run(Thread.java:748)
io.netty.util.concurrent.BlockingOperationException: DefaultPromise@6a77ffc2(incomplete)
	at io.netty.util.concurrent.DefaultPromise.checkDeadLock(DefaultPromise.java:461)
	at io.netty.util.concurrent.DefaultPromise.await(DefaultPromise.java:246)
	at com.cloud.bssp.netty.promise.Test6.lambda$main$1(Test6.java:33)
	at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98)
	at io.netty.util.concurrent.PromiseTask.run(PromiseTask.java:106)
	at io.netty.channel.DefaultEventLoop.run(DefaultEventLoop.java:54)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.lang.Thread.run(Thread.java:748)

java复制代码public interface Future<V> {



    boolean cancel(boolean mayInterruptIfRunning);



    boolean isCancelled();



    boolean isDone();



    V get() throws InterruptedException, ExecutionException;



    V get(long timeout, TimeUnit unit)

        throws InterruptedException, ExecutionException, TimeoutExceptio

}

java复制代码/**

 * 描述：     演示一个 Future 的使用方法

 */

public class OneFuture {



    public static void main(String[] args) {

        ExecutorService service = Executors.newFixedThreadPool(10);

        Future<Integer> future = service.submit(new CallableTask());

        try {

            System.out.println(future.get());

        } catch (InterruptedException e) {

            e.printStackTrace();

        } catch (ExecutionException e) {

            e.printStackTrace();

        }

        service.shutdown();

    }



    static class CallableTask implements Callable<Integer> {



        @Override

        public Integer call() throws Exception {

            Thread.sleep(3000);

            return new Random().nextInt();

        }

    }

}

java复制代码public class GetException {



    public static void main(String[] args) {

        ExecutorService service = Executors.newFixedThreadPool(20);

        Future<Integer> future = service.submit(new CallableTask());





        try {

            for (int i = 0; i < 5; i++) {

                System.out.println(i);

                Thread.sleep(500);

            }

            System.out.println(future.isDone());

            future.get();

        } catch (InterruptedException e) {

            e.printStackTrace();

        } catch (ExecutionException e) {

            e.printStackTrace();

        }

    }





    static class CallableTask implements Callable<Integer> {



        @Override

        public Integer call() throws Exception {

            throw new IllegalArgumentException("Callable抛出异常");

        }

    }

}

java复制代码public class FutureTask<V> implements RunnableFuture<V>{

 ...

}

java复制代码public interface RunnableFuture<V> extends Runnable, Future<V> {

    void run();

}

java复制代码/**

 * 描述：     演示 FutureTask 的用法

 */

public class FutureTaskDemo {



    public static void main(String[] args) {

        Task task = new Task();

        FutureTask<Integer> integerFutureTask = new FutureTask<>(task);

        new Thread(integerFutureTask).start();



        try {

            System.out.println("task运行结果："+integerFutureTask.get());

        } catch (InterruptedException e) {

            e.printStackTrace();

        } catch (ExecutionException e) {

            e.printStackTrace();

        }

    }

}



class Task implements Callable<Integer> {



    @Override

    public Integer call() throws Exception {

        System.out.println("子线程正在计算");

        int sum = 0;

        for (int i = 0; i < 100; i++) {

            sum += i;

        }

        return sum;

    }

}

js复制代码修改com.ctrip.framework.apollo.configservice.ConfigServiceApplication，把@EnableEurekaServer改为@EnableEurekaClient

ini复制代码#!/bin/sh

# apollo config db info
apollo_config_db_url=jdbc:oracle:thin:@192.168.2.12:1521/orcl
apollo_config_db_username=APOLLOCONFIG
apollo_config_db_password=123

# apollo portal db info
apollo_portal_db_url=jdbc:oracle:thin:@192.168.2.12:1521/orcl
apollo_portal_db_username=APOLLOPORTAL
apollo_portal_db_password=123


# meta server url, different environments should have different meta server addresses
# dev_meta=http://fill-in-dev-meta-server:8080
# fat_meta=http://fill-in-fat-meta-server:8080
# uat_meta=http://fill-in-uat-meta-server:8080
pro_meta=http://127.0.0.1:8080

js复制代码./startup.sh

txt复制代码https://www.19lou.com/r/1/19lnsxq.html
https://www.19lou.com/r/1/19lnsxq_2.html
https://www.19lou.com/r/1/19lnsxq-233.html

python复制代码from lxml import etree
html = "一点HTML代码"
#生成一个 XPath 对象
html=etree.HTML(text)
# 提取数据
html.xpath('//li/a')

python复制代码raise FakeUserAgentError('Maximum amount of retries reached')

shell复制代码pip install -U fake-useragent

python复制代码import requests
from lxml import etree
from fake_useragent import UserAgent
import time


def save(src, title):
    try:
        res = requests.get(src)
        with open(f"imgs/{title}.jpg", "wb+") as f:
            f.write(res.content)
    except Exception as e:
        print(e)


def run(url):
    # ua = UserAgent(cache=False)
    ua = "Mozilla/5.0 (Windows NT 6.1; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/90.0.4430.85 Safari/537.36"
    headers = {
        "User-Agent": ua,
        "Host": "www.19lou.com",
        "Referer": "https://www.19lou.com/r/1/19lnsxq-233.html",
        "Cookie": "_Z3nY0d4C_=37XgPK9h"  # 从反爬代码中获取到的值
    }
    try:
        res = requests.get(url=url, headers=headers)
        text = res.text
        # 将 html 转换成 Element 对象
        html = etree.HTML(text)
        # xpath 路径提取 @class 为选取 class 属性
        divs = html.xpath("//div[@class='pics']")
        # print(len(divs))
        # 遍历 Elements 节点
        for div in divs:
            # 提取地址，注意提取的属性为 data-src 而不是 src
            src = div.xpath("./img/@data-src")[0]
            # 提取标题
            title = div.xpath("./img/@alt")[0]
            save(src, title)
    except Exception as e:
        print(e)


if __name__ == '__main__':
    urls = ["https://www.19lou.com/r/1/19lnsxq.html"]
    for i in range(114, 243):
        urls.append(f"https://www.19lou.com/r/1/19lnsxq-{i}.html")
    for url in urls:
        print(f"正在抓取{url}")
        run(url)
        # time.sleep(5)

    print("全部爬取完毕")

bash复制代码DUPLICATE TARGET DATABASE TO dup_db
FROM ACTIVE DATABASE
PASSWORD FILE
USING COMPRESSED BACKUPSET;

bash复制代码DUPLICATE TARGET DATABASE TO dup_db
FROM ACTIVE DATABASE
PASSWORD FILE
SECTION SIZE 400M;

bash复制代码##在DUPLICATE命令之前使用SET ENCRYPTION ALGORITHM命令来指定加密算法。
SET ENCRYPTION ON IDENTIFIED BY password;

bash复制代码##按优先级排序
1.SET NEWNAME FOR DATAFILE and SET NEWNAME FOR TEMPFILE
2.SET NEWNAME FOR TABLESPACE
3.SET NEWNAME FOR DATABASE

##Example
##1.该脚本为数据文件1至5和临时文件1指定了新名称。该脚本未为数据文件6设置新名称，因为它位于TOOLS表空间中，该表空间已从重复数据库中排除。
RUN
{
SET NEWNAME FOR DATAFILE 1 TO '/oradata1/system01.dbf'; 
SET NEWNAME FOR DATAFILE 2 TO '/oradata2/sysaux01.dbf';
SET NEWNAME FOR DATAFILE 3 TO '/oradata3/undotbs01.dbf';
SET NEWNAME FOR DATAFILE 4 TO '/oradata4/users01.dbf'; 
SET NEWNAME FOR DATAFILE 5 TO '/oradata5/users02.dbf';
SET NEWNAME FOR TEMPFILE 1 TO '/oradatat/temp01.dbf'; 
DUPLICATE TARGET DATABASE TO dupdb
  SKIP TABLESPACE tools
  LOGFILE
     GROUP 1 ('/duplogs/redo01a.log','/duplogs/redo01b.log') SIZE 4M REUSE, 
     GROUP 2 ('/duplogs/redo02a.log', '/duplogs/redo02b.log') SIZE 4M REUSE;
}

##2.并使用单个SET NEWNAME命令命名表空间用户中的所有数据文件。 示例完成后，表空间用户的文件名设置为：/oradata4/users01.dbf和/oradata5/users02.dbf。
{
SET NEWNAME FOR TABLESPACE users TO '/oradata%f/%b';
SET NEWNAME FOR DATAFILE 1 TO '/oradata1/system01.dbf';
SET NEWNAME FOR DATAFILE 2 TO '/oradata2/sysaux01.dbf';
SET NEWNAME FOR DATAFILE 3 TO '/oradata3/undotbs01.dbf';
SET NEWNAME FOR TEMPFILE 1 TO '/oradatat/temp01.dbf';
DUPLICATE TARGET DATABASE TO dupdb
SKIP TABLESPACE tools
LOGFILE
   GROUP 1 ('/duplogs/redo01a.log','/duplogs/redo01b.log') SIZE 4M REUSE,
   GROUP 2 ('/duplogs/redo02a.log','/duplogs/redo02b.log') SIZE 4M REUSE;
}

##3.使用单个SET命令命名数据库中的所有数据文件。
RUN
{
SET NEWNAME FOR DATABASE TO '/oradata/%U';
DUPLICATE TARGET DATABASE TO dupdb
  SKIP TABLESPACE tools
  LOGFILE
    GROUP 1 ('/duplogs/redo01a.log','/duplogs/redo01b.log') SIZE 4M REUSE,
    GROUP 2 ('/duplogs/redo02a.log','/duplogs/redo02b.log') SIZE 4M REUSE;
}

bash复制代码##Example

##1.USER表空间的文件是用OMF托管，因此使用set newname to new
RUN
{
SET NEWNAME FOR TABLESPACE users TO NEW;
SET NEWNAME FOR DATAFILE 3 TO NEW;
SET NEWNAME FOR DATAFILE 1 TO '/oradata1/system01.dbf';
SET NEWNAME FOR DATAFILE 2 TO '/oradata2/sysaux01.dbf';
SET NEWNAME FOR TEMPFILE 1 TO '/oradatat/temp01';
DUPLICATE TARGET DATABASE TO dupdb
  SKIP TABLESPACE tools
  LOGFILE
    GROUP 1 ('/duplogs/redo01a.log','/duplogs/redo01b.log') SIZE 4M REUSE,
    GROUP 2 ('/duplogs/redo02a.log','/duplogs/redo02b.log') SIZE 4M REUSE;
}

##2.用SET NEWNAME在ASM创建文件
RUN
{
SET NEWNAME FOR DATAFILE 1 TO "+DGROUP1";
SET NEWNAME FOR DATAFILE 2 TO "+DGROUP2";
.
.
.
DUPLICATE TARGET DATABASE
TO dupdb
FROM ACTIVE DATABASE
SPFILE SET DB_CREATE_FILE_DEST +DGROUP3;
}

bash复制代码##Example:

##1.以指定文件数据文件1到5的名称
CONFIGURE AUXNAME FOR DATAFILE 1 TO '/oradata1/system01.dbf';
CONFIGURE AUXNAME FOR DATAFILE 2 TO '/oradata2/sysaux01.dbf';
CONFIGURE AUXNAME FOR DATAFILE 3 TO '/oradata3/undotbs01.dbf';
CONFIGURE AUXNAME FOR DATAFILE 4 TO '/oradata4/users01.dbf'; 
CONFIGURE AUXNAME FOR DATAFILE 5 TO '/oradata5/users02.dbf';
SET NEWNAME FOR TEMPFILE 1 TO '/oradatat/temp01.dbf'; 
DUPLICATE TARGET DATABASE
  TO dupdb
  SKIP TABLESPACE tools
  LOGFILE
     GROUP 1 ('/duplogs/redo01a.log','/duplogs/redo01b.log') SIZE 4M REUSE,
     GROUP 2 ('/duplogs/redo02a.log','/duplogs/redo02b.log') SIZE 4M REUSE;

bash复制代码##Example

##1.假设源数据库prod在host1上，并将其数据文件存储在非ASM文件系统中。 prod的控制文件位于/ oracle / oradata / prod /中。 您要将源数据库复制到远程主机host2上的数据库dupdb中。 您要将重复的数据库文件存储在ASM磁盘组+ DISK1中。

DUPLICATE TARGET DATABASE TO dupdb
FROM ACTIVE DATABASE
SPFILE
PARAMETER_VALUE_CONVERT '/oracle/oradata/prod/', '+DISK1'
SET DB_CREATE_FILE_DEST +DISK1;

##DUPLICATE命令完成后，将创建重复数据库，其中包含ASM磁盘组+DISK1中的数据文件，联机重做日志文件和控制文件。


##2.假定源数据库prod在host1上，并将其数据文件存储在ASM磁盘组+DISK1中。 您要将目标复制到远程主机host2上的数据库dupdb。 您想要将dupdb的数据文件存储在ASM中。

DUPLICATE TARGET DATABASE
TO dupdb
FROM ACTIVE DATABASE
SPFILE PARAMETER_VALUE_CONVERT '+DISK1','+DISK2'
SET DB_RECOVERY_FILE_DEST_SIZE='750G';

##当DUPLICATE命令完成时，将创建重复的数据库，其中包含较大ASM磁盘组+DISK2中的数据文件，联机重做日志和控制文件。

bash复制代码1.不能使用DUPLICATE命令的DB_FILE_NAME_CONVERT选项来控制源数据库实例中OMF格式的辅助实例中文件的新名称的生成。
2.不能使用LOG_FILE_NAME_CONVERT初始化参数来控制源数据库实例中OMF格式的重复实例中文件的新名称的生成。
3.如果设置OMF初始化参数，请不要指定LOG_FILE_NAME_CONVERT参数。
4.LOG_FILE_NAME_CONVERT参数不能在DUPLICATE命令中指定为子句，而只能在辅助实例的初始化参数中指定。

bash复制代码SID_LIST_LISTENER =
  (SID_LIST =
    (SID_DESC =
      (GLOBAL_DBNAME = orcl)
      (ORACLE_HOME = /u01/app/oracle/product/11.2.0/db)
      (SID_NAME = orcl)
    )
  )

java复制代码/**
 * @author 小黑说Java
 * @ClassName Computer
 * @date 2021/11/17
 **/
public abstract class Computer {

    /**
     * 内存
     */
    public abstract String getRAM();

    /**
     * 硬盘
     */
    public abstract String getHDD();

    /**
     * CPU
     */
    public abstract String getCPU();

    @Override
    public String toString() {
        return "RAM= " + this.getRAM() + ", HDD=" + this.getHDD() + ", CPU=" + this.getCPU();
    }
}

java复制代码/**
 * @author 小黑说Java
 * @ClassName PC
 * @date 2021/11/17
 **/
public class PC extends Computer {

    private String ram;
    private String hdd;
    private String cpu;

    public PC(String ram, String hdd, String cpu) {
        this.ram = ram;
        this.hdd = hdd;
        this.cpu = cpu;
    }

    @Override
    public String getRAM() {
        return ram;
    }

    @Override
    public String getHDD() {
        return hdd;
    }

    @Override
    public String getCPU() {
        return cpu;
    }
}

java复制代码/**
 * @author 小黑说Java
 * @ClassName Laptop
 * @date 2021/11/17
 **/
public class Laptop extends Computer{
    private String ram;
    private String hdd;
    private String cpu;
    
    public Laptop(String ram, String hdd, String cpu) {
        this.ram = ram;
        this.hdd = hdd;
        this.cpu = cpu;
    }
    @Override
    public String getRAM() {
        return ram;
    }

    @Override
    public String getHDD() {
        return hdd;
    }

    @Override
    public String getCPU() {
        return cpu;
    }
}

java复制代码/**
 * @author 小黑说Java
 * @ClassName ComputerFactory
 * @date 2021/11/17
 **/
public class ComputerFactory {

    public static Computer getComputer(String type, String ram, String hdd, String cpu) {
        if ("PC".equalsIgnoreCase(type)) {
            return new PC(ram, hdd, cpu);
        }
        if ("Laptop".equalsIgnoreCase(type)) {
            return new Laptop(ram, hdd, cpu);
        }
        return null;
    }
}

java复制代码/**
 * @author 小黑说Java
 * @ClassName FactoryTest
 * @date 2021/11/17
 **/
public class FactoryTest {

    public static void main(String[] args) {
        Computer pc = ComputerFactory.getComputer("PC", "16GB", "500GB", "2.4GHz");

        Computer laptop = ComputerFactory.getComputer("Laptop", "16GB", "500GB", "2.4GHz");

        System.out.println("PC:"+pc);
        System.out.println("laptop:"+laptop);
    }
}

java复制代码public class UserService {
    @Autowired 
    private UserDao userDao;

    public User getCurrentLoginUser() {
        return userDao.getUserById(1);
    }
}

java复制代码public class UserService {
    @Autowired
    private UserDao userDao;

    public User getCurrentLoginUser() {
        // getUserById模拟的返回用户对象
        return userDao.getUserById(1);
    }
}

java复制代码public class UserDao {
    public User getUserById(Integer id) {
        System.out.println("返回了一个用户");
        return new User(id, "user" + id);
    }
}

java复制代码import org.springframework.beans.factory.annotation.Autowired;

import java.io.IOException;
import java.lang.reflect.Field;
import java.lang.reflect.InvocationTargetException;
import java.util.*;
import java.util.stream.Collectors;

public class MyIoCContainer {
    private Map<String, Object> beansCache = new HashMap<>();

    public static void main(String[] args) {
        // 创建一个容器并启动
        MyIoCContainer container = new MyIoCContainer();
        container.start();
        // 通过getBean获取实例，并调用其方法
        UserService userService = (UserService) container.getBean("userService");
        userService.getCurrentLoginUser();
    }

    // 启动该容器
    public void start() {
        Properties properties = new Properties();
        try {
            properties.load(MyIoCContainer.class.getResourceAsStream("/beans.properties"));
            properties.forEach((propertyName, propertyClassName) -> {
                try {
                    beansCache.put((String) propertyName, 
                            Class.forName((String) propertyClassName).getConstructor().newInstance());
                } catch (InstantiationException | IllegalAccessException | InvocationTargetException | NoSuchMethodException | ClassNotFoundException e) {
                    e.printStackTrace();
                }
            });
        } catch (IOException e) {
            e.printStackTrace();
        }
        // 使用lambdab表达式简化代码
        beansCache.forEach((beanName, beanInstance) -> dependencyInjection(beanInstance, beansCache));
    }

    // 实现依赖注入
    private void dependencyInjection(Object beanInstance, Map<String, Object> beansCache) {
        // Stream结合lambda表达式
        // 得到所有带@Autowired注解的字段
        List<Field> fieldList = Arrays.stream(beanInstance.getClass().getDeclaredFields())
            .filter(field -> field.getAnnotation(Autowired.class) != null)
            .collect(Collectors.toList());
        
        // 自动装配对应的对象实例
        fieldList.forEach(field -> {
            String fieldName = field.getName();
            field.setAccessible(true);
            try {
                field.set(beanInstance, beansCache.get(fieldName));
            } catch (IllegalAccessException e) {
                e.printStackTrace();
            }
        });
    }

    // 从容器中获取一个bean
    public Object getBean(String beanName) {
        return beansCache.get(beanName);
    }
}